inprocessprovider

README

All code in this package is required to support relayers that run in the same process as the core. This has been moved into common as part of the RelayerSet implementation.

Once all relayers are running as LOOPPs this package can be disposed of.

Documentation

Index

• func RegisterStandAloneProvider(s *grpc.Server, p types.PluginProvider, pType types.OCR2PluginType) error
• type ProviderServer
  • func NewProviderServer(p types.PluginProvider, pType types.OCR2PluginType, lggr logger.Logger) (*ProviderServer, error)
  • func (p *ProviderServer) Close() error
  • func (p *ProviderServer) GetConn() (grpc.ClientConnInterface, error)
  • func (p *ProviderServer) Start(ctx context.Context) error

Functions

func RegisterStandAloneProvider

func RegisterStandAloneProvider(s *grpc.Server, p types.PluginProvider, pType types.OCR2PluginType) error

RegisterStandAloneProvider register the servers needed for a plugin provider, this is a workaround to test the Node API POCs on EVM until the EVM relayer is loopifyed

Types

type ProviderServer

type ProviderServer struct {
	// contains filtered or unexported fields
}

ProviderServer is a GRPC server that will wrap a provider, this is a workaround, copied from core, until all providers are in their own loops.

func NewProviderServer

func NewProviderServer(p types.PluginProvider, pType types.OCR2PluginType, lggr logger.Logger) (*ProviderServer, error)

NewProviderServer creates a GRPC server that will wrap a provider, this is a workaround to test the Node API PoC until the EVM relayer is loopifyed

func (*ProviderServer) Close

func (p *ProviderServer) Close() error

func (*ProviderServer) GetConn

func (p *ProviderServer) GetConn() (grpc.ClientConnInterface, error)

func (*ProviderServer) Start

func (p *ProviderServer) Start(ctx context.Context) error