Documentation
¶
Overview ¶
модуль для обмена с сервисом NATS через sync_exchange
Index ¶
- Constants
- func CloseConnection()
- func Connect(ServiceName, ServiceVersion string)
- func Connect_err(ServiceName, ServiceVersion string) error
- func LogInfo_Connected(err error)
- func PprofGoroutines1() error
- func PprofMemoryProfile1() error
- func PprofNats1() error
- func PprofNats_forever()
- func SendResponseError(sp *sync_types.SyncPackage, err error)
- func Start(ServiceName, ServiceVersion string)
- func Start_PprofNats()
- func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ...) error
- func TextTestOrEmpty() string
- func WaitStop()
Constants ¶
const TopicNamePprof_Goroutine_Suffix = ".goroutine_profile"
TopicNamePprof_Goroutine_Suffix - имя суффикса топика с профилем памяти
const TopicNamePprof_Heap_Suffix = ".heap_profile"
TopicNamePprof_Heap_Suffix - имя суффикса топика с профилем памяти
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect(ServiceName, ServiceVersion string)
Connect - подключение к NATS SyncExchange
func Connect_err ¶ added in v1.0.58
Connect_err - подключение к NATS SyncExchange
func LogInfo_Connected ¶ added in v1.0.58
func LogInfo_Connected(err error)
LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке
func PprofGoroutines1 ¶ added in v1.0.139
func PprofGoroutines1() error
PprofGoroutines1 - профилирование горутин отправляет в NATS 1 раз
func PprofMemoryProfile1 ¶ added in v1.0.139
func PprofMemoryProfile1() error
PprofMemoryProfile1 - профилирование памяти отправляет в NATS 1 раз
func PprofNats1 ¶ added in v1.0.133
func PprofNats1() error
PprofNats1 - профилирование памяти отправляет в NATS 1 раз
func PprofNats_forever ¶ added in v1.0.133
func PprofNats_forever()
PprofNats_forever - профилирование памяти отправляет в NATS, бесконечно
func SendResponseError ¶
func SendResponseError(sp *sync_types.SyncPackage, err error)
SendResponseError - Отправляет ответ в NATS SyncExchange
func Start ¶
func Start(ServiceName, ServiceVersion string)
Start - необходимые процедуры для подключения к серверу Nats SyncExchange
func Start_PprofNats ¶ added in v1.0.133
func Start_PprofNats()
Start_PprofNats - профилирование памяти отправляет в NATS, бесконечно + WaitGroup
func Start_ctx ¶ added in v1.0.58
func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName, ServiceVersion string) error
Start_ctx - необходимые процедуры для подключения к NATS с библиотекой SyncExchange Свой контекст и WaitGroup нужны для остановки работы сервиса Graceful shutdown Для тех кто пользуется этим репозиторием для старта и останова сервиса можно просто Start()
func TextTestOrEmpty ¶ added in v1.0.136
func TextTestOrEmpty() string
TextTestOrEmpty - возвращает "_test" или ""
Types ¶
This section is empty.
Source Files