vernemqtt

Documentation

Index

• func GetLogger() *slog.Logger
• func InitWebhooks(ctx context.Context, config configuration.Config, ...)
• type DisconnectWebhookMsg
• type LoggerMiddleWare
  • func Logger(handler http.Handler) *LoggerMiddleWare
  • func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type LoginWebhookMsg
• type OnlineWebhookMsg
• type PublishWebhookMsg
• type SubscribeWebhookMsg
• type SubscribeWebhookResult
• type UnsubscribeWebhookMsg
• type WebhookmsgTopic

Functions

func GetLogger

func GetLogger() *slog.Logger

func InitWebhooks

func InitWebhooks(ctx context.Context, config configuration.Config, connector *platform_connector_lib.Connector, connectionLog connectionlog.ConnectionLog)

Types

type DisconnectWebhookMsg

type DisconnectWebhookMsg struct {
	ClientId string `json:"client_id"`
}

type LoggerMiddleWare

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

func Logger

func Logger(handler http.Handler) *LoggerMiddleWare

func (*LoggerMiddleWare) ServeHTTP

func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)

type LoginWebhookMsg

type LoginWebhookMsg struct {
	PeerAddr     string `json:"peer_addr"`
	PeerPort     int    `json:"peer_port"`
	Username     string `json:"username"`
	Password     string `json:"password"`
	ClientId     string `json:"client_id"`
	CleanSession bool   `json:"clean_session"` //v4
	CleanStart   bool   `json:"clean_start"`   //v5
}

type OnlineWebhookMsg

type OnlineWebhookMsg struct {
	ClientId string `json:"client_id"`
}

type PublishWebhookMsg

type PublishWebhookMsg struct {
	Username string `json:"username"`
	ClientId string `json:"client_id"`
	Topic    string `json:"topic"`
	Payload  string `json:"payload"`
	Qos      int    `json:"qos"`
}

type SubscribeWebhookMsg

type SubscribeWebhookMsg struct {
	Username string            `json:"username"`
	ClientId string            `json:"client_id"`
	Topics   []WebhookmsgTopic `json:"topics"`
}

type SubscribeWebhookResult

type SubscribeWebhookResult struct {
	Result string            `json:"result"`
	Topics []WebhookmsgTopic `json:"topics"`
}

type UnsubscribeWebhookMsg

type UnsubscribeWebhookMsg struct {
	Username string   `json:"username"`
	ClientId string   `json:"client_id"`
	Topics   []string `json:"topics"`
}

type WebhookmsgTopic

type WebhookmsgTopic struct {
	Topic string `json:"topic"`
	Qos   int64  `json:"qos"`
}