datasourcetest

Documentation

Index

• type ManageOpts
• type TestPlugin
  • func Manage(instanceFactory datasource.InstanceFactoryFunc, opts ManageOpts) (TestPlugin, error)
  • func (p *TestPlugin) Shutdown() error
• type TestPluginClient
  • func (p *TestPluginClient) CallResource(ctx context.Context, r *backend.CallResourceRequest, ...) error
  • func (p *TestPluginClient) CheckHealth(ctx context.Context, r *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (p *TestPluginClient) QueryData(ctx context.Context, r *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
• type TestPluginServer

Types

type ManageOpts

type ManageOpts struct {
	Address string
}

type TestPlugin

type TestPlugin struct {
	Client *TestPluginClient
	Server *TestPluginServer
}

func Manage

func Manage(instanceFactory datasource.InstanceFactoryFunc, opts ManageOpts) (TestPlugin, error)

func (*TestPlugin) Shutdown

func (p *TestPlugin) Shutdown() error

type TestPluginClient

type TestPluginClient struct {
	DataClient        pluginv2.DataClient
	DiagnosticsClient pluginv2.DiagnosticsClient
	ResourceClient    pluginv2.ResourceClient
	// contains filtered or unexported fields
}

func (*TestPluginClient) CallResource

func (p *TestPluginClient) CallResource(ctx context.Context, r *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

func (*TestPluginClient) CheckHealth

func (p *TestPluginClient) CheckHealth(ctx context.Context, r *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*TestPluginClient) QueryData

func (p *TestPluginClient) QueryData(ctx context.Context, r *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

type TestPluginServer

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