badger

Documentation

Index

• type Mutator
  • func (m *Mutator) Bootstrap(genesis *cluster.Block) error
  • func (m *Mutator) Extend(block *cluster.Block) 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 NewState(db *badger.DB, clusterID flow.ChainID, headers storage.Headers, ...) (*State, error)
  • func (s *State) AtBlockID(blockID flow.Identifier) cluster.Snapshot
  • func (s *State) Final() cluster.Snapshot
  • func (s *State) Mutate() cluster.Mutator
• type Translator
  • func NewTranslator(payloads storage.ClusterPayloads, state protocol.State) *Translator
  • func (t *Translator) Translate(blockID flow.Identifier) (flow.Identifier, error)

Types

type Mutator

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

func (*Mutator) Bootstrap

func (m *Mutator) Bootstrap(genesis *cluster.Block) error

func (*Mutator) Extend

func (m *Mutator) Extend(block *cluster.Block) 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 NewState

func NewState(db *badger.DB, clusterID flow.ChainID, headers storage.Headers, payloads storage.ClusterPayloads) (*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) Mutate

func (s *State) Mutate() cluster.Mutator

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.