component

Documentation

Index

• Constants
• Variables
• func CreateMqttClient(addressable domain.Addressable, token string)
• func WebSocketHandler(w http.ResponseWriter, r *http.Request)
• func WsClientSend(token string, message []byte)
• type WsClientConn

Constants

const (
	ReadBufferSize  = 1024
	WriteBufferSize = 1024
)

const (
	ClientIDPrefix = "edgex-go-"
)

Variables

var ExportSubscriberCache = make(map[string]interface{}, 10)

{token:MqttClient}

var MqttTokenCache string

Functions

func CreateMqttClient

func CreateMqttClient(addressable domain.Addressable, token string)

func WebSocketHandler

func WebSocketHandler(w http.ResponseWriter, r *http.Request)

func WsClientSend

func WsClientSend(token string, message []byte)

Types

type WsClientConn

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