Documentation
¶
Index ¶
Constants ¶
View Source
const PluginServiceName = "ocr3-plugin-service"
Variables ¶
This section is empty.
Functions ¶
func NewLOOPPServiceValidation ¶
func NewLOOPPServiceValidation( lggr logger.Logger, grpcOpts loop.GRPCOpts, cmd func() *exec.Cmd, ) *reportingplugins.LOOPPServiceValidation
Types ¶
type GRPCService ¶
type GRPCService[T types.PluginProvider] struct { plugin.NetRPCUnsupportedPlugin loop.BrokerConfig PluginServer ProviderServer[T] // contains filtered or unexported fields }
func (*GRPCService[T]) ClientConfig ¶
func (g *GRPCService[T]) ClientConfig() *plugin.ClientConfig
func (*GRPCService[T]) GRPCClient ¶
func (g *GRPCService[T]) GRPCClient(_ context.Context, broker *plugin.GRPCBroker, conn *grpc.ClientConn) (interface{}, error)
func (*GRPCService[T]) GRPCServer ¶
func (g *GRPCService[T]) GRPCServer(broker *plugin.GRPCBroker, server *grpc.Server) error
type LOOPPService ¶
type LOOPPService struct {
goplugin.PluginService[*GRPCService[types.PluginProvider], core.OCR3ReportingPluginFactory]
}
func NewLOOPPService ¶
func NewLOOPPService( lggr logger.Logger, grpcOpts loop.GRPCOpts, cmd func() *exec.Cmd, config core.ReportingPluginServiceConfig, providerConn grpc.ClientConnInterface, pipelineRunner core.PipelineRunnerService, telemetryService core.TelemetryService, errorLog core.ErrorLog, capRegistry core.CapabilitiesRegistry, keyValueStore core.KeyValueStore, relayerSet core.RelayerSet, ) *LOOPPService
func (*LOOPPService) NewReportingPlugin ¶
func (g *LOOPPService) NewReportingPlugin(ctx context.Context, config ocr3types.ReportingPluginConfig) (ocr3types.ReportingPlugin[[]byte], ocr3types.ReportingPluginInfo, error)
type ProviderServer ¶
type ProviderServer[T types.PluginProvider] interface { core.OCR3ReportingPluginServer[T] ConnToProvider(conn grpc.ClientConnInterface, broker net.Broker, brokerConfig loop.BrokerConfig) T }
type ValidateConfigService ¶
Source Files
Click to show internal directories.
Click to hide internal directories.