handler

Documentation

Index

• Variables
• func CheckEvent(connector *platform_connector_lib.Connector, token security.JwtToken, ...) (err error)
• func CheckHub(connector *platform_connector_lib.Connector, token security.JwtToken, ...) (err error)
• func ParseTopic(topic string) (prefix string, ownerId string, deviceUri string, serviceUri string, err error)
• type Handler
• type Result
  • func HandleTopicSubscribe(clientId string, username string, topic string, handlers []Handler) (Result, error)

Variables

var ServiceNotFound = errors.New("service not found")

Functions

func CheckEvent

func CheckEvent(connector *platform_connector_lib.Connector, token security.JwtToken, deviceUri string, serviceUri string) (err error)

func CheckHub

func CheckHub(connector *platform_connector_lib.Connector, token security.JwtToken, hubId string, deviceUri string) (err error)

func ParseTopic

func ParseTopic(topic string) (prefix string, ownerId string, deviceUri string, serviceUri string, err error)

Types

type Handler

type Handler interface {
	Subscribe(clientId string, user string, topic string) (result Result, err error)
	Publish(clientId string, user string, topic string, payload []byte, qos int, size float64) (result Result, err error)
}

type Result

type Result int

const (
	Unhandled Result = iota
	Accepted
	Rejected
	Error
)

func HandleTopicSubscribe

func HandleTopicSubscribe(clientId string, username string, topic string, handlers []Handler) (Result, error)