store

Documentation

Index

• Variables
• type BlockStore
  • func NewBlockStore(db KeyValueReaderWriter) *BlockStore
  • func (bs *BlockStore) GetLastStoredBlock(domainID uint8) (*big.Int, error)
  • func (bs *BlockStore) GetStartBlock(domainID uint8, startBlock *big.Int, latest bool, fresh bool) (*big.Int, error)
  • func (bs *BlockStore) StoreBlock(block *big.Int, domainID uint8) error
• type KeyValueReader
• type KeyValueReaderWriter
• type KeyValueWriter
• type NonceStore
  • func NewNonceStore(db KeyValueReaderWriter) *NonceStore
  • func (ns *NonceStore) GetNonce(chainID *big.Int) (*big.Int, error)
  • func (ns *NonceStore) StoreNonce(chainID *big.Int, nonce *big.Int) error

Variables

var (
	ErrNotFound = errors.New("key not found")
)

Types

type BlockStore

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

func NewBlockStore

func NewBlockStore(db KeyValueReaderWriter) *BlockStore

func (*BlockStore) GetLastStoredBlock

func (bs *BlockStore) GetLastStoredBlock(domainID uint8) (*big.Int, error)

GetLastStoredBlock queries the blockstore and returns latest known block

func (*BlockStore) GetStartBlock

func (bs *BlockStore) GetStartBlock(domainID uint8, startBlock *big.Int, latest bool, fresh bool) (*big.Int, error)

GetStartBlock queries the blockstore for the latest known block. If the latest block is greater than configured startBlock, then startBlock is replaced with the latest known block.

func (*BlockStore) StoreBlock

func (bs *BlockStore) StoreBlock(block *big.Int, domainID uint8) error

StoreBlock stores block number per domainID into blockstore

type KeyValueReader

type KeyValueReader interface {
	GetByKey(key []byte) ([]byte, error)
}

type KeyValueReaderWriter

type KeyValueReaderWriter interface {
	KeyValueReader
	KeyValueWriter
}

type KeyValueWriter

type KeyValueWriter interface {
	SetByKey(key []byte, value []byte) error
}

type NonceStore

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

func NewNonceStore

func NewNonceStore(db KeyValueReaderWriter) *NonceStore

func (*NonceStore) GetNonce

func (ns *NonceStore) GetNonce(chainID *big.Int) (*big.Int, error)

GetNonce queries the blockstore and returns latest nonce

func (*NonceStore) StoreNonce

func (ns *NonceStore) StoreNonce(chainID *big.Int, nonce *big.Int) error

StoreNonce stores nonce per chainID