response

Documentation

Index

• type Handler
  • func New(config configuration.Config, connector *platform_connector_lib.Connector, ...) *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 handler.Result, err error)
• type ResponseEnvelope

Types

type Handler

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

func New

func New(config configuration.Config, connector *platform_connector_lib.Connector, correlation *correlation.CorrelationService) *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)

func (*Handler) Subscribe

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

type ResponseEnvelope

type ResponseEnvelope struct {
	CorrelationId string                                    `json:"correlation_id"`
	Payload       platform_connector_lib.CommandResponseMsg `json:"payload"`
	Trace         []model.Trace                             `json:"trace,omitempty"`
}