cluster

Documentation

Index

• func CanonicalClusterID(epoch uint64, participants flow.IdentityList) flow.ChainID
• func CanonicalRootBlock(epoch uint64, participants flow.IdentityList) *cluster.Block
• type Mutator
• type Params
• type Snapshot
• type State

Functions

func CanonicalClusterID

func CanonicalClusterID(epoch uint64, participants flow.IdentityList) flow.ChainID

CanonicalClusterID returns the canonical chain ID for the given cluster in the given epoch.

func CanonicalRootBlock

func CanonicalRootBlock(epoch uint64, participants flow.IdentityList) *cluster.Block

CanonicalRootBlock returns the canonical root block for the given cluster in the given epoch. It contains an empty collection referencing

Types

type Mutator

type Mutator interface {

	// Bootstrap initializes the persistent cluster state with a genesis block.
	// The genesis block must have number 0, a parent hash of 32 zero bytes,
	// and an empty collection as payload.
	Bootstrap(genesis *cluster.Block) error

	// Extend introduces the given block into the cluster state as a pending
	// without modifying the current finalized state.
	Extend(block *cluster.Block) error
}

Mutator represents an interface to modify the persistent cluster state in a way that conserves its integrity. It enforces a number of invariants on the input data to ensure internal bookkeeping mechanisms remain functional and valid.

type Params

type Params interface {

	// ChainID returns the chain ID for this cluster.
	ChainID() (flow.ChainID, error)
}

Params contains constant information about this cluster state.

type Snapshot

type Snapshot interface {

	// Collection returns the collection generated in this step of the cluster
	// state history.
	Collection() (*flow.Collection, error)

	// Head returns the latest block at the selected point of the cluster state
	// history. If the snapshot was selected by block ID, returns the header
	// with that block ID. If the snapshot was selected as final, returns the
	// latest finalized block.
	Head() (*flow.Header, error)

	// Pending returns all children IDs for the snapshot head, which thus were
	// potential extensions of the protocol state at this snapshot. The result
	// is ordered such that parents are included before their children. These
	// are NOT guaranteed to have been validated by HotStuff.
	Pending() ([]flow.Identifier, error)
}

Snapshot represents an immutable snapshot at a specific point in the cluster state history.

type State

type State interface {

	// Params returns constant information about the cluster state.
	Params() Params

	// Final returns the snapshot of the cluster state at the latest finalized
	// block. The returned snapshot is therefore immutable over time.
	Final() Snapshot

	// AtBlockID returns the snapshot of the persistent cluster at the given
	// block ID. It is available for any block that was introduced into the
	// the cluster state, and can thus represent an ambiguous state that was or
	// will never be finalized.
	AtBlockID(blockID flow.Identifier) Snapshot

	// Mutate will create a mutator for the persistent cluster state. It allows
	// extending the cluster state in a consistent manner that preserves
	// integrity, validity, and functionality of the database.
	Mutate() Mutator
}

State represents the chain state for collection node cluster consensus. It tracks which blocks are finalized and indexes blocks by number and ID. The purpose of cluster consensus is to agree on collections of transactions, so each block within the cluster state corresponds to a proposed collection.

NOTE: This is modelled after, and is a simpler version of, protocol.State.