nats

Documentation

Index

• Constants
• Variables
• func ListenForever()
• func NextMessageRequest() (types.MessageNatsIn, error)
• func ReceiveMessageFromNats() (types.MessageNatsIn, bool)
• func StartNats()
• func SubscribeTopics()
• func WaitStop()

Constants

const PAUSE_WAIT_NEW_MESSAGE = 1000

PAUSE_WAIT_NEW_MESSAGE - количество миллисекунд паузы обращения к серверу NATS

Variables

var NatsSubscriptionIn *nats.Subscription

NatsSubscriptionIn - подписка на нужный топик

var TOPIC_PDF_IN = "/claim/pdf_generator/in/"

Functions

func ListenForever

func ListenForever()

ListenForever - бесконечный цикл получения данных с сервера Nats

func NextMessageRequest

func NextMessageRequest() (types.MessageNatsIn, error)

NextMessageRequest - получает следующее 1 сообщение с сервера Nats

func ReceiveMessageFromNats

func ReceiveMessageFromNats() (types.MessageNatsIn, bool)

ReceiveMessageFromNats - получение 1 сообщения с сервера Nats возвращает true если есть сообщение

func StartNats

func StartNats()

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

func SubscribeTopics

func SubscribeTopics()

SubscribeTopics - подписывается на топики nats

func WaitStop

func WaitStop()

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