services

Documentation

Index

• func InitializeNsqProducer()
• func ProduceInfo()
• func ShutdownProducer()
• type ConferencePacket
• type TiniyoMqttClient
  • func (tmc *TiniyoMqttClient) Initialize(topic string)
  • func (tmc *TiniyoMqttClient) Publish(cp ConferencePacket)

Functions

func InitializeNsqProducer

func InitializeNsqProducer()

func ProduceInfo

func ProduceInfo()

func ShutdownProducer

func ShutdownProducer()

Types

type ConferencePacket

type ConferencePacket struct {
	InfoType  string `json:"type"` /* request / notify / response */
	UserName  string `json:"user_name"`
	UserID    string `json:"user_id"`
	EventType string `json:"event_type"`
	EventName string `json:"event_name"`
	EventData string `json:"event_data"`
}

type TiniyoMqttClient

type TiniyoMqttClient struct {
	// contains filtered or unexported fields
}

func (*TiniyoMqttClient) Initialize

func (tmc *TiniyoMqttClient) Initialize(topic string)

func (*TiniyoMqttClient) Publish

func (tmc *TiniyoMqttClient) Publish(cp ConferencePacket)