Versions in this module Expand all Collapse all v1 v1.10.17 Oct 18, 2021 Changes in this version + func NewLocalConfig(cfg ValidationConfig, spec job.OffchainReportingOracleSpec) ocrtypes.LocalConfig + type Config interface + ChainType func() chains.ChainType + DefaultChainID func() *big.Int + Dev func() bool + EvmGasLimitDefault func() uint64 + FlagsContractAddress func() string + JobPipelineResultWriteQueueDepth func() uint64 + OCRBlockchainTimeout func() time.Duration + OCRContractConfirmations func() uint16 + OCRContractPollInterval func() time.Duration + OCRContractSubscribeInterval func() time.Duration + OCRContractTransmitterTransmitTimeout func() time.Duration + OCRDatabaseTimeout func() time.Duration + OCRDefaultTransactionQueueDepth func() uint32 + OCRKeyBundleID func() (string, error) + OCRObservationGracePeriod func() time.Duration + OCRObservationTimeout func() time.Duration + OCRTraceLogging func() bool + OCRTransmitterAddress func() (ethkey.EIP55Address, error) + P2PBootstrapPeers func() ([]string, error) + P2PPeerID func() p2pkey.PeerID + P2PV2Bootstrappers func() []ocrtypes.BootstrapperLocator type ValidationConfig + ChainID func() *big.Int + ChainType func() chains.ChainType v1.10.16 Oct 18, 2021 Changes in this version + const ConfigOverriderPollInterval + const InitialHibernationStatus + var OCRContractConfigSet = getEventTopic("ConfigSet") + var OCRContractLatestRoundRequested = getEventTopic("RoundRequested") + func IsLaterThan(incoming gethTypes.Log, existing gethTypes.Log) bool + func NewDB(sqldb *sql.DB, oracleSpecID int32) *db + func NewLogger(l *logger.Logger, trace bool, saveError func(string)) ocrtypes.Logger + func ValidatedOracleSpecToml(config ValidationConfig, tomlString string) (job.Job, error) + type ArbitrumBlockTranslator struct + func NewArbitrumBlockTranslator(ethClient eth.Client) *ArbitrumBlockTranslator + func (a *ArbitrumBlockTranslator) BinarySearch(ctx context.Context, targetL1 int64) (l2lowerBound *big.Int, l2upperBound *big.Int, err error) + func (a *ArbitrumBlockTranslator) NumberToQueryRange(ctx context.Context, changedInL1Block uint64) (fromBlock *big.Int, toBlock *big.Int) + type BlockTranslator interface + NumberToQueryRange func(ctx context.Context, changedInL1Block uint64) (fromBlock *big.Int, toBlock *big.Int) + func NewBlockTranslator(chain *chains.Chain, client eth.Client) BlockTranslator + type ConfigOverriderImpl struct + DeltaCFromAddress time.Duration + func NewConfigOverriderImpl(logger *logger.Logger, contractAddress ethkey.EIP55Address, ...) (*ConfigOverriderImpl, error) + func (c *ConfigOverriderImpl) Close() error + func (c *ConfigOverriderImpl) ConfigOverride() *ocrtypes.ConfigOverride + func (c *ConfigOverriderImpl) Start() error + type ContractFlags struct + func NewFlags(addrHex string, ethClient eth.Client) (*ContractFlags, error) + func (f *ContractFlags) Contract() flags_wrapper.FlagsInterface + func (f *ContractFlags) ContractExists() bool + func (f *ContractFlags) IsLowered(contractAddr common.Address) (bool, error) + type Delegate struct + func NewDelegate(db *gorm.DB, txm txManager, jobORM job.ORM, config DelegateConfig, ...) *Delegate + func (Delegate) AfterJobCreated(spec job.Job) + func (Delegate) BeforeJobDeleted(spec job.Job) + func (d Delegate) JobType() job.Type + func (d Delegate) ServicesForSpec(jobSpec job.Job) (services []job.Service, err error) + type DelegateConfig interface + Chain func() *chains.Chain + ChainID func() *big.Int + Dev func() bool + EthGasLimitDefault func() uint64 + FlagsContractAddress func() string + JobPipelineResultWriteQueueDepth func() uint64 + OCRBlockchainTimeout func(time.Duration) time.Duration + OCRContractConfirmations func(uint16) uint16 + OCRContractPollInterval func(time.Duration) time.Duration + OCRContractSubscribeInterval func(time.Duration) time.Duration + OCRContractTransmitterTransmitTimeout func() time.Duration + OCRDatabaseTimeout func() time.Duration + OCRDefaultTransactionQueueDepth func() uint32 + OCRKeyBundleID func(*models.Sha256Hash) (models.Sha256Hash, error) + OCRObservationGracePeriod func() time.Duration + OCRObservationTimeout func(time.Duration) time.Duration + OCRTraceLogging func() bool + OCRTransmitterAddress func(*ethkey.EIP55Address) (ethkey.EIP55Address, error) + P2PBootstrapPeers func([]string) ([]string, error) + P2PPeerID func(*p2pkey.PeerID) (p2pkey.PeerID, error) + P2PV2Bootstrappers func() []ocrtypes.BootstrapperLocator + type DiscovererDatabase struct + func NewDiscovererDatabase(db *sql.DB, peerID p2ppeer.ID) *DiscovererDatabase + func (d *DiscovererDatabase) ReadAnnouncements(ctx context.Context, peerIDs []string) (map[string][]byte, error) + func (d *DiscovererDatabase) StoreAnnouncement(ctx context.Context, peerID string, ann []byte) error + type NetworkingConfig interface + OCRBootstrapCheckInterval func() time.Duration + OCRDHTLookupInterval func() int + OCRIncomingMessageBufferSize func() int + OCRNewStreamTimeout func() time.Duration + OCROutgoingMessageBufferSize func() int + OCRTraceLogging func() bool + P2PAnnounceIP func() net.IP + P2PAnnouncePort func() uint16 + P2PBootstrapPeers func([]string) ([]string, error) + P2PDHTAnnouncementCounterUserPrefix func() uint32 + P2PListenIP func() net.IP + P2PListenPort func() uint16 + P2PNetworkingStack func() ocrnetworking.NetworkingStack + P2PPeerID func(override *p2pkey.PeerID) (p2pkey.PeerID, error) + P2PPeerstoreWriteInterval func() time.Duration + P2PV2AnnounceAddresses func() []string + P2PV2Bootstrappers func() []ocrtypes.BootstrapperLocator + P2PV2DeltaDial func() models.Duration + P2PV2DeltaReconcile func() models.Duration + P2PV2ListenAddresses func() []string + type OCRContractConfigSubscription OCRContractTracker + func (sub *OCRContractConfigSubscription) Close() + func (sub *OCRContractConfigSubscription) Configs() <-chan ocrtypes.ContractConfig + type OCRContractTracker struct + func NewOCRContractTracker(contract *offchain_aggregator_wrapper.OffchainAggregator, ...) (o *OCRContractTracker) + func (t *OCRContractTracker) Close() error + func (t *OCRContractTracker) ConfigFromLogs(ctx context.Context, changedInBlock uint64) (c ocrtypes.ContractConfig, err error) + func (t *OCRContractTracker) Connect(*models.Head) error + func (t *OCRContractTracker) HandleLog(lb log.Broadcast) + func (t *OCRContractTracker) IsV2Job() bool + func (t *OCRContractTracker) JobID() models.JobID + func (t *OCRContractTracker) JobIDV2() int32 + func (t *OCRContractTracker) LatestBlockHeight(ctx context.Context) (blockheight uint64, err error) + func (t *OCRContractTracker) LatestConfigDetails(ctx context.Context) (changedInBlock uint64, configDigest ocrtypes.ConfigDigest, err error) + func (t *OCRContractTracker) LatestRoundRequested(_ context.Context, lookback time.Duration) (configDigest ocrtypes.ConfigDigest, epoch uint32, round uint8, err error) + func (t *OCRContractTracker) OnNewLongestChain(_ context.Context, h models.Head) + func (t *OCRContractTracker) Start() error + func (t *OCRContractTracker) SubscribeToNewConfigs(context.Context) (ocrtypes.ContractConfigSubscription, error) + type OCRContractTrackerDB interface + LoadLatestRoundRequested func() (rr offchainaggregator.OffchainAggregatorRoundRequested, err error) + SaveLatestRoundRequested func(tx *sql.Tx, rr offchainaggregator.OffchainAggregatorRoundRequested) error + type OCRContractTransmitter struct + func NewOCRContractTransmitter(address gethCommon.Address, ...) *OCRContractTransmitter + func (oc *OCRContractTransmitter) ChainID() *big.Int + func (oc *OCRContractTransmitter) FromAddress() gethCommon.Address + func (oc *OCRContractTransmitter) LatestRoundRequested(ctx context.Context, lookback time.Duration) (configDigest ocrtypes.ConfigDigest, epoch uint32, round uint8, err error) + func (oc *OCRContractTransmitter) LatestTransmissionDetails(ctx context.Context) (configDigest ocrtypes.ConfigDigest, epoch uint32, round uint8, ...) + func (oc *OCRContractTransmitter) Transmit(ctx context.Context, report []byte, rs, ss [][32]byte, vs [32]byte) error + type P2PPeer struct + Addr string + CreatedAt time.Time + ID string + PeerID string + UpdatedAt time.Time + func (P2PPeer) TableName() string + type Pstorewrapper struct + Peerstore p2ppeerstore.Peerstore + func NewPeerstoreWrapper(db *gorm.DB, writeInterval time.Duration, peerID p2pkey.PeerID) (*Pstorewrapper, error) + func (p *Pstorewrapper) Close() error + func (p *Pstorewrapper) Start() error + func (p *Pstorewrapper) WriteToDB() error + type RunResultSaver struct + func NewResultRunSaver(db *gorm.DB, runResults <-chan pipeline.RunWithResults, ...) *RunResultSaver + func (r *RunResultSaver) Close() error + func (r *RunResultSaver) Start() error + type SingletonPeerWrapper struct + Peer peer + PeerID p2pkey.PeerID + func NewSingletonPeerWrapper(keyStore *keystore.OCR, config *config.Config, db *gorm.DB) *SingletonPeerWrapper + func (p *SingletonPeerWrapper) Close() error + func (p *SingletonPeerWrapper) IsStarted() bool + func (p *SingletonPeerWrapper) Start() error + type Transmitter interface + CreateEthTransaction func(ctx context.Context, toAddress gethCommon.Address, payload []byte) error + FromAddress func() gethCommon.Address + func NewTransmitter(txm txManager, db *gorm.DB, fromAddress common.Address, gasLimit uint64, ...) Transmitter + type ValidationConfig interface + Dev func() bool + OCRBlockchainTimeout func(override time.Duration) time.Duration + OCRContractConfirmations func(override uint16) uint16 + OCRContractPollInterval func(override time.Duration) time.Duration + OCRContractSubscribeInterval func(override time.Duration) time.Duration + OCRContractTransmitterTransmitTimeout func() time.Duration + OCRDatabaseTimeout func() time.Duration + OCRObservationGracePeriod func() time.Duration + OCRObservationTimeout func(override time.Duration) time.Duration
Go to main page