db

package

Go to main page

Versions in this module

v1

v1.10.0

Nov 19, 2024

v1.9.5

Nov 8, 2024

Changes in this version

+ func OpenCrossDerivedFromDB(logger log.Logger, chainID types.ChainID, dataDir string, ...) (*fromda.DB, error)

+ func OpenLocalDerivedFromDB(logger log.Logger, chainID types.ChainID, dataDir string, ...) (*fromda.DB, error)

+ func OpenLogDB(logger log.Logger, chainID types.ChainID, dataDir string, m logs.Metrics) (*logs.DB, error)

+ func PrepDataDir(datadir string) error

type ChainsDB

+ func (db *ChainsDB) AddCrossDerivedFromDB(chainID types.ChainID, dfDB CrossDerivedFromStorage)

+ func (db *ChainsDB) AddCrossUnsafeTracker(chainID types.ChainID)

+ func (db *ChainsDB) AddLocalDerivedFromDB(chainID types.ChainID, dfDB LocalDerivedFromStorage)

+ func (db *ChainsDB) CandidateCrossSafe(chain types.ChainID) (derivedFromScope, crossSafe eth.BlockRef, err error)

+ func (db *ChainsDB) CrossDerivedFrom(chain types.ChainID, derived eth.BlockID) (derivedFrom types.BlockSeal, err error)

+ func (db *ChainsDB) CrossDerivedFromBlockRef(chainID types.ChainID, derived eth.BlockID) (derivedFrom eth.BlockRef, err error)

+ func (db *ChainsDB) CrossSafe(chainID types.ChainID) (derivedFrom types.BlockSeal, derived types.BlockSeal, err error)

+ func (db *ChainsDB) CrossUnsafe(chainID types.ChainID) (types.BlockSeal, error)

+ func (db *ChainsDB) DependencySet() depset.DependencySet

+ func (db *ChainsDB) Finalized(chainID types.ChainID) (types.BlockSeal, error)

+ func (db *ChainsDB) IsCrossUnsafe(chainID types.ChainID, block eth.BlockID) error

+ func (db *ChainsDB) IsLocalUnsafe(chainID types.ChainID, block eth.BlockID) error

+ func (db *ChainsDB) LastDerivedFrom(chainID types.ChainID, derivedFrom eth.BlockID) (derived types.BlockSeal, err error)

+ func (db *ChainsDB) LocalDerivedFrom(chain types.ChainID, derived eth.BlockID) (derivedFrom types.BlockSeal, err error)

+ func (db *ChainsDB) LocalSafe(chainID types.ChainID) (derivedFrom types.BlockSeal, derived types.BlockSeal, err error)

+ func (db *ChainsDB) LocalUnsafe(chainID types.ChainID) (types.BlockSeal, error)

+ func (db *ChainsDB) NextDerivedFrom(chain types.ChainID, derivedFrom eth.BlockID) (after eth.BlockRef, err error)

+ func (db *ChainsDB) OpenBlock(chainID types.ChainID, blockNum uint64) (seal eth.BlockRef, logCount uint32, ...)

+ func (db *ChainsDB) ParentBlock(chainID types.ChainID, parentOf eth.BlockID) (parent eth.BlockID, err error)

+ func (db *ChainsDB) PreviousDerived(chain types.ChainID, derived eth.BlockID) (prevDerived types.BlockSeal, err error)

+ func (db *ChainsDB) PreviousDerivedFrom(chain types.ChainID, derivedFrom eth.BlockID) (prevDerivedFrom types.BlockSeal, err error)

+ func (db *ChainsDB) UpdateCrossSafe(chain types.ChainID, l1View eth.BlockRef, lastCrossDerived eth.BlockRef) error

+ func (db *ChainsDB) UpdateCrossUnsafe(chain types.ChainID, crossUnsafe types.BlockSeal) error

+ func (db *ChainsDB) UpdateFinalizedL1(finalized eth.BlockRef) error

+ func (db *ChainsDB) UpdateLocalSafe(chain types.ChainID, derivedFrom eth.BlockRef, lastDerived eth.BlockRef) error

+ type CrossDerivedFromStorage interface

+ type LocalDerivedFromStorage interface

+ AddDerived func(derivedFrom eth.BlockRef, derived eth.BlockRef) error

+ DerivedFrom func(derived eth.BlockID) (derivedFrom types.BlockSeal, err error)

+ First func() (derivedFrom types.BlockSeal, derived types.BlockSeal, err error)

+ FirstAfter func(derivedFrom, derived eth.BlockID) (nextDerivedFrom, nextDerived types.BlockSeal, err error)

+ LastDerivedAt func(derivedFrom eth.BlockID) (derived types.BlockSeal, err error)

+ Latest func() (derivedFrom types.BlockSeal, derived types.BlockSeal, err error)

+ NextDerived func(derived eth.BlockID) (derivedFrom types.BlockSeal, nextDerived types.BlockSeal, err error)

+ NextDerivedFrom func(derivedFrom eth.BlockID) (nextDerivedFrom types.BlockSeal, err error)

+ PreviousDerived func(derived eth.BlockID) (prevDerived types.BlockSeal, err error)

+ PreviousDerivedFrom func(derivedFrom eth.BlockID) (prevDerivedFrom types.BlockSeal, err error)

type LogStorage

+ OpenBlock func(blockNum uint64) (ref eth.BlockRef, logCount uint32, execMsgs map[uint32]*types.ExecutingMessage, ...)

v1.9.4

Oct 8, 2024

Changes in this version

type ChainsDB

+ func (db *ChainsDB) IteratorStartingAt(chain types.ChainID, sealedNum uint64, logIndex uint32) (logs.Iterator, error)

+ func (db *ChainsDB) Safest(chainID types.ChainID, blockNum uint64, index uint32) (safest types.SafetyLevel)

v1.9.3

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

v1.9.2

Sep 5, 2024

v1.9.1

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

v1.9.0

Aug 7, 2024

v1.8.0

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL