relayer

Documentation

Index

• func RegisterPluginRelayerServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, ...) error
• func RegisterStandAloneMedianProvider(s *grpc.Server, p types.MedianProvider)
• func RegisterStandAloneOCR3CapabilityProvider(s *grpc.Server, p types.OCR3CapabilityProvider)
• func RegisterStandAlonePluginProvider(s *grpc.Server, p types.PluginProvider)
• type PluginProviderClient
  • func WrapProviderClientConnection(ctx context.Context, providerType string, cc grpc.ClientConnInterface, ...) (PluginProviderClient, error)
• type PluginRelayerClient
  • func NewPluginRelayerClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *PluginRelayerClient
  • func (p *PluginRelayerClient) NewRelayer(ctx context.Context, config string, keystore core.Keystore, ...) (looptypes.Relayer, error)

Functions

func RegisterPluginRelayerServer

func RegisterPluginRelayerServer(server *grpc.Server, broker net.Broker, brokerCfg net.BrokerConfig, impl looptypes.PluginRelayer) error

func RegisterStandAloneMedianProvider

func RegisterStandAloneMedianProvider(s *grpc.Server, p types.MedianProvider)

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

func RegisterStandAloneOCR3CapabilityProvider

func RegisterStandAloneOCR3CapabilityProvider(s *grpc.Server, p types.OCR3CapabilityProvider)

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

func RegisterStandAlonePluginProvider

func RegisterStandAlonePluginProvider(s *grpc.Server, p types.PluginProvider)

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

Types

type PluginProviderClient

type PluginProviderClient interface {
	types.PluginProvider
	goplugin.GRPCClientConn
}

func WrapProviderClientConnection

func WrapProviderClientConnection(ctx context.Context, providerType string, cc grpc.ClientConnInterface, broker *net.BrokerExt) (PluginProviderClient, error)

type PluginRelayerClient

type PluginRelayerClient struct {
	*goplugin.PluginClient
	// contains filtered or unexported fields
}

func NewPluginRelayerClient

func NewPluginRelayerClient(broker net.Broker, brokerCfg net.BrokerConfig, conn *grpc.ClientConn) *PluginRelayerClient

func (*PluginRelayerClient) NewRelayer

func (p *PluginRelayerClient) NewRelayer(ctx context.Context, config string, keystore core.Keystore, capabilityRegistry core.CapabilitiesRegistry) (looptypes.Relayer, error)