emq

Documentation

Index

• func Connect(cfg Config) mqtt.Client
• type Config
• type Emq
  • func (e Emq) Publish(topic string, data interface{})
  • func (e Emq) Subscribe(topic string, callback mqtt.MessageHandler)
• type Event
• type EventType

Functions

func Connect

func Connect(cfg Config) mqtt.Client

Types

type Config

type Config struct {
	ClientID string `koanf:"client_id"`
	URL      string `koanf:"url"`
}

type Emq

type Emq struct {
	Client mqtt.Client
	Logger *zap.Logger
}

func (Emq) Publish

func (e Emq) Publish(topic string, data interface{})

func (Emq) Subscribe

func (e Emq) Subscribe(topic string, callback mqtt.MessageHandler)

type Event

type Event struct {
	Type    EventType   `json:"type,omitempty"`
	Payload interface{} `json:"payload,omitempty"`
}

type EventType

type EventType string

const (
	RoomCreated EventType = "room-created"
	RoomDeleted EventType = "room-deleted"
	JoinRoom    EventType = "join-room"
)