Documentation
¶
Index ¶
- func NewDatasource(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
- type Datasource
- func (ds *Datasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
- func (ds *Datasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
- func (ds *Datasource) Dispose()
- func (ds *Datasource) ExecuteAction(ctx context.Context, cmd actions.ActionCommand) actions.ActionResponse
- func (ds *Datasource) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
- func (ds *Datasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
- func (ds *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
- func (ds *Datasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
- type SignalStreamer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDatasource ¶
func NewDatasource(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
NewMQTTDatasource creates a new datasource instance.
Types ¶
type Datasource ¶
type Datasource struct {
// contains filtered or unexported fields
}
func (*Datasource) CallResource ¶
func (ds *Datasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error
func (*Datasource) CheckHealth ¶
func (ds *Datasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
func (*Datasource) Dispose ¶
func (ds *Datasource) Dispose()
Dispose here tells plugin SDK that plugin wants to clean up resources when a new instance created. As soon as datasource settings change detected by SDK old datasource instance will be disposed and a new one will be created using NewSampleDatasource factory function.
func (*Datasource) ExecuteAction ¶
func (ds *Datasource) ExecuteAction(ctx context.Context, cmd actions.ActionCommand) actions.ActionResponse
func (*Datasource) PublishStream ¶
func (ds *Datasource) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
func (*Datasource) QueryData ¶
func (ds *Datasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
func (*Datasource) RunStream ¶
func (ds *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender backend.StreamPacketSender) error
func (*Datasource) SubscribeStream ¶
func (ds *Datasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
type SignalStreamer ¶
type SignalStreamer struct {
// contains filtered or unexported fields
}
DatasourceHandler is the plugin entrypoint and implements all of the necessary handler functions for dataqueries, healthchecks, and resources.
func (*SignalStreamer) UpdateValues ¶
func (s *SignalStreamer) UpdateValues(props map[string]interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.