db

Sep 25, 2024

Changes in this version

type ChainsDB

+ func (db *ChainsDB) AddLogDB(chain types.ChainID, logDB LogStorage)

+ func (db *ChainsDB) FindSealedBlock(chain types.ChainID, block eth.BlockID) (nextEntry entrydb.EntryIdx, err error)

+ func (db *ChainsDB) RequestMaintenance()

+ func (db *ChainsDB) ResumeFromLastSealedBlock() error

+ func (db *ChainsDB) SealBlock(chain types.ChainID, parentHash common.Hash, block eth.BlockID, ...) error

type LogStorage

+ FindSealedBlock func(block eth.BlockID) (nextEntry entrydb.EntryIdx, err error)

+ IteratorStartingAt func(i entrydb.EntryIdx) (logs.Iterator, error)

+ LatestSealedBlockNum func() (n uint64, ok bool)

+ SealBlock func(parentHash common.Hash, block eth.BlockID, timestamp uint64) error

Aug 28, 2024

Changes in this version

+ const Finalized

+ const Safe

+ const Unsafe

type ChainsDB

+ func (db *ChainsDB) Check(chain types.ChainID, blockNum uint64, logIdx uint32, ...) (bool, entrydb.EntryIdx, error)

+ func (db *ChainsDB) LastLogInBlock(chain types.ChainID, blockNum uint64) (entrydb.EntryIdx, error)

+ func (db *ChainsDB) StartCrossHeadMaintenance(ctx context.Context)

+ func (db *ChainsDB) UpdateCrossHeads(checker SafetyChecker) error

+ func (db *ChainsDB) UpdateCrossHeadsForChain(chainID types.ChainID, checker SafetyChecker) error

+ func (db *ChainsDB) UpdateCrossSafeHeads() error

type HeadsStorage

+ Apply func(op heads.Operation) error

+ Current func() *heads.Heads

type LogStorage

+ ClosestBlockIterator func(blockNum uint64) (logs.Iterator, error)

+ Contains func(blockNum uint64, logIdx uint32, loghash backendTypes.TruncatedHash) (bool, entrydb.EntryIdx, error)

+ LastCheckpointBehind func(entrydb.EntryIdx) (logs.Iterator, error)

+ NextExecutingMessage func(logs.Iterator) (backendTypes.ExecutingMessage, error)

+ type SafetyChecker interface

+ Check func(chain types.ChainID, blockNum uint64, logIdx uint32, ...) bool

+ CrossHeadForChain func(chainID types.ChainID) entrydb.EntryIdx

+ LocalHeadForChain func(chainID types.ChainID) entrydb.EntryIdx

+ Name func() string

+ SafetyLevel func() types.SafetyLevel

+ Update func(chain types.ChainID, index entrydb.EntryIdx) heads.OperationFn

+ func NewSafetyChecker(t types.SafetyLevel, chainsDB *ChainsDB) SafetyChecker

Jul 17, 2024

Changes in this version

+ var ErrUnknownChain = errors.New("unknown chain")

+ func Resume(logDB LogStorage) error

+ type ChainsDB struct

+ func NewChainsDB(logDBs map[types.ChainID]LogStorage, heads HeadsStorage) *ChainsDB

+ func (db *ChainsDB) AddLog(chain types.ChainID, logHash backendTypes.TruncatedHash, block eth.BlockID, ...) error

+ func (db *ChainsDB) Close() error

+ func (db *ChainsDB) LatestBlockNum(chain types.ChainID) uint64

+ func (db *ChainsDB) Resume() error

+ func (db *ChainsDB) Rewind(chain types.ChainID, headBlockNum uint64) error

+ type HeadsStorage interface

+ type LogStorage interface

+ AddLog func(logHash backendTypes.TruncatedHash, block eth.BlockID, timestamp uint64, ...) error

+ ClosestBlockInfo func(blockNum uint64) (uint64, backendTypes.TruncatedHash, error)

+ LatestBlockNum func() uint64

+ Rewind func(newHeadBlockNum uint64) error