nats_connect

Documentation

Index

• Variables
• func CloseConnection()
• func Connect()
• func Connect_err() error
• func FillSettings()
• func SendMessage(subject string, data []byte) error
• func SendMessageCtx(ctx context.Context, subject string, data []byte) error
• func StartNats()
• func WaitStop()
• type SettingsINI

Variables

var Conn *nats.Conn

Conn - соединение к серверу nats

Functions

func CloseConnection

func CloseConnection()

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

func Connect

func Connect()

Connect - подключается к серверу Nats

func Connect_err

func Connect_err() error

Connect_err - подключается к серверу Nats и возвращает ошибку

func FillSettings

func FillSettings()

FillSettings загружает переменные окружения в структуру из файла или из переменных окружения

func SendMessage

func SendMessage(subject string, data []byte) error

SendMessage - Отправляет сообщение

func SendMessageCtx

func SendMessageCtx(ctx context.Context, subject string, data []byte) error

SendMessageCtx - Отправляет сообщение, учитывает таймаут контекста

func StartNats

func StartNats()

StartNats - необходимые процедуры для подключения к серверу Nats

func WaitStop

func WaitStop()

WaitStop - ожидает отмену глобального контекста

Types

type SettingsINI

type SettingsINI struct {
	NATS_HOST     string
	NATS_PORT     string
	NATS_LOGIN    string
	NATS_PASSWORD string
}

SettingsINI - структура для хранения всех нужных переменных окружения

var Settings SettingsINI

Settings хранит все нужные переменные окружения