capability

Documentation

Index

• func RegisterStandardCapabilitiesServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
• type StandardCapabilities
• type StandardCapabilitiesClient
  • func NewStandardCapabilitiesClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) *StandardCapabilitiesClient
  • func (c *StandardCapabilitiesClient) Close() error
  • func (c *StandardCapabilitiesClient) Infos(ctx context.Context) ([]capabilities.CapabilityInfo, error)
  • func (c *StandardCapabilitiesClient) Initialise(ctx context.Context, config string, telemetryService core.TelemetryService, ...) error

Functions

func RegisterStandardCapabilitiesServer

func RegisterStandardCapabilitiesServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl StandardCapabilities) error

Types

type StandardCapabilities

type StandardCapabilities interface {
	services.Service
	Initialise(ctx context.Context, config string, telemetryService core.TelemetryService, store core.KeyValueStore,
		capabilityRegistry core.CapabilitiesRegistry, errorLog core.ErrorLog,
		pipelineRunner core.PipelineRunnerService, relayerSet core.RelayerSet) error
	Infos(ctx context.Context) ([]capabilities.CapabilityInfo, error)
}

type StandardCapabilitiesClient

type StandardCapabilitiesClient struct {
	*goplugin.PluginClient
	capabilitiespb.StandardCapabilitiesClient
	*goplugin.ServiceClient
	*net.BrokerExt
	// contains filtered or unexported fields
}

func NewStandardCapabilitiesClient

func NewStandardCapabilitiesClient(brokerExt *net.BrokerExt, conn *grpc.ClientConn) *StandardCapabilitiesClient

func (*StandardCapabilitiesClient) Close

func (c *StandardCapabilitiesClient) Close() error

func (*StandardCapabilitiesClient) Infos

func (c *StandardCapabilitiesClient) Infos(ctx context.Context) ([]capabilities.CapabilityInfo, error)

func (*StandardCapabilitiesClient) Initialise

func (c *StandardCapabilitiesClient) Initialise(ctx context.Context, config string, telemetryService core.TelemetryService,
	keyValueStore core.KeyValueStore, capabilitiesRegistry core.CapabilitiesRegistry, errorLog core.ErrorLog,
	pipelineRunner core.PipelineRunnerService, relayerSet core.RelayerSet) error