brokers

Documentation

Index

• Constants
• func NewPubSub(url, queue string, logger logger.Logger) (messaging.PubSub, error)
• func NewPublisher(url string) (messaging.Publisher, error)

Constants

const (
	// SubjectSenML represents subject to subscribe for the SenML messages.
	SubjectSenML = "channels.*.senml.>"
	// SubjectJSON represents subject to subscribe for the JSON messages.
	SubjectJSON = "channels.*.json.>"
	// SubjectSmtp represents subject to subscribe for the SMTP notifications.
	SubjectSmtp = "smtp"
	// SubjectSmpp represents subject to subscribe for the SMPP notifications.
	SubjectSmpp = "smpp"
	// SubjectWebhook represents subject to subscribe for sending the Webhooks.
	SubjectWebhook = "webhook"
)

Functions

func NewPubSub

func NewPubSub(url, queue string, logger logger.Logger) (messaging.PubSub, error)

func NewPublisher

func NewPublisher(url string) (messaging.Publisher, error)