relay

Documentation

Index

• type RelayerAdapter
  • func (r *RelayerAdapter) Close() error
  • func (r *RelayerAdapter) HealthReport() map[string]error
  • func (r *RelayerAdapter) Name() string
  • func (r *RelayerAdapter) NewAutomationProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.AutomationProvider, error)
  • func (r *RelayerAdapter) NewCCIPCommitProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.CCIPCommitProvider, error)
  • func (r *RelayerAdapter) NewCCIPExecProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.CCIPExecProvider, error)
  • func (r *RelayerAdapter) NewChainWriter(ctx context.Context, contractWriterConfig []byte) (types.ChainWriter, error)
  • func (r *RelayerAdapter) NewConfigProvider(ctx context.Context, rargs types.RelayArgs) (types.ConfigProvider, error)
  • func (r *RelayerAdapter) NewContractReader(_ context.Context, contractReaderConfig []byte) (types.ContractReader, error)
  • func (r *RelayerAdapter) NewFunctionsProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.FunctionsProvider, error)
  • func (r *RelayerAdapter) NewLLOProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.LLOProvider, error)
  • func (r *RelayerAdapter) NewMedianProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.MedianProvider, error)
  • func (r *RelayerAdapter) NewMercuryProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.MercuryProvider, error)
  • func (r *RelayerAdapter) NewOCR3CapabilityProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.OCR3CapabilityProvider, error)
  • func (r *RelayerAdapter) NewPluginProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.PluginProvider, error)
  • func (r *RelayerAdapter) Ready() (err error)
  • func (r *RelayerAdapter) Start(ctx context.Context) error
• type RelayerExt
• type ServerAdapter
  • func NewServerAdapter(r types.Relayer, e RelayerExt) *ServerAdapter
  • func (r *ServerAdapter) NewPluginProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.PluginProvider, error)

Types

type RelayerAdapter

type RelayerAdapter struct {
	types.Relayer
	RelayerExt
}

RelayerAdapter adapts a types.Relayer and RelayerExt to implement [Relayer].

func (*RelayerAdapter) Close

func (r *RelayerAdapter) Close() error

func (*RelayerAdapter) HealthReport

func (r *RelayerAdapter) HealthReport() map[string]error

func (*RelayerAdapter) Name

func (r *RelayerAdapter) Name() string

func (*RelayerAdapter) NewAutomationProvider

func (r *RelayerAdapter) NewAutomationProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.AutomationProvider, error)

func (*RelayerAdapter) NewCCIPCommitProvider

func (r *RelayerAdapter) NewCCIPCommitProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.CCIPCommitProvider, error)

func (*RelayerAdapter) NewCCIPExecProvider

func (r *RelayerAdapter) NewCCIPExecProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.CCIPExecProvider, error)

func (*RelayerAdapter) NewChainWriter

func (r *RelayerAdapter) NewChainWriter(ctx context.Context, contractWriterConfig []byte) (types.ChainWriter, error)

func (*RelayerAdapter) NewConfigProvider

func (r *RelayerAdapter) NewConfigProvider(ctx context.Context, rargs types.RelayArgs) (types.ConfigProvider, error)

func (*RelayerAdapter) NewContractReader

func (r *RelayerAdapter) NewContractReader(_ context.Context, contractReaderConfig []byte) (types.ContractReader, error)

func (*RelayerAdapter) NewFunctionsProvider

func (r *RelayerAdapter) NewFunctionsProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.FunctionsProvider, error)

func (*RelayerAdapter) NewLLOProvider

func (r *RelayerAdapter) NewLLOProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.LLOProvider, error)

func (*RelayerAdapter) NewMedianProvider

func (r *RelayerAdapter) NewMedianProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.MedianProvider, error)

func (*RelayerAdapter) NewMercuryProvider

func (r *RelayerAdapter) NewMercuryProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.MercuryProvider, error)

func (*RelayerAdapter) NewOCR3CapabilityProvider

func (r *RelayerAdapter) NewOCR3CapabilityProvider(ctx context.Context, rargs types.RelayArgs, pargs types.PluginArgs) (types.OCR3CapabilityProvider, error)

func (*RelayerAdapter) NewPluginProvider

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

func (*RelayerAdapter) Ready

func (r *RelayerAdapter) Ready() (err error)

func (*RelayerAdapter) Start

func (r *RelayerAdapter) Start(ctx context.Context) error

type RelayerExt

type RelayerExt interface {
	types.ChainService
	ID() string
}

RelayerExt is a subset of [loop.Relayer] for adapting types.Relayer, typically with a Chain. See RelayerAdapter.

type ServerAdapter

type ServerAdapter struct {
	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

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

NewServerAdapter returns a new ServerAdapter.

func (*ServerAdapter) NewPluginProvider

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