vernemq

Documentation

Index

• type Subscription
• type SubscriptionWrapper
• type Vernemq
  • func New(config configuration.Config, metrics *prometheus.Metrics) *Vernemq
  • func (this *Vernemq) CheckClient(clientId string) (onlineClientExists bool, err error)
  • func (this *Vernemq) CheckTopic(topic string) (result bool, err error)

Types

type Subscription

type Subscription struct {
	ClientId string `json:"client_id"`
	User     string `json:"user"`
	Topic    string `json:"topic"`
	IsOnline bool   `json:"is_online"`
}

type SubscriptionWrapper

type SubscriptionWrapper struct {
	Table []Subscription `json:"table"`
}

type Vernemq

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

func New

func New(config configuration.Config, metrics *prometheus.Metrics) *Vernemq

func (*Vernemq) CheckClient

func (this *Vernemq) CheckClient(clientId string) (onlineClientExists bool, err error)

func (*Vernemq) CheckTopic

func (this *Vernemq) CheckTopic(topic string) (result bool, err error)