quorum

Documentation

Index

• type CountingQuorumTally
  • func (qrm *CountingQuorumTally) Acknowledged(aid int32) bool
  • func (qrm *CountingQuorumTally) Add(aid int32)
  • func (qrm *CountingQuorumTally) CanFormQuorum(aid int32) bool
  • func (qrm *CountingQuorumTally) Reached() bool
• type QuorumTally
• type ResponseHolder
  • func GetResponseHolder() ResponseHolder
• type SpecificQuorumTally
  • func (qrm *SpecificQuorumTally) Acknowledged(aid int32) bool
  • func (qrm *SpecificQuorumTally) Add(id int32)
  • func (qrm *SpecificQuorumTally) CanFormQuorum(aid int32) bool
  • func (qrm *SpecificQuorumTally) Reached() bool

Types

type CountingQuorumTally

type CountingQuorumTally struct {
	ResponseHolder
	Threshold int
	Can       []int32
}

func (*CountingQuorumTally) Acknowledged

func (qrm *CountingQuorumTally) Acknowledged(aid int32) bool

func (*CountingQuorumTally) Add

func (qrm *CountingQuorumTally) Add(aid int32)

func (*CountingQuorumTally) CanFormQuorum

func (qrm *CountingQuorumTally) CanFormQuorum(aid int32) bool

func (*CountingQuorumTally) Reached

func (qrm *CountingQuorumTally) Reached() bool

type QuorumTally

type QuorumTally interface {
	Add(id int32)
	Reached() bool
	Acknowledged(int32) bool
	CanFormQuorum(int32) bool
}

type ResponseHolder

type ResponseHolder struct {
	Nacks map[int32]struct{}
	Acks  map[int32]struct{}
}

func GetResponseHolder

func GetResponseHolder() ResponseHolder

type SpecificQuorumTally

type SpecificQuorumTally struct {
	ResponseHolder
	Qrms [][]int32
	Can  []int32
}

func (*SpecificQuorumTally) Acknowledged

func (qrm *SpecificQuorumTally) Acknowledged(aid int32) bool

func (*SpecificQuorumTally) Add

func (qrm *SpecificQuorumTally) Add(id int32)

func (*SpecificQuorumTally) CanFormQuorum

func (qrm *SpecificQuorumTally) CanFormQuorum(aid int32) bool

func (*SpecificQuorumTally) Reached

func (qrm *SpecificQuorumTally) Reached() bool