plugin

Documentation

Index

• func GetDatasourceOpts() datasource.ServeOpts
• func GetDatasourceSettings(s backend.DataSourceInstanceSettings) (*mqtt.Options, error)
• func NewServerInstance(settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• func ToFrame(messages []mqtt.Message) *data.Frame
• type Handler
  • func (h *Handler) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (h *Handler) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (h *Handler) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (h *Handler) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (h *Handler) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
• type MQTTClient
• type MQTTDatasource
  • func NewMQTTDatasource(s backend.DataSourceInstanceSettings) (*MQTTDatasource, error)
  • func (m *MQTTDatasource) Dispose()
  • func (m *MQTTDatasource) Query(query backend.DataQuery) backend.DataResponse
  • func (m *MQTTDatasource) SendMessage(msg mqtt.StreamMessage, req *backend.RunStreamRequest, ...) error

Functions

func GetDatasourceOpts

func GetDatasourceOpts() datasource.ServeOpts

func GetDatasourceSettings

func GetDatasourceSettings(s backend.DataSourceInstanceSettings) (*mqtt.Options, error)

func NewServerInstance

func NewServerInstance(settings backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

func ToFrame

func ToFrame(messages []mqtt.Message) *data.Frame

Types

type Handler

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

func (*Handler) CheckHealth

func (h *Handler) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*Handler) PublishStream

func (h *Handler) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*Handler) QueryData

func (h *Handler) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*Handler) RunStream

func (h *Handler) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender backend.StreamPacketSender) error

func (*Handler) SubscribeStream

func (h *Handler) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

type MQTTClient

type MQTTClient interface {
	Stream() *chan mqtt.StreamMessage
	IsConnected() bool
	IsSubscribed(topic string) bool
	Messages(topic string) ([]mqtt.Message, bool)
	Subscribe(topic string)
}

type MQTTDatasource

type MQTTDatasource struct {
	Client MQTTClient
	// contains filtered or unexported fields
}

func NewMQTTDatasource

func NewMQTTDatasource(s backend.DataSourceInstanceSettings) (*MQTTDatasource, error)

func (*MQTTDatasource) Dispose

func (m *MQTTDatasource) Dispose()

func (*MQTTDatasource) Query

func (m *MQTTDatasource) Query(query backend.DataQuery) backend.DataResponse

func (*MQTTDatasource) SendMessage

func (m *MQTTDatasource) SendMessage(msg mqtt.StreamMessage, req *backend.RunStreamRequest, sender backend.StreamPacketSender) error