types

Jan 13, 2026

Changes in this version

+ var ErrFinished = fmt.Errorf("no more segments to sync")

+ type ContractConfig struct

+ Address common.Address

+ FromBlock uint64

+ RequiredBlockHeader bool

+ Syncers []SyncerID

+ ToBlock aggkittypes.BlockNumberFinality

+ func NewContractConfigFromSyncerConfig(address common.Address, syncerConfig aggkittypes.SyncerConfig) *ContractConfig

+ func (c *ContractConfig) Update(syncerConfig aggkittypes.SyncerConfig)

+ type LogQuery struct

+ Addrs []common.Address

+ BlockRange aggkitcommon.BlockRange

+ func NewLogQuery(fromBlock uint64, toBlock uint64, addrs []common.Address) LogQuery

+ func NewLogQueryFromEthereumFilter(query ethereum.FilterQuery) LogQuery

+ func (l *LogQuery) String() string

+ func (l *LogQuery) ToRPCFilterQuery() ethereum.FilterQuery

+ type SetSyncSegment struct

+ func NewSetSyncSegment() SetSyncSegment

+ func NewSetSyncSegmentFromLogQuery(logQuery *LogQuery) SetSyncSegment

+ func (f *SetSyncSegment) AddLogQuery(logQuery *LogQuery) error

+ func (f *SetSyncSegment) Clone() *SetSyncSegment

+ func (f *SetSyncSegment) Finished() bool

+ func (f *SetSyncSegment) GetAddressesForBlockRange(blockRange aggkitcommon.BlockRange) []common.Address

+ func (f *SetSyncSegment) GetLowestFromBlockSegment() *SyncSegment

+ func (f *SetSyncSegment) IsAvailable(query LogQuery) bool

+ func (f *SetSyncSegment) NextQuery(syncBlockChunkSize uint32, maxBlockNumber uint64) (*LogQuery, error)

+ func (f *SetSyncSegment) Remove(segmentToRemove *SyncSegment)

+ func (f *SetSyncSegment) SubtractLogQuery(logQuery *LogQuery) error

+ func (f *SetSyncSegment) SubtractSegments(segments *SetSyncSegment) error

+ func (f *SetSyncSegment) TotalBlocks() uint64

+ func (f *SetSyncSegment) UpdateBlockRange(segment *SyncSegment, newBlockRange aggkitcommon.BlockRange)

+ func (f *SetSyncSegment) UpdateTargetBlockToNumber(ctx context.Context, blockNotifierGetter ethermantypes.BlockNotifierManager) error

+ func (s *SetSyncSegment) Add(segment SyncSegment)

+ func (s *SetSyncSegment) GetByContract(addr common.Address) (SyncSegment, bool)

+ func (s *SetSyncSegment) Segments() []SyncSegment

+ func (s *SetSyncSegment) SegmentsByContract(addrs []common.Address) []SyncSegment

+ func (s *SetSyncSegment) String() string

+ type SetSyncerConfig struct

+ func NewSetSyncerConfig() SetSyncerConfig

+ func (f *SetSyncerConfig) Add(filter aggkittypes.SyncerConfig)

+ func (f *SetSyncerConfig) Addresses(blockRange aggkitcommon.BlockRange) []common.Address

+ func (f *SetSyncerConfig) ContractConfigs() []ContractConfig

+ func (f *SetSyncerConfig) SyncSegments() (*SetSyncSegment, error)

+ type Storager interface

+ GetBlockHeaderByNumber func(tx dbtypes.Querier, blockNumber uint64) (*aggkittypes.BlockHeader, bool, error)

+ GetEthLogs func(tx dbtypes.Querier, query LogQuery) ([]types.Log, error)

+ GetSyncedBlockRangePerContract func(tx dbtypes.Querier) (SetSyncSegment, error)

+ NewTx func(ctx context.Context) (dbtypes.Txer, error)

+ SaveEthLogsWithHeaders func(tx dbtypes.Querier, blockHeaders []*aggkittypes.BlockHeader, logs []types.Log, ...) error

+ UpdateSyncedStatus func(tx dbtypes.Querier, segments []SyncSegment) error

+ UpsertSyncerConfigs func(tx dbtypes.Querier, configs []ContractConfig) error

+ type SyncSegment struct

+ BlockRange aggkitcommon.BlockRange

+ ContractAddr common.Address

+ TargetToBlock aggkittypes.BlockNumberFinality

+ func NewSyncSegment(contractAddr common.Address, blockRange aggkitcommon.BlockRange, ...) SyncSegment

+ func (s *SyncSegment) Clone() *SyncSegment

+ func (s *SyncSegment) String() string

+ func (s *SyncSegment) UpdateToBlock(newToBlock uint64)

+ func (s SyncSegment) Equal(other SyncSegment) bool

+ func (s SyncSegment) NewBlockRange(br aggkitcommon.BlockRange) SyncSegment

+ type SyncerID = string