storage

package

v0.8.0 Latest Latest Go to latest Published: Jan 13, 2026 License: Apache-2.0, MIT Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/agglayer/aggkit

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewBlockRowFromEthLog(log types.Log, isFinal bool) *blockRow
func NewBlockRowsFromAggkitBlock(blockHeaders []*aggkittypes.BlockHeader, isFinal bool) map[uint64]*blockRow
func NewBlockRowsFromLogs(logs []types.Log, isFinal bool) map[uint64]*blockRow
func NewLogRowFromEthLog(log types.Log) *logRow
func NewLogRowsFromEthLogs(logs []types.Log) []*logRow
type Blocks
- func NewBlocks() Blocks
type DBRuntimeData
- func (r DBRuntimeData) IsCompatible(storage DBRuntimeData) error
- func (r DBRuntimeData) String() string
type MultidownloaderStorage
- func NewMultidownloaderStorage(logger aggkitcommon.Logger, cfg MultidownloaderStorageConfig) (*MultidownloaderStorage, error)
type MultidownloaderStorageConfig

Constants ¶

View Source

const (
	// DataVersionCurrent is the current data version
	DataVersionCurrent = 1
)

View Source

const SqliteBoolFalse = 0

View Source

const SqliteBoolTrue = 1

Variables ¶

This section is empty.

Functions ¶

func NewBlockRowFromEthLog ¶

func NewBlockRowFromEthLog(log types.Log, isFinal bool) *blockRow

func NewBlockRowsFromAggkitBlock ¶

func NewBlockRowsFromAggkitBlock(blockHeaders []*aggkittypes.BlockHeader, isFinal bool) map[uint64]*blockRow

func NewBlockRowsFromLogs ¶

func NewBlockRowsFromLogs(logs []types.Log, isFinal bool) map[uint64]*blockRow

func NewLogRowFromEthLog ¶

func NewLogRowFromEthLog(log types.Log) *logRow

func NewLogRowsFromEthLogs ¶

func NewLogRowsFromEthLogs(logs []types.Log) []*logRow

Types ¶

type Blocks ¶

type Blocks struct {
	Headers  map[uint64]*aggkittypes.BlockHeader
	AreFinal map[uint64]bool
}

func NewBlocks ¶

func NewBlocks() Blocks

func (*Blocks) Add ¶

func (b *Blocks) Add(header *aggkittypes.BlockHeader, isFinal bool)

func (*Blocks) Get ¶

func (b *Blocks) Get(number uint64) (*aggkittypes.BlockHeader, bool, error)

func (*Blocks) IsEmpty ¶

func (b *Blocks) IsEmpty() bool

func (*Blocks) ListHeaders ¶

func (b *Blocks) ListHeaders() []*aggkittypes.BlockHeader

type DBRuntimeData ¶

type DBRuntimeData struct {
	NetworkID   uint64
	DataVersion int
}

func (DBRuntimeData) IsCompatible ¶

func (r DBRuntimeData) IsCompatible(storage DBRuntimeData) error

func (DBRuntimeData) String ¶

func (r DBRuntimeData) String() string

type MultidownloaderStorage ¶

type MultidownloaderStorage struct {
	dbtypes.KeyValueStorager
	// contains filtered or unexported fields
}

func NewMultidownloaderStorage ¶

func NewMultidownloaderStorage(logger aggkitcommon.Logger,
	cfg MultidownloaderStorageConfig) (*MultidownloaderStorage, error)

func (*MultidownloaderStorage) GetBlockHeaderByNumber ¶

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

func (*MultidownloaderStorage) GetEthLogs ¶

func (a *MultidownloaderStorage) GetEthLogs(tx dbtypes.Querier, query mdrtypes.LogQuery) ([]types.Log, error)

func (*MultidownloaderStorage) GetSyncedBlockRangePerContract ¶

func (a *MultidownloaderStorage) GetSyncedBlockRangePerContract(tx dbtypes.Querier) (mdrtypes.SetSyncSegment, error)

func (*MultidownloaderStorage) NewTx ¶

func (a *MultidownloaderStorage) NewTx(ctx context.Context) (dbtypes.Txer, error)

func (*MultidownloaderStorage) SaveEthLogs ¶

func (a *MultidownloaderStorage) SaveEthLogs(tx dbtypes.Querier, logs []types.Log, isFinal bool) error

tx dbtypes.Txer

func (*MultidownloaderStorage) SaveEthLogsWithHeaders ¶

func (a *MultidownloaderStorage) SaveEthLogsWithHeaders(tx dbtypes.Querier,
	blockHeaders []*aggkittypes.BlockHeader, logs []types.Log, isFinal bool) error

func (*MultidownloaderStorage) UpdateSyncedStatus ¶

func (a *MultidownloaderStorage) UpdateSyncedStatus(tx dbtypes.Querier,
	segments []mdrtypes.SyncSegment) error

func (*MultidownloaderStorage) UpsertSyncerConfigs ¶

func (a *MultidownloaderStorage) UpsertSyncerConfigs(tx dbtypes.Querier, configs []mdrtypes.ContractConfig) error

type MultidownloaderStorageConfig ¶

type MultidownloaderStorageConfig struct {
	DBPath string
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
migrations

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