types

Jan 13, 2026

Changes in this version

+ const MaxPositiveOffsetFinalized

+ const MaxPositiveOffsetLatest

+ const MaxPositiveOffsetPending

+ const MaxPositiveOffsetSafe

+ type BlockHeader struct

+ Hash common.Hash

+ Number uint64

+ ParentHash *common.Hash

+ Time uint64

+ func NewBlockHeader(number uint64, hash common.Hash, time uint64, parentHash *common.Hash) *BlockHeader

+ func NewBlockHeaderFromEthHeader(ethHeader *types.Header) *BlockHeader

+ func (gb *BlockHeader) String() string

type BlockNumberFinality

+ func (b *BlockNumberFinality) Equal(other BlockNumberFinality) bool

+ func (b BlockNumberFinality) Validate() error

+ type MultiDownloader interface

+ BlockHeader func(ctx context.Context, finality BlockNumberFinality) (*BlockHeader, error)

+ BlockNumber func(ctx context.Context, finality BlockNumberFinality) (uint64, error)

+ ChainID func(ctx context.Context) (uint64, error)

+ EthClient func() BaseEthereumClienter

+ FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]ethtypes.Log, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*BlockHeader, error)

+ RegisterSyncer func(data SyncerConfig) error

+ Start func(ctx context.Context) error

type NoopRPCClient

+ func (c *NoopRPCClient) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error

type RPCClienter

+ BatchCallContext func(ctx context.Context, b []rpc.BatchElem) error

+ type SyncerConfig struct

+ ContractsAddr []common.Address

+ FromBlock uint64

+ SyncerID string

+ ToBlock BlockNumberFinality

Nov 6, 2025

Changes in this version

type BlockNumberFinality

+ func (b *BlockNumberFinality) BlockHeader(ctx context.Context, requester ethereum.ChainReader) (*types.Header, error)

Oct 13, 2025

Changes in this version

+ const Empty

+ const EmptyBlockName

+ const FinalizedBlockName

+ const LatestBlockName

+ const PendingBlockName

+ const SafeBlockName

type BlockNumber

+ func NewBlockNumber(s string) (BlockNumber, error)

+ func (b BlockNumber) ApplyOffset(blockNumber uint64, offset int64) uint64

+ func (b BlockNumber) String() string

type BlockNumberFinality

+ Block BlockNumber

+ Offset int64

+ func (b *BlockNumberFinality) BlockNumber(ctx context.Context, requester ethereum.ChainReader) (uint64, error)

+ func (b *BlockNumberFinality) LessFinalThan(other BlockNumberFinality) bool

+ func (b BlockNumberFinality) IsLatest() bool

type EthClienter

+ func DialWithRetry(ctx context.Context, url string, retryHandler commontypes.RetryHandler) (EthClienter, error)

Aug 8, 2025

Changes in this version

+ const Earliest

+ const Finalized

+ const Latest

+ const Pending

+ const Safe

+ var EarliestBlock = BlockNumberFinality

+ var FinalizedBlock = BlockNumberFinality

+ var LatestBlock = BlockNumberFinality

+ var PendingBlock = BlockNumberFinality

+ var SafeBlock = BlockNumberFinality

+ type BaseEthereumClienter interface

+ type BlockNumber int64

+ type BlockNumberFinality struct

+ func NewBlockNumberFinality(s string) BlockNumberFinality

+ func (BlockNumberFinality) JSONSchema() *jsonschema.Schema

+ func (b *BlockNumberFinality) ToBlockNum() (*big.Int, error)

+ func (b BlockNumberFinality) IsEmpty() bool

+ func (b BlockNumberFinality) IsFinalized() bool

+ func (b BlockNumberFinality) IsSafe() bool

+ func (b BlockNumberFinality) String() string

+ func (d *BlockNumberFinality) UnmarshalText(data []byte) error

+ type DefaultEthClient struct

+ func NewDefaultEthClient(baseClient BaseEthereumClienter, rpcClient RPCClienter) *DefaultEthClient

+ type EthClienter interface

+ type NoopRPCClient struct

+ func (c *NoopRPCClient) Call(result any, method string, args ...any) error

+ type RPCClienter interface

+ Call func(result any, method string, args ...any) error