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, deviceUri string, serviceUri string, err error)
• func ParseTopicWithOwner(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, deviceUri string, serviceUri string, err error)

func ParseTopicWithOwner

func ParseTopicWithOwner(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)