bp

Documentation

Index

• type Cluster
  • func NewCluster(cfg *config.ConsensusConfig, cdb consensus.ChainDB) (*Cluster, error)
  • func (c *Cluster) BpID2Index(id peer.ID) (uint16, bool)
  • func (c *Cluster) BpIndex2ID(idx uint16) (peer.ID, bool)
  • func (c *Cluster) Has(id peer.ID) bool
  • func (c *Cluster) Size() uint16
  • func (c *Cluster) Update(ids []string) error
• type ClusterMember
• type Snapshot
  • func NewSnapshot(blockNo types.BlockNo, bpCount uint16, bps []string) (*Snapshot, error)
  • func (s *Snapshot) Key() []byte
  • func (s *Snapshot) Value() []byte
• type Snapshots
  • func NewSnapshots(c ClusterMember, cdb consensus.ChainDB) *Snapshots
  • func (sn *Snapshots) AddSnapshot(refBlockNo types.BlockNo) ([]string, error)
  • func (sn *Snapshots) Del(refBlockNo types.BlockNo) error
  • func (sn *Snapshots) GC(blockNo types.BlockNo)
  • func (sn *Snapshots) NeedToRefresh(blockNo types.BlockNo) bool
  • func (sn *Snapshots) SetStateDB(sdb *state.ChainStateDB)

Types

type Cluster

type Cluster struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Cluster represents a cluster of block producers.

func NewCluster

func NewCluster(cfg *config.ConsensusConfig, cdb consensus.ChainDB) (*Cluster, error)

NewCluster returns a new bp.Cluster.

func (*Cluster) BpID2Index

func (c *Cluster) BpID2Index(id peer.ID) (uint16, bool)

BpID2Index returns the index corresponding to id.

func (*Cluster) BpIndex2ID

func (c *Cluster) BpIndex2ID(idx uint16) (peer.ID, bool)

BpIndex2ID returns the ID correspinding to idx.

func (*Cluster) Has

func (c *Cluster) Has(id peer.ID) bool

Has reports whether c includes id or not

func (*Cluster) Size

func (c *Cluster) Size() uint16

Size returns c.size.

func (*Cluster) Update

func (c *Cluster) Update(ids []string) error

Update updates old cluster index by using ids.

type ClusterMember

type ClusterMember interface {
	Size() uint16
	Update(ids []string) error
}

ClusterMember is an interface which corresponds to BP member udpate.

type Snapshot

type Snapshot struct {
	RefBlockNo types.BlockNo
	List       []string
}

Snapshot represents the set of the elected BP at refBlockNo.

func NewSnapshot

func NewSnapshot(blockNo types.BlockNo, bpCount uint16, bps []string) (*Snapshot, error)

NewSnapshot returns a Snapshot corresponding to blockNo and period.

func (*Snapshot) Key

func (s *Snapshot) Key() []byte

Key returns the properly prefixed key corresponding to s.

func (*Snapshot) Value

func (s *Snapshot) Value() []byte

Value returns s.list.

type Snapshots

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

Snapshots is a map from block no to *Snapshot.

func NewSnapshots

func NewSnapshots(c ClusterMember, cdb consensus.ChainDB) *Snapshots

NewSnapshots returns a new Snapshots.

func (*Snapshots) AddSnapshot

func (sn *Snapshots) AddSnapshot(refBlockNo types.BlockNo) ([]string, error)

AddSnapshot add a new BP list corresponding to refBlockNO to sn.

func (*Snapshots) Del

func (sn *Snapshots) Del(refBlockNo types.BlockNo) error

Del removes a snapshot corresponding to refBlockNo from sn.snaps.

func (*Snapshots) GC

func (sn *Snapshots) GC(blockNo types.BlockNo)

GC remove all the snapshots less than blockNo

func (*Snapshots) NeedToRefresh

func (sn *Snapshots) NeedToRefresh(blockNo types.BlockNo) bool

NeedToRefresh reports whether blockNo corresponds to a BP regime change point.

func (*Snapshots) SetStateDB

func (sn *Snapshots) SetStateDB(sdb *state.ChainStateDB)

SetStateDB sets sdb to sn.sdb.