bus

Documentation

Index

• Constants
• func AddStream(name string, subjects ...string) error
• func Close()
• func PublishMessage(subject string, msg message.Message) error
• func StartSubscriptions(consumer string)
• func Subscribe(name string, handler message.Subscriber)
• func Subscriber(topic string) message.Subscriber

Constants

const (
	NatsUrlEnvVariableName = "NATS_URL"
)

Functions

func AddStream

func AddStream(name string, subjects ...string) error

AddStream add new stream with dedicated subjects

func Close

func Close()

Close closes NATS connections

func PublishMessage

func PublishMessage(subject string, msg message.Message) error

PublishMessage publishes message to subject subject - subject where message be published msg - Message to publish

func StartSubscriptions

func StartSubscriptions(consumer string)

StartSubscriptions - actually subscribe on NATS jet stream

func Subscribe

func Subscribe(name string, handler message.Subscriber)

Subscribe - provide handler func to subject subject - subscribe to handler - handler func which would be invoked on incoming message

func Subscriber

func Subscriber(topic string) message.Subscriber

Subscriber - returns subscriber which publishes message in NATS stream