sync_exchange_connect

Documentation

Overview

модуль для обмена с сервисом NATS через sync_exchange

Index

• func CloseConnection()
• func Connect(ServiceName, ServiceVersion string)
• func Connect_err(ServiceName, ServiceVersion string) error
• func LogInfo_Connected(err error)
• func SendResponseError(sp *sync_types.SyncPackage, err error)
• func Start(ServiceName, ServiceVersion string)
• func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ...) error
• func WaitStop()

Functions

func CloseConnection

func CloseConnection()

CloseConnection - закрывает соединение с NATS

func Connect

func Connect(ServiceName, ServiceVersion string)

Connect - подключение к NATS SyncExchange

func Connect_err

func Connect_err(ServiceName, ServiceVersion string) error

Connect_err - подключение к NATS SyncExchange

func LogInfo_Connected

func LogInfo_Connected(err error)

LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке

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_ctx

func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName, ServiceVersion string) error

Start_ctx - необходимые процедуры для подключения к NATS с библиотекой SyncExchange Свой контекст и WaitGroup нужны для остановки работы сервиса Graceful shutdown Для тех кто пользуется этим репозиторием для старта и останова сервиса можно просто Start()

func WaitStop

func WaitStop()

WaitStop - ожидает отмену глобального контекста или сигнала завершения приложения