consensus

Oct 23, 2018

Changes in this version

+ type NodeKeeper interface

+ AddActiveNodes func([]*core.ActiveNode)

+ AddUnsync func(nodeID core.RecordRef, roles []core.NodeRole, address string, version string) (chan *core.ActiveNode, error)

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

+ GetActiveNodes func() []*core.ActiveNode

+ GetActiveNodesByRole func(role core.JetRole) []core.RecordRef

+ GetID func() core.RecordRef

+ GetSelf func() *core.ActiveNode

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

+ SetPulse func(number core.PulseNumber) (bool, UnsyncList)

+ Sync func(syncCandidates []*core.ActiveNode, number core.PulseNumber)

type Processor

+ SetNodeKeeper func(keeper NodeKeeper)

+ type UnsyncList interface

+ AddUnsyncHash func(ref core.RecordRef, hash []*NodeUnsyncHash)

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

+ GetHash func(blockTimeout time.Duration) ([]*NodeUnsyncHash, error)

+ GetPulse func() core.PulseNumber

+ GetUnsync func() []*core.ActiveNode

+ GetUnsyncHash func(ref core.RecordRef) ([]*NodeUnsyncHash, bool)

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

+ SetHash func([]*NodeUnsyncHash)

Oct 16, 2018

Changes in this version

+ func CalculateHash(list []*core.ActiveNode) (result []byte, err error)

+ type CommunicatorReceiver interface

+ ExchangeData func(ctx context.Context, pulse core.PulseNumber, from core.RecordRef, ...) ([]*core.ActiveNode, error)

+ ExchangeHash func(ctx context.Context, pulse core.PulseNumber, from core.RecordRef, ...) ([]*NodeUnsyncHash, error)

+ type NodeUnsyncHash struct

+ Hash []byte

+ NodeID core.RecordRef

+ func CalculateNodeUnsyncHash(nodeID core.RecordRef, list []*core.ActiveNode) (*NodeUnsyncHash, error)

+ type Processor interface

+ IsPartOfConsensus func() bool

+ ProcessPulse func(ctx context.Context, pulse core.Pulse)

+ ReceiverHandler func() CommunicatorReceiver

+ type UnsyncHolder interface

+ GetHash func(blockTimeout time.Duration) ([]*NodeUnsyncHash, error)

+ GetPulse func() core.PulseNumber

+ GetUnsync func() []*core.ActiveNode

+ SetHash func([]*NodeUnsyncHash)

Oct 9, 2018

Changes in this version

+ type Communicator interface

+ ExchangeData func(ctx context.Context, p Participant, data []*core.ActiveNode) ([]*core.ActiveNode, error)

+ ExchangeHash func(ctx context.Context, p Participant, data []byte) ([]byte, error)

+ type Consensus interface

+ DoConsensus func(ctx context.Context, self Participant, allParticipants []*Participant) (bool, error)

+ func NewConsensus(provider DataProvider, communicator Communicator) (Consensus, error)

+ type DataProvider interface

+ GetDataList func() []*core.ActiveNode

+ MergeDataList func([]*core.ActiveNode) error

+ type Participant interface

+ GetActiveNode func() *core.ActiveNode