nodekeeper

Documentation

Index

• func NewActiveNodeComponent(configuration configuration.Configuration) (core.ActiveNodeComponent, error)
• func NewNodeKeeper(nodeID core.RecordRef) consensus.NodeKeeper
• type UnsyncList
  • func NewUnsyncHolder(pulse core.PulseNumber, unsync []*core.ActiveNode) *UnsyncList
  • func (u *UnsyncList) AddUnsyncHash(ref core.RecordRef, hash []*consensus.NodeUnsyncHash)
  • func (u *UnsyncList) AddUnsyncList(ref core.RecordRef, unsync []*core.ActiveNode)
  • func (u *UnsyncList) GetHash(blockTimeout time.Duration) ([]*consensus.NodeUnsyncHash, error)
  • func (u *UnsyncList) GetPulse() core.PulseNumber
  • func (u *UnsyncList) GetUnsync() []*core.ActiveNode
  • func (u *UnsyncList) GetUnsyncHash(ref core.RecordRef) ([]*consensus.NodeUnsyncHash, bool)
  • func (u *UnsyncList) GetUnsyncList(ref core.RecordRef) ([]*core.ActiveNode, bool)
  • func (u *UnsyncList) SetHash(hash []*consensus.NodeUnsyncHash)

Functions

func NewActiveNodeComponent

func NewActiveNodeComponent(configuration configuration.Configuration) (core.ActiveNodeComponent, error)

NewActiveNodeComponent create active node component

func NewNodeKeeper

func NewNodeKeeper(nodeID core.RecordRef) consensus.NodeKeeper

NewNodeKeeper create new NodeKeeper

Types

type UnsyncList

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

func NewUnsyncHolder

func NewUnsyncHolder(pulse core.PulseNumber, unsync []*core.ActiveNode) *UnsyncList

NewUnsyncHolder create new object to hold data for consensus

func (*UnsyncList) AddUnsyncHash

func (u *UnsyncList) AddUnsyncHash(ref core.RecordRef, hash []*consensus.NodeUnsyncHash)

AddUnsyncHash add unsync hash for remote ref

func (*UnsyncList) AddUnsyncList

func (u *UnsyncList) AddUnsyncList(ref core.RecordRef, unsync []*core.ActiveNode)

AddUnsyncList add unsync list for remote ref

func (*UnsyncList) GetHash

func (u *UnsyncList) GetHash(blockTimeout time.Duration) ([]*consensus.NodeUnsyncHash, error)

GetHash get hash of unsync lists for each node of consensus. If hash is not calculated yet, then this call blocks until the hash is calculated with SetHash() call

func (*UnsyncList) GetPulse

func (u *UnsyncList) GetPulse() core.PulseNumber

GetPulse returns actual pulse for current consensus process.

func (*UnsyncList) GetUnsync

func (u *UnsyncList) GetUnsync() []*core.ActiveNode

GetUnsync returns list of local unsync nodes. This list is created

func (*UnsyncList) GetUnsyncHash

func (u *UnsyncList) GetUnsyncHash(ref core.RecordRef) ([]*consensus.NodeUnsyncHash, bool)

GetUnsyncHash get unsync hash for remote ref

func (*UnsyncList) GetUnsyncList

func (u *UnsyncList) GetUnsyncList(ref core.RecordRef) ([]*core.ActiveNode, bool)

GetUnsyncList get unsync list for remote ref

func (*UnsyncList) SetHash

func (u *UnsyncList) SetHash(hash []*consensus.NodeUnsyncHash)

SetHash sets hash of unsync lists for each node of consensus.