Versions in this module Expand all Collapse all v0 v0.5.0 Jun 23, 2023 v0.4.0 Jun 22, 2023 v0.3.0 Jun 22, 2023 v0.2.0 Jun 22, 2023 Changes in this version + var ConfigSet = common.HexToHash("0x1591690b8638f5fb2dbec82ac741805ac5da8b45dc5263f4875b0496fdce4e05") + func AccountToAddress(accounts []types.Account) (addresses []common.Address, err error) + func ConfigFromLog(logData []byte) (ocrtypes.ContractConfig, error) + func IsLaterThan(incoming gethTypes.Log, existing gethTypes.Log) bool + func NewOCR2DRProvider(chainSet evm.ChainSet, rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs, ...) (relaytypes.Plugin, error) + func NewOCRContractTransmitter(address gethcommon.Address, caller contractReader, contractABI abi.ABI, ...) (*contractTransmitter, error) + func NewRoundRequestedDB(sqldb *sql.DB, oracleSpecID int32, lggr logger.Logger) *requestRoundDB + func OnchainPublicKeyToAddress(publicKeys []types.OnchainPublicKey) (addresses []common.Address, err error) + type ConfigPoller struct + func NewConfigPoller(lggr logger.Logger, destChainPoller logpoller.LogPoller, addr common.Address) (*ConfigPoller, error) + func (lp *ConfigPoller) LatestBlockHeight(ctx context.Context) (blockHeight uint64, err error) + func (lp *ConfigPoller) LatestConfig(ctx context.Context, changedInBlock uint64) (ocrtypes.ContractConfig, error) + func (lp *ConfigPoller) LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error) + func (lp *ConfigPoller) Notify() <-chan struct{} + type ContractTransmitter interface + type DKGProvider interface + type OCR2AbstractConfigSet struct + ConfigCount uint64 + ConfigDigest [32]byte + F uint8 + OffchainConfig []byte + OffchainConfigVersion uint64 + OnchainConfig []byte + PreviousConfigBlockNumber uint32 + Signers []common.Address + Transmitters []common.Address + type OCR2KeeperProvider interface + type OCR2KeeperProviderOpts struct + InstanceID int + PArgs relaytypes.PluginArgs + RArgs relaytypes.RelayArgs + type OCR2KeeperRelayer interface + NewOCR2KeeperProvider func(rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs) (OCR2KeeperProvider, error) + func NewOCR2KeeperRelayer(db *sqlx.DB, chain evm.Chain, pr pipeline.Runner, spec job.Job, ...) OCR2KeeperRelayer + type OCR2VRFProvider interface + type OCR2VRFRelayer interface + NewDKGProvider func(rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs) (DKGProvider, error) + NewOCR2VRFProvider func(rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs) (OCR2VRFProvider, error) + func NewOCR2VRFRelayer(db *sqlx.DB, chain evm.Chain, lggr logger.Logger, ethKeystore keystore.Eth) OCR2VRFRelayer + type Relayer struct + func NewRelayer(db *sqlx.DB, chainSet evm.ChainSet, lggr logger.Logger, cfg RelayerConfig, ...) *Relayer + func (r *Relayer) Close() error + func (r *Relayer) HealthReport() map[string]error + func (r *Relayer) Healthy() error + func (r *Relayer) Name() string + func (r *Relayer) NewConfigProvider(args relaytypes.RelayArgs) (relaytypes.ConfigProvider, error) + func (r *Relayer) NewMedianProvider(rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs) (relaytypes.MedianProvider, error) + func (r *Relayer) NewMercuryMedianProvider(relayConfig types.RelayConfig) (contractTransmitter ContractTransmitter, reportCodec median.ReportCodec, ...) + func (r *Relayer) NewMercuryProvider(rargs relaytypes.RelayArgs, pargs relaytypes.PluginArgs) (relaytypes.MercuryProvider, error) + func (r *Relayer) Ready() error + func (r *Relayer) Start(context.Context) error + type RelayerConfig interface + MercuryCredentials func(url string) (username, password string, err error) + type RequestRoundDB interface + LoadLatestRoundRequested func() (rr ocr2aggregator.OCR2AggregatorRoundRequested, err error) + SaveLatestRoundRequested func(tx pg.Queryer, rr ocr2aggregator.OCR2AggregatorRoundRequested) error + type RequestRoundTracker struct + func NewRequestRoundTracker(contract *offchain_aggregator_wrapper.OffchainAggregator, ...) (o *RequestRoundTracker) + func (t *RequestRoundTracker) Close() error + func (t *RequestRoundTracker) HandleLog(lb log.Broadcast) + func (t *RequestRoundTracker) IsV2Job() bool + func (t *RequestRoundTracker) JobID() int32 + func (t *RequestRoundTracker) LatestRoundRequested(_ context.Context, lookback time.Duration) (configDigest ocrtypes.ConfigDigest, epoch uint32, round uint8, err error) + func (t *RequestRoundTracker) Start() error + type Transmitter interface + CreateEthTransaction func(ctx context.Context, toAddress gethcommon.Address, payload []byte) error + FromAddress func() gethcommon.Address
Go to main page