pebble

Documentation

Index

• type Accounts
  • func NewAccounts(db *Storage) *Accounts
  • func (a *Accounts) GetBalance(address common.Address) (*big.Int, error)
  • func (a *Accounts) GetNonce(address common.Address) (uint64, error)
  • func (a *Accounts) Update(tx models.Transaction, receipt *models.StorageReceipt, batch *pebble.Batch) error
• type Blocks
  • func NewBlocks(store *Storage, chainID flowGo.ChainID) *Blocks
  • func (b *Blocks) GetByHeight(height uint64) (*models.Block, error)
  • func (b *Blocks) GetByID(ID common.Hash) (*models.Block, error)
  • func (b *Blocks) GetCadenceHeight(evmHeight uint64) (uint64, error)
  • func (b *Blocks) GetCadenceID(evmHeight uint64) (flow.Identifier, error)
  • func (b *Blocks) GetHeightByID(ID common.Hash) (uint64, error)
  • func (b *Blocks) InitHeights(cadenceHeight uint64, cadenceID flow.Identifier) error
  • func (b *Blocks) LatestCadenceHeight() (uint64, error)
  • func (b *Blocks) LatestEVMHeight() (uint64, error)
  • func (b *Blocks) SetLatestCadenceHeight(height uint64, batch *pebble.Batch) error
  • func (b *Blocks) Store(cadenceHeight uint64, cadenceID flow.Identifier, block *models.Block, ...) error
• type Receipts
  • func NewReceipts(store *Storage) *Receipts
  • func (r *Receipts) BloomsForBlockRange(start, end *big.Int) ([]*models.BloomsHeight, error)
  • func (r *Receipts) GetByBlockHeight(height *big.Int) ([]*models.StorageReceipt, error)
  • func (r *Receipts) GetByTransactionID(ID common.Hash) (*models.StorageReceipt, error)
  • func (r *Receipts) Store(receipt *models.StorageReceipt, batch *pebble.Batch) error
• type Storage
  • func New(dir string, log zerolog.Logger) (*Storage, error)
  • func (s *Storage) NewBatch() *pebble.Batch
• type Traces
  • func NewTraces(store *Storage) *Traces
  • func (t *Traces) GetTransaction(ID common.Hash) (json.RawMessage, error)
  • func (t *Traces) StoreTransaction(ID common.Hash, trace json.RawMessage, batch *pebble.Batch) error
• type Transactions
  • func NewTransactions(store *Storage) *Transactions
  • func (t *Transactions) Get(ID common.Hash) (models.Transaction, error)
  • func (t *Transactions) Store(tx models.Transaction, batch *pebble.Batch) error

Types

type Accounts

type Accounts struct {
	// contains filtered or unexported fields
}

func NewAccounts

func NewAccounts(db *Storage) *Accounts

func (*Accounts) GetBalance

func (a *Accounts) GetBalance(address common.Address) (*big.Int, error)

func (*Accounts) GetNonce

func (a *Accounts) GetNonce(address common.Address) (uint64, error)

func (*Accounts) Update

func (a *Accounts) Update(
	tx models.Transaction,
	receipt *models.StorageReceipt,
	batch *pebble.Batch,
) error

type Blocks

type Blocks struct {
	// contains filtered or unexported fields
}

func NewBlocks

func NewBlocks(store *Storage, chainID flowGo.ChainID) *Blocks

func (*Blocks) GetByHeight

func (b *Blocks) GetByHeight(height uint64) (*models.Block, error)

func (*Blocks) GetByID

func (b *Blocks) GetByID(ID common.Hash) (*models.Block, error)

func (*Blocks) GetCadenceHeight

func (b *Blocks) GetCadenceHeight(evmHeight uint64) (uint64, error)

func (*Blocks) GetCadenceID

func (b *Blocks) GetCadenceID(evmHeight uint64) (flow.Identifier, error)

func (*Blocks) GetHeightByID

func (b *Blocks) GetHeightByID(ID common.Hash) (uint64, error)

func (*Blocks) InitHeights

func (b *Blocks) InitHeights(cadenceHeight uint64, cadenceID flow.Identifier) error

InitHeights sets the Cadence height to zero as well as EVM heights. Used for empty database init.

func (*Blocks) LatestCadenceHeight

func (b *Blocks) LatestCadenceHeight() (uint64, error)

func (*Blocks) LatestEVMHeight

func (b *Blocks) LatestEVMHeight() (uint64, error)

func (*Blocks) SetLatestCadenceHeight

func (b *Blocks) SetLatestCadenceHeight(height uint64, batch *pebble.Batch) error

func (*Blocks) Store

func (b *Blocks) Store(
	cadenceHeight uint64,
	cadenceID flow.Identifier,
	block *models.Block,
	batch *pebble.Batch,
) error

type Receipts

type Receipts struct {
	// contains filtered or unexported fields
}

func NewReceipts

func NewReceipts(store *Storage) *Receipts

func (*Receipts) BloomsForBlockRange

func (r *Receipts) BloomsForBlockRange(start, end *big.Int) ([]*models.BloomsHeight, error)

func (*Receipts) GetByBlockHeight

func (r *Receipts) GetByBlockHeight(height *big.Int) ([]*models.StorageReceipt, error)

func (*Receipts) GetByTransactionID

func (r *Receipts) GetByTransactionID(ID common.Hash) (*models.StorageReceipt, error)

func (*Receipts) Store

func (r *Receipts) Store(receipt *models.StorageReceipt, batch *pebble.Batch) error

Store receipt in the index.

Storing receipt will create multiple indexes, each receipt has a transaction ID, and a block height. We create following mappings: - receipt transaction ID => block height bytes - receipt block height => list of encoded receipts (1+ per block) - receipt block height => list of bloom filters (1+ per block)

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

func New

func New(dir string, log zerolog.Logger) (*Storage, error)

New creates a new storage instance using the provided dir location as the storage directory.

func (*Storage) NewBatch

func (s *Storage) NewBatch() *pebble.Batch

type Traces

type Traces struct {
	// contains filtered or unexported fields
}

func NewTraces

func NewTraces(store *Storage) *Traces

func (*Traces) GetTransaction

func (t *Traces) GetTransaction(ID common.Hash) (json.RawMessage, error)

func (*Traces) StoreTransaction

func (t *Traces) StoreTransaction(ID common.Hash, trace json.RawMessage, batch *pebble.Batch) error

type Transactions

type Transactions struct {
	// contains filtered or unexported fields
}

func NewTransactions

func NewTransactions(store *Storage) *Transactions

func (*Transactions) Get

func (t *Transactions) Get(ID common.Hash) (models.Transaction, error)

func (*Transactions) Store

func (t *Transactions) Store(tx models.Transaction, batch *pebble.Batch) error