plugin

Documentation

Index

• func NewTezosDatasource(_ backend.DataSourceInstanceSettings, storage *bolt.BoltStorage) (instancemgmt.Instance, error)
• type TezosDatasource
  • func (d *TezosDatasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (d *TezosDatasource) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (d *TezosDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (d *TezosDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (d *TezosDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

Functions

func NewTezosDatasource

func NewTezosDatasource(_ backend.DataSourceInstanceSettings, storage *bolt.BoltStorage) (instancemgmt.Instance, error)

Types

type TezosDatasource

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

func (*TezosDatasource) CheckHealth

func (d *TezosDatasource) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*TezosDatasource) PublishStream

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

func (*TezosDatasource) QueryData

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

func (*TezosDatasource) RunStream

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

func (*TezosDatasource) SubscribeStream

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