IsLaterThan returns true if the first log was emitted "after" the second log from the blockchain's point of view.

NewArbitrumBlockTranslator returns a concrete ArbitrumBlockTranslator.

NewBlockTranslator returns the block translator for the given chain.

NewDB returns a new DB scoped to this oracleSpecID.

NewOCRContractTracker makes a new OCRContractTracker.

NewPeerstoreWrapper creates a new database-backed peerstore wrapper scoped to the given jobID Multiple peerstore wrappers should not be instantiated with the same jobID.

NewSingletonPeerWrapper creates a new peer based on the p2p keys in the keystore It currently only supports one peerID/key It should be fairly easy to modify it to support multiple peerIDs/keys using e.g.

NewTransmitter creates a new eth transmitter.

ValidatedOracleSpecToml validates an oracle spec that came from TOML.

ArbitrumBlockTranslator uses Arbitrum's special L1BlockNumber to optimise log lookups Performance matters here hence aggressive use of the cache We want to minimise fetches because calling eth_getBlockByNumber is relatively expensive.

go:generate mockery --name OCRContractTrackerDB --output ./mocks/ --case=underscore.

BlockTranslator converts emitted block numbers (from block.number) into a block number range suitable for query in FilterLogs.

go:generate mockery --name OCRContractTrackerDB --output ./mocks/ --case=underscore.

OCRContractConfigSubscription only exists to comply with the ContractConfigSubscription interface, it's just a simple shell around OCRContractTracker that defines two methods.