plugin

Documentation

Index

• func NewKafkaInstance(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• type KafkaDatasource
  • func (d *KafkaDatasource) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (d *KafkaDatasource) Dispose()
  • func (d *KafkaDatasource) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (d *KafkaDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (d *KafkaDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (d *KafkaDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

Functions

func NewKafkaInstance

func NewKafkaInstance(s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

Types

type KafkaDatasource

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

func (*KafkaDatasource) CheckHealth

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

func (*KafkaDatasource) Dispose

func (d *KafkaDatasource) Dispose()

func (*KafkaDatasource) PublishStream

func (d *KafkaDatasource) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*KafkaDatasource) QueryData

func (d *KafkaDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*KafkaDatasource) RunStream

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

func (*KafkaDatasource) SubscribeStream

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