Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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, oracleFactory core.OracleFactory) 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(brokerCfg net.BrokerConfig) *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, oracleFactory core.OracleFactory) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.