Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

consensus

package

Go to main page

Versions in this module

v0

v0.6.2

Nov 1, 2018

v0.6.1

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)

v0.6.0

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)

v0.5.0

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