nodekeeper

Nov 1, 2018

Changes in this version

+ func NewNodeNetwork(configuration configuration.Configuration) (core.NodeNetwork, error)

Oct 23, 2018

Changes in this version

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

Oct 16, 2018

Changes in this version

type NodeKeeper

+ GetID func() core.RecordRef

+ GetSelf func() *core.ActiveNode

+ GetUnsyncHolder func(pulse core.PulseNumber, duration time.Duration) (*UnsyncList, error)

+ type UnsyncList struct

+ 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)

Oct 9, 2018

Changes in this version

type NodeKeeper

+ func NewNodeKeeper(unsyncDiscardAfter time.Duration) NodeKeeper

+ AddActiveNodes func([]*core.ActiveNode)

+ GetActiveNode func(ref core.RecordRef) *core.ActiveNode

+ SetPulse func(number core.PulseNumber)

Oct 3, 2018

Changes in this version

+ type NodeKeeper interface

+ AddUnsync func(*core.ActiveNode)

+ AddUnsyncGossip func([]*core.ActiveNode)

+ GetActiveNodes func() []*core.ActiveNode

+ GetUnsync func() []*core.ActiveNode

+ GetUnsyncHash func() (hash []byte, unsyncCount int)

+ Sync func(approved bool)