relay

type ChainID ¶

type ChainID = string

type ID ¶

type ID struct {
	Network Network
	ChainID ChainID
}

ID uniquely identifies a relayer by network and chain id

func NewID(n Network, c ChainID) ID

func (i *ID) Name() string

func (i *ID) String() string

func (i *ID) UnmarshalString(s string) error

type Network ¶

type Network = string

var (
	EVM             Network = "evm"
	SupportedRelays         = map[Network]struct{}{
		EVM: {},
	}
)

type ProviderServer ¶

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

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

func (p *ProviderServer) Close() error

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

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

type ServerAdapter ¶

type ServerAdapter struct {
	loop.RelayerAdapter
}

ServerAdapter extends loop.RelayerAdapter by overriding NewPluginProvider to dispatches calls according to `RelayArgs.ProviderType`. This should only be used to adapt relayers not running via GRPC in a LOOPP.

func NewServerAdapter(r types.Relayer, e loop.RelayerExt) *ServerAdapter

func (r *ServerAdapter) NewPluginProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.PluginProvider, error)