automanagement

Documentation

Index

• type Manager
  • func NewManager(instanceManager instancemgmt.InstanceManager) *Manager
  • func (m *Manager) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
  • func (m *Manager) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (m *Manager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (m *Manager) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (m *Manager) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (m *Manager) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

Types

type Manager

type Manager struct {
	instancemgmt.InstanceManager
}

Manager is a helper to simplify instance management for plugin developers. It gets instancemgmt.InstanceManager on every call thus making sure datasource instance disposed on configuration change and new datasource instance created.

func NewManager

func NewManager(instanceManager instancemgmt.InstanceManager) *Manager

NewManager creates Manager. It accepts datasource instance factory.

func (*Manager) CallResource

func (m *Manager) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

func (*Manager) CheckHealth

func (m *Manager) CheckHealth(ctx context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*Manager) PublishStream

func (m *Manager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*Manager) QueryData

func (m *Manager) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*Manager) RunStream

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

func (*Manager) SubscribeStream

func (m *Manager) SubscribeStream(ctx context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)