go/starter
1
0
Fork 0
mirror of https://github.com/ManyakRus/starter.git synced 2025-12-01 23:51:28 +02:00
Code Issues Releases Activity

сделал PprofNats1()

Browse Source
This commit is contained in:
Nikitin Aleksandr
2025-04-08 15:23:40 +03:00
parent b2c4f1c96b
commit 429a0447f1
4 changed files with 58 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
sync_exchange_connect/sync_exchange_connect.go
View File

@@ -17,8 +17,11 @@ import (
"time"
)
// TopicNamePprofSuffix - имя суффикса топика с профилем памяти
const TopicNamePprofSuffix = ".heap_profile"
// TopicNamePprof_Heap_Suffix - имя суффикса топика с профилем памяти
const TopicNamePprof_Heap_Suffix = ".heap_profile"
// TopicNamePprof_Goroutine_Suffix - имя суффикса топика с профилем памяти
const TopicNamePprof_Goroutine_Suffix = ".goroutine_profile"
// serviceName - имя сервиса который подключается
var serviceName string
@@ -149,7 +152,7 @@ func SendResponseError(sp *sync_types.SyncPackage, err error) {
// Start_PprofNats - профилирование памяти отправляет в NATS, бесконечно + WaitGroup
func Start_PprofNats() {
TextTest := TextTestOrEmpty()
topicHeapProfile := serviceName + TextTest + TopicNamePprofSuffix
topicHeapProfile := serviceName + TextTest + TopicNamePprof_Heap_Suffix
log.Info("Start_PprofNats(), topic: ", topicHeapProfile)
stopapp.GetWaitGroup_Main().Add(1)
@@ -190,8 +193,31 @@ loop:
func PprofNats1() error {
var err error
//память
err = PprofMemoryProfile1()
if err != nil {
err = fmt.Errorf("PprofMemoryProfile1(), error: %w", err)
log.Error(err)
return err
}
//горутины
err = PprofGoroutines1()
if err != nil {
err = fmt.Errorf("PprofMemoryProfile1(), error: %w", err)
log.Error(err)
return err
}
return err
}
// PprofMemoryProfile1 - профилирование памяти отправляет в NATS 1 раз
func PprofMemoryProfile1() error {
var err error
TextTest := TextTestOrEmpty()
topicHeapProfile := serviceName + TextTest + TopicNamePprofSuffix
topicHeapProfile := serviceName + TextTest + TopicNamePprof_Heap_Suffix
var buf bytes.Buffer
err = pprof.WriteHeapProfile(&buf)
if err != nil {
@@ -211,6 +237,31 @@ func PprofNats1() error {
return err
}
// PprofGoroutines1 - профилирование горутин отправляет в NATS 1 раз
func PprofGoroutines1() error {
var err error
TextTest := TextTestOrEmpty()
topicHeapProfile := serviceName + TextTest + TopicNamePprof_Goroutine_Suffix
var buf bytes.Buffer
err = pprof.Lookup("goroutine").WriteTo(&buf, 2)
if err != nil {
err = fmt.Errorf("pprof.WriteHeapProfile(), topic: %v, error: %w", topicHeapProfile, err)
log.Error(err)
time.Sleep(10 * time.Second)
return err
}
err = sync_exchange.SendRawMessage(topicHeapProfile, buf.Bytes())
if err != nil {
err = fmt.Errorf("sync_exchange.SendRawMessage(), topic: %v, error: %w", topicHeapProfile, err)
log.Error(err)
time.Sleep(10 * time.Second)
return err
}
return err
}
// TextTestOrEmpty - возвращает "_test" или ""
func TextTestOrEmpty() string {
Otvet := "_test"