fog

Documentation

Index

• Constants
• type Handler
  • func NewHandler(producerProvider ProducerProvider, fogTopicPrefix string) *Handler
  • func (this *Handler) Publish(clientId string, user string, topic string, payload []byte, qos int, ...) (result handler.Result, err error)
  • func (this *Handler) Subscribe(clientId string, user string, topic string) (result Result, err error)
• type KeyWrapper
• type ProducerProvider
• type Result

Constants

const (
	Unhandled Result = handler.Unhandled
	Accepted         = handler.Accepted
	Rejected         = handler.Rejected
	Error            = handler.Error
)

Types

type Handler

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

func NewHandler

func NewHandler(producerProvider ProducerProvider, fogTopicPrefix string) *Handler

func (*Handler) Publish

func (this *Handler) Publish(clientId string, user string, topic string, payload []byte, qos int, size float64) (result handler.Result, err error)

the user param may be used in the future to check auth

func (*Handler) Subscribe

func (this *Handler) Subscribe(clientId string, user string, topic string) (result Result, err error)

the user param may be used in the future to check auth

type KeyWrapper

type KeyWrapper struct {
	Key string `json:"operator_id"`
}

type ProducerProvider

type ProducerProvider interface {
	GetProducer(qos platform_connector_lib.Qos) (producer kafka.ProducerInterface, err error)
}

type Result

type Result = handler.Result