badger

Documentation

Index

• func BackfillClusterBlockByReferenceHeightIndex(db *badger.DB, log zerolog.Logger, me flow.Identifier, state protocol.State, ...) error
• func IsBootstrapped(db *badger.DB, clusterID flow.ChainID) (bool, error)
• type MutableState
  • func NewMutableState(state *State, tracer module.Tracer, headers storage.Headers, ...) (*MutableState, error)
  • func (m *MutableState) Extend(block *cluster.Block) error
• type Params
  • func (p *Params) ChainID() (flow.ChainID, error)
• type Snapshot
  • func (s *Snapshot) Collection() (*flow.Collection, error)
  • func (s *Snapshot) Head() (*flow.Header, error)
  • func (s *Snapshot) Pending() ([]flow.Identifier, error)
• type State
  • func Bootstrap(db *badger.DB, stateRoot *StateRoot) (*State, error)
  • func OpenState(db *badger.DB, tracer module.Tracer, headers storage.Headers, ...) (*State, error)
  • func (s *State) AtBlockID(blockID flow.Identifier) cluster.Snapshot
  • func (s *State) Final() cluster.Snapshot
  • func (s *State) Params() cluster.Params
• type StateRoot
  • func NewStateRoot(genesis *cluster.Block) (*StateRoot, error)
  • func (s StateRoot) Block() *cluster.Block
  • func (s StateRoot) ClusterID() flow.ChainID
• type Translator
  • func NewTranslator(payloads storage.ClusterPayloads, state protocol.State) *Translator
  • func (t *Translator) Translate(blockID flow.Identifier) (flow.Identifier, error)

Functions

func BackfillClusterBlockByReferenceHeightIndex

func BackfillClusterBlockByReferenceHeightIndex(db *badger.DB, log zerolog.Logger, me flow.Identifier, state protocol.State, backfillNum int) error

BackfillClusterBlockByReferenceHeightIndex populates the reference height to cluster block index for all blocks in this node's cluster for the previous 2 epochs. This is intended for use when initially deploying transaction deduplication mid-spork.

This procedure is idempotent - it will backfill the index only once and on all subsequent calls will be a no-op.

TODO this method should not be included in the master branch.

func IsBootstrapped

func IsBootstrapped(db *badger.DB, clusterID flow.ChainID) (bool, error)

IsBootstrapped returns whether or not the database contains a bootstrapped state

Types

type MutableState

type MutableState struct {
	*State
	// contains filtered or unexported fields
}

func NewMutableState

func NewMutableState(state *State, tracer module.Tracer, headers storage.Headers, payloads storage.ClusterPayloads, log zerolog.Logger) (*MutableState, error)

func (*MutableState) Extend

func (m *MutableState) Extend(block *cluster.Block) error

TODO (Ramtin) pass context here

type Params

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

func (*Params) ChainID

func (p *Params) ChainID() (flow.ChainID, error)

type Snapshot

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

Snapshot represents a snapshot of chain state anchored at a particular reference block.

func (*Snapshot) Collection

func (s *Snapshot) Collection() (*flow.Collection, error)

func (*Snapshot) Head

func (s *Snapshot) Head() (*flow.Header, error)

func (*Snapshot) Pending

func (s *Snapshot) Pending() ([]flow.Identifier, error)

type State

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

func Bootstrap

func Bootstrap(db *badger.DB, stateRoot *StateRoot) (*State, error)

Bootstrap initializes the persistent cluster state with a genesis block. The genesis block must have height 0, a parent hash of 32 zero bytes, and an empty collection as payload.

func OpenState

func OpenState(db *badger.DB, tracer module.Tracer, headers storage.Headers, payloads storage.ClusterPayloads, clusterID flow.ChainID) (*State, error)

func (*State) AtBlockID

func (s *State) AtBlockID(blockID flow.Identifier) cluster.Snapshot

func (*State) Final

func (s *State) Final() cluster.Snapshot

func (*State) Params

func (s *State) Params() cluster.Params

type StateRoot

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

StateRoot is the root information required to bootstrap the cluster state

func NewStateRoot

func NewStateRoot(genesis *cluster.Block) (*StateRoot, error)

func (StateRoot) Block

func (s StateRoot) Block() *cluster.Block

func (StateRoot) ClusterID

func (s StateRoot) ClusterID() flow.ChainID

type Translator

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

Translator is a translation layer that determines the reference block on the main chain for a given cluster block, using the reference block from the cluster block's payload.

func NewTranslator

func NewTranslator(payloads storage.ClusterPayloads, state protocol.State) *Translator

NewTranslator returns a new block ID translator.

func (*Translator) Translate

func (t *Translator) Translate(blockID flow.Identifier) (flow.Identifier, error)

Translate retrieves the reference main-chain block ID for the given cluster block ID.