Versions in this module Expand all Collapse all v3 v3.4.4 Mar 18, 2020 Changes in this version + type Config struct + AutoLeave bool + Learners map[uint64]struct{} + LearnersNext map[uint64]struct{} + Voters quorum.JointConfig + func (c *Config) Clone() Config + func (c Config) String() string + type Inflights struct + func NewInflights(size int) *Inflights + func (in *Inflights) Add(inflight uint64) + func (in *Inflights) Clone() *Inflights + func (in *Inflights) Count() int + func (in *Inflights) FreeFirstOne() + func (in *Inflights) FreeLE(to uint64) + func (in *Inflights) Full() bool + type Progress struct + Inflights *Inflights + IsLearner bool + Match uint64 + Next uint64 + PendingSnapshot uint64 + ProbeSent bool + RecentActive bool + State StateType + func (pr *Progress) BecomeProbe() + func (pr *Progress) BecomeReplicate() + func (pr *Progress) BecomeSnapshot(snapshoti uint64) + func (pr *Progress) IsPaused() bool + func (pr *Progress) MaybeDecrTo(rejected, last uint64) bool + func (pr *Progress) MaybeUpdate(n uint64) bool + func (pr *Progress) OptimisticUpdate(n uint64) + func (pr *Progress) ProbeAcked() + func (pr *Progress) ResetState(state StateType) + func (pr *Progress) String() string + type ProgressMap map[uint64]*Progress + func (m ProgressMap) String() string + type ProgressTracker struct + MaxInflight int + Progress ProgressMap + Votes map[uint64]bool + func MakeProgressTracker(maxInflight int) ProgressTracker + func (p *ProgressTracker) Committed() uint64 + func (p *ProgressTracker) ConfState() pb.ConfState + func (p *ProgressTracker) IsSingleton() bool + func (p *ProgressTracker) LearnerNodes() []uint64 + func (p *ProgressTracker) QuorumActive() bool + func (p *ProgressTracker) RecordVote(id uint64, v bool) + func (p *ProgressTracker) ResetVotes() + func (p *ProgressTracker) TallyVotes() (granted int, rejected int, _ quorum.VoteResult) + func (p *ProgressTracker) Visit(f func(id uint64, pr *Progress)) + func (p *ProgressTracker) VoterNodes() []uint64 + type StateType uint64 + const StateProbe + const StateReplicate + const StateSnapshot + func (st StateType) String() string