сделал PprofNats1()

sync_exchange_connect/sync_exchange_connect.go

@@ -11,6 +11,7 @@ import (
 	"github.com/ManyakRus/starter/stopapp"
 	"gitlab.aescorp.ru/dsp_dev/claim/common/sync_exchange"
 	"gitlab.aescorp.ru/dsp_dev/claim/common/sync_exchange/sync_types"
+	"os"
 	"runtime/pprof"
 	"sync"
 	"time"
@@ -175,7 +176,9 @@ loop:
 // PprofNats1 - профилирование памяти отправляет в NATS 1 раз
 func PprofNats1() error {
 	var err error
-	topicHeapProfile := serviceName + ".heap_profile"
+
+	TextTest := TextTestOrEmpty()
+	topicHeapProfile := serviceName + TextTest + ".heap_profile"
 	var buf bytes.Buffer
 	err = pprof.WriteHeapProfile(&buf)
 	if err != nil {
@@ -194,3 +197,17 @@ func PprofNats1() error {
 
 	return err
 }
+
+// TextTestOrEmpty - возвращает "_test" или ""
+func TextTestOrEmpty() string {
+	Otvet := "_test"
+	stage := os.Getenv("STAGE")
+	switch stage {
+	case "dev":
+		Otvet = ""
+	case "prod":
+		Otvet = ""
+	}
+
+	return Otvet
+}

sync_exchange_connect/sync_exchange_connect_test.go

@@ -57,3 +57,10 @@ func TestPprofNats1(t *testing.T) {
 
 	PprofNats1()
 }
+
+func TestTextTestOrEmpty(t *testing.T) {
+	Otvet := TextTestOrEmpty()
+	if Otvet != "" && Otvet != "_test" {
+		t.Errorf("TextTestOrEmpty() error: Otvet=%v", Otvet)
+	}
+}