plugin

Documentation

Index

• Variables
• func NewDatasource(_ context.Context, s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• type Datasource
  • func (d *Datasource) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (d *Datasource) Dispose()
  • func (d *Datasource) PublishStream(context.Context, *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (d *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (d *Datasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)
• type Query

Variables

var Logger = backend.Logger

Functions

func NewDatasource

func NewDatasource(_ context.Context, s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

Types

type Datasource

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

func (*Datasource) CheckHealth

func (d *Datasource) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*Datasource) Dispose

func (d *Datasource) Dispose()

func (*Datasource) PublishStream

func (d *Datasource) PublishStream(context.Context, *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*Datasource) RunStream

func (d *Datasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

func (*Datasource) SubscribeStream

func (d *Datasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

type Query

type Query struct {
	TopicName string `json:"topicName"`
}