reportingplugins

type GRPCService ¶

type GRPCService[T types.PluginProvider] struct {
	plugin.NetRPCUnsupportedPlugin

	loop.BrokerConfig

	PluginServer ProviderServer[T]
	// contains filtered or unexported fields
}

GRPCService is the loopp interface for a plugin that can run an arbitrary product in the core node. By specifying `T`, server instances can request a specific provider type.

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 ¶

type LOOPPService struct {
	internal.PluginService[*GRPCService[types.PluginProvider], types.ReportingPluginFactory]
}

LOOPPService is a types.Service that maintains an internal types.PluginClient.

func NewLOOPPService(
	lggr logger.Logger,
	grpcOpts loop.GRPCOpts,
	cmd func() *exec.Cmd,
	config types.ReportingPluginServiceConfig,
	providerConn grpc.ClientConnInterface,
	pipelineRunner types.PipelineRunnerService,
	telemetryService types.TelemetryService,
	errorLog types.ErrorLog,
) *LOOPPService

func (g *LOOPPService) NewReportingPlugin(config ocrtypes.ReportingPluginConfig) (ocrtypes.ReportingPlugin, ocrtypes.ReportingPluginInfo, error)

type MedianProviderServer ¶

type MedianProviderServer = internal.MedianProviderServer

type PluginProviderServer ¶

type PluginProviderServer = internal.PluginProviderServer

These implement `ConnToProvider` and return the conn wrapped as the specified provider type. They can be embedded into the server struct for ease of use.

type ProviderServer ¶

type ProviderServer[T types.PluginProvider] interface {
	types.ReportingPluginServer[T]
	ConnToProvider(conn grpc.ClientConnInterface, broker internal.Broker, brokerConfig loop.BrokerConfig) T
}