Documentation
¶
Index ¶
- Constants
- Variables
- func CloseConnection()
- func Connect(ServiceName string)
- func Connect_err(ServiceName string) error
- func FillSettings()
- func GetContext() *context.Context
- func GetWaitGroup() *sync.WaitGroup
- func LogInfo_Connected(err error)
- func SendMessage(subject string, data []byte) error
- func SendMessageCtx(ctx context.Context, subject string, data []byte) error
- func SetContext(ctx *context.Context)
- func SetWaitGroup(wg *sync.WaitGroup)
- func StartNats(ServiceName string)
- func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName string) error
- func WaitStop()
- type SettingsINI
Constants ¶
const PackageName = "nats_connect"
PackageName - имя текущего пакета, для логирования
Variables ¶
var Conn *nats.Conn
Conn - соединение к серверу nats
Functions ¶
func CloseConnection ¶
func CloseConnection()
CloseConnection - закрывает соединение с сервером Nats
func Connect_err ¶
Connect_err - подключается к серверу Nats и возвращает ошибку
func FillSettings ¶
func FillSettings()
FillSettings загружает переменные окружения в структуру из файла или из переменных окружения
func GetContext ¶ added in v1.0.247
GetContext возвращает указатель на контекст с защитой RLock
func GetWaitGroup ¶ added in v1.0.247
GetWaitGroup - возвращает группу ожидания завершения всех частей программы
func LogInfo_Connected ¶ added in v1.0.58
func LogInfo_Connected(err error)
LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке
func SendMessage ¶
SendMessage - Отправляет сообщение
func SendMessageCtx ¶
SendMessageCtx - Отправляет сообщение, учитывает таймаут контекста
func SetContext ¶ added in v1.0.247
SetContext устанавливает новое значение контекста с защитой Lock
func SetWaitGroup ¶ added in v1.0.247
SetWaitGroup - присваивает внешний WaitGroup
func StartNats ¶
func StartNats(ServiceName string)
StartNats - необходимые процедуры для подключения к серверу Nats
Types ¶
type SettingsINI ¶
type SettingsINI struct {
NATS_HOST string
NATS_PORT string
NATS_LOGIN string
NATS_PASSWORD string
}
SettingsINI - структура для хранения всех нужных переменных окружения
var Settings SettingsINI
Settings хранит все нужные переменные окружения
Source Files