mq

Documentation

Index

• Constants
• func GetClient() *nats.Conn
• func GetJetStream() (nats.JetStreamContext, error)

Constants

const (
	StreamVideo          = "VIDEO"
	SubjectVideo         = "video"
	SubjectGetDeviceInfo = "GetDeviceInfo"
	GroupVideo           = "video-group"
)

video subject

const (
	StreamDevice                 = "DEVICE"
	StreamDeviceData             = "DEVICE_DATA"
	StreamDeviceTelemetry        = "DEVICE_TELEMETRY"
	StreamDeviceHealth           = "DEVICE_HEALTH"
	SubjectDevicPrefix           = "device."
	SubjectDeviceData            = "device_data"
	SubjectDeviceTelemetryPrefix = "device.telemetry."
	SubjectDeviceHealthPrefix    = "device.health."
	GroupDevice                  = "group.device"
	GroupSaveDeviceData          = "group.device.data.save"
	GroupPublishDeviceData       = "group.device.data.pub"
)

device subject

Functions

func GetClient

func GetClient() *nats.Conn

GetClient get mq connection

func GetJetStream

func GetJetStream() (nats.JetStreamContext, error)

GetClient get mq connection