types

Documentation

Index

• Variables
• type ConfigPoller
• type FunctionsProvider
• type LogPollerWrapper
• type OracleRequest
• type OracleResponse
• type RelayConfig
• type RelayOpts
  • func NewRelayOpts(args types.RelayArgs) *RelayOpts
  • func (o *RelayOpts) RelayConfig() (RelayConfig, error)
• type RouteUpdateSubscriber

Variables

var ErrBadRelayConfig = errors.New("bad relay config")

Types

type ConfigPoller

type ConfigPoller interface {
	ocrtypes.ContractConfigTracker

	Start()
	Close() error
	Replay(ctx context.Context, fromBlock int64) error
}

type FunctionsProvider

type FunctionsProvider interface {
	relaytypes.FunctionsProvider
	LogPollerWrapper() LogPollerWrapper
}

TODO(FUN-668): Migrate this fully into relaytypes.FunctionsProvider

type LogPollerWrapper

type LogPollerWrapper interface {
	relaytypes.Service
	LatestEvents() ([]OracleRequest, []OracleResponse, error)

	// TODO (FUN-668): Remove from the LOOP interface and only use internally within the EVM relayer
	SubscribeToUpdates(name string, subscriber RouteUpdateSubscriber)
}

A LogPoller wrapper that understands router proxy contracts

type OracleRequest

type OracleRequest struct {
	RequestId           [32]byte
	RequestingContract  common.Address
	RequestInitiator    common.Address
	SubscriptionId      uint64
	SubscriptionOwner   common.Address
	Data                []byte
	DataVersion         uint16
	Flags               [32]byte
	CallbackGasLimit    uint64
	TxHash              common.Hash
	CoordinatorContract common.Address
	OnchainMetadata     []byte
}

type OracleResponse

type OracleResponse struct {
	RequestId [32]byte
}

type RelayConfig

type RelayConfig struct {
	ChainID                *utils.Big  `json:"chainID"`
	FromBlock              uint64      `json:"fromBlock"`
	EffectiveTransmitterID null.String `json:"effectiveTransmitterID"`

	// Contract-specific
	SendingKeys pq.StringArray `json:"sendingKeys"`

	// Mercury-specific
	FeedID *common.Hash `json:"feedID"`
}

type RelayOpts

type RelayOpts struct {
	// TODO BCF-2508 -- should anyone ever get the raw config bytes that are embedded in args? if not,
	// make this private and wrap the arg fields with funcs on RelayOpts
	relaytypes.RelayArgs
	// contains filtered or unexported fields
}

func NewRelayOpts

func NewRelayOpts(args types.RelayArgs) *RelayOpts

func (*RelayOpts) RelayConfig

func (o *RelayOpts) RelayConfig() (RelayConfig, error)

type RouteUpdateSubscriber

type RouteUpdateSubscriber interface {
	UpdateRoutes(activeCoordinator common.Address, proposedCoordinator common.Address) error
}