ocr3

Documentation

Index

• Constants
• func NewLOOPPServiceValidation(lggr logger.Logger, grpcOpts loop.GRPCOpts, cmd func() *exec.Cmd) *reportingplugins.LOOPPServiceValidation
• type GRPCService
  • func (g *GRPCService[T]) ClientConfig() *plugin.ClientConfig
  • func (g *GRPCService[T]) GRPCClient(_ context.Context, broker *plugin.GRPCBroker, conn *grpc.ClientConn) (interface{}, error)
  • func (g *GRPCService[T]) GRPCServer(broker *plugin.GRPCBroker, server *grpc.Server) error
• type LOOPPService
  • func NewLOOPPService(lggr logger.Logger, grpcOpts loop.GRPCOpts, cmd func() *exec.Cmd, ...) *LOOPPService
  • func (g *LOOPPService) NewReportingPlugin(ctx context.Context, config ocr3types.ReportingPluginConfig) (ocr3types.ReportingPlugin[[]byte], ocr3types.ReportingPluginInfo, error)
• type ProviderServer
• type ValidateConfigService

Constants

const PluginServiceName = "ocr3-plugin-service"

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

type ValidateConfigService interface {
	NewValidationService(ctx context.Context) (core.ValidationService, error)
}