quorumsystem

Documentation

Index

• type AcceptanceQuorumsConstructor
• type CountingQuorumSynodQuorumSystem
  • func (qrmSys *CountingQuorumSynodQuorumSystem) AddToQuorum(i int32)
  • func (qrmSys *CountingQuorumSynodQuorumSystem) Broadcast(code uint8, msg fastrpc.Serializable) []int32
  • func (qrmSys *CountingQuorumSynodQuorumSystem) GetAcceptanceQuorum() quorum.QuorumTally
  • func (qrmSys *CountingQuorumSynodQuorumSystem) HasAcknowledged(i int32) bool
  • func (qrmSys *CountingQuorumSynodQuorumSystem) QuorumReached() bool
  • func (qrmSys *CountingQuorumSynodQuorumSystem) StartAcceptanceQuorum()
  • func (qrmSys *CountingQuorumSynodQuorumSystem) StartPromiseQuorum()
• type GridQuorumSynodQuorumSystem
  • func (qrmSys *GridQuorumSynodQuorumSystem) AddToQuorum(i int32)
  • func (qrmSys *GridQuorumSynodQuorumSystem) Broadcast(code uint8, msg fastrpc.Serializable) []int32
  • func (qrmSys *GridQuorumSynodQuorumSystem) GetAcceptanceQuorum() quorum.QuorumTally
  • func (qrmSys *GridQuorumSynodQuorumSystem) HasAcknowledged(i int32) bool
  • func (qrmSys *GridQuorumSynodQuorumSystem) QuorumReached() bool
  • func (qrmSys *GridQuorumSynodQuorumSystem) StartAcceptanceQuorum()
  • func (qrmSys *GridQuorumSynodQuorumSystem) StartPromiseQuorum()
• type Phase
• type SynodCountingQuorumSystemConstructor
  • func (constructor *SynodCountingQuorumSystemConstructor) Construct(acceptors []int32) SynodQuorumSystem
  • func (constructor *SynodCountingQuorumSystemConstructor) ConstructAQ(acc []int32) quorum.QuorumTally
• type SynodGridQuorumSystemConstructor
  • func (constructor *SynodGridQuorumSystemConstructor) Construct(acceptors []int32) SynodQuorumSystem
  • func (constructor *SynodGridQuorumSystemConstructor) ConstructAQ(acceptors []int32) quorum.QuorumTally
• type SynodQuorum
• type SynodQuorumSystem
• type SynodQuorumSystemConstructor
• type SynodTringleGridQuorumSystemConstructor

Types

type AcceptanceQuorumsConstructor

type AcceptanceQuorumsConstructor interface {
	ConstructAQ(acceptors []int32) quorum.QuorumTally
}

type CountingQuorumSynodQuorumSystem

type CountingQuorumSynodQuorumSystem struct {
	*genericsmr.Replica
	Phase
	// contains filtered or unexported fields
}

func (*CountingQuorumSynodQuorumSystem) AddToQuorum

func (qrmSys *CountingQuorumSynodQuorumSystem) AddToQuorum(i int32)

func (*CountingQuorumSynodQuorumSystem) Broadcast

func (qrmSys *CountingQuorumSynodQuorumSystem) Broadcast(code uint8, msg fastrpc.Serializable) []int32

func (*CountingQuorumSynodQuorumSystem) GetAcceptanceQuorum

func (qrmSys *CountingQuorumSynodQuorumSystem) GetAcceptanceQuorum() quorum.QuorumTally

func (*CountingQuorumSynodQuorumSystem) HasAcknowledged

func (qrmSys *CountingQuorumSynodQuorumSystem) HasAcknowledged(i int32) bool

func (*CountingQuorumSynodQuorumSystem) QuorumReached

func (qrmSys *CountingQuorumSynodQuorumSystem) QuorumReached() bool

func (*CountingQuorumSynodQuorumSystem) StartAcceptanceQuorum

func (qrmSys *CountingQuorumSynodQuorumSystem) StartAcceptanceQuorum()

func (*CountingQuorumSynodQuorumSystem) StartPromiseQuorum

func (qrmSys *CountingQuorumSynodQuorumSystem) StartPromiseQuorum()

type GridQuorumSynodQuorumSystem

type GridQuorumSynodQuorumSystem struct {
	*genericsmr.Replica
	Phase
	// contains filtered or unexported fields
}

func (*GridQuorumSynodQuorumSystem) AddToQuorum

func (qrmSys *GridQuorumSynodQuorumSystem) AddToQuorum(i int32)

func (*GridQuorumSynodQuorumSystem) Broadcast

func (qrmSys *GridQuorumSynodQuorumSystem) Broadcast(code uint8, msg fastrpc.Serializable) []int32

func (*GridQuorumSynodQuorumSystem) GetAcceptanceQuorum

func (qrmSys *GridQuorumSynodQuorumSystem) GetAcceptanceQuorum() quorum.QuorumTally

func (*GridQuorumSynodQuorumSystem) HasAcknowledged

func (qrmSys *GridQuorumSynodQuorumSystem) HasAcknowledged(i int32) bool

func (*GridQuorumSynodQuorumSystem) QuorumReached

func (qrmSys *GridQuorumSynodQuorumSystem) QuorumReached() bool

func (*GridQuorumSynodQuorumSystem) StartAcceptanceQuorum

func (qrmSys *GridQuorumSynodQuorumSystem) StartAcceptanceQuorum()

func (*GridQuorumSynodQuorumSystem) StartPromiseQuorum

func (qrmSys *GridQuorumSynodQuorumSystem) StartPromiseQuorum()

type Phase

type Phase int

const (
	PROMISE Phase = iota
	ACCEPTANCE
)

type SynodCountingQuorumSystemConstructor

type SynodCountingQuorumSystemConstructor struct {
	F       int
	Thrifty bool
	*genericsmr.Replica
	BroadcastFastest bool
	//broadcastStrat BroadcastStrat
	AllAids          []int32
	SendAllAcceptors bool
}

func (*SynodCountingQuorumSystemConstructor) Construct

func (constructor *SynodCountingQuorumSystemConstructor) Construct(acceptors []int32) SynodQuorumSystem

func (*SynodCountingQuorumSystemConstructor) ConstructAQ

func (constructor *SynodCountingQuorumSystemConstructor) ConstructAQ(acc []int32) quorum.QuorumTally

type SynodGridQuorumSystemConstructor

type SynodGridQuorumSystemConstructor struct {
	F                int
	Thrifty          bool
	BroadcastFastest bool
	*genericsmr.Replica
}

func (*SynodGridQuorumSystemConstructor) Construct

func (constructor *SynodGridQuorumSystemConstructor) Construct(acceptors []int32) SynodQuorumSystem

func (*SynodGridQuorumSystemConstructor) ConstructAQ

func (constructor *SynodGridQuorumSystemConstructor) ConstructAQ(acceptors []int32) quorum.QuorumTally

type SynodQuorum

type SynodQuorum interface {
	HasAcknowledged(int) bool
	Reached() bool
	GetAcks() []int32
}

type SynodQuorumSystem

type SynodQuorumSystem interface {
	StartPromiseQuorum()
	StartAcceptanceQuorum()
	GetAcceptanceQuorum() quorum.QuorumTally
	QuorumReached() bool
	AddToQuorum(int32)
	HasAcknowledged(int32) bool
	Broadcast(code uint8, msg fastrpc.Serializable) []int32
}

type SynodQuorumSystemConstructor

type SynodQuorumSystemConstructor interface {
	AcceptanceQuorumsConstructor
	Construct(acceptors []int32) SynodQuorumSystem
}

type SynodTringleGridQuorumSystemConstructor

type SynodTringleGridQuorumSystemConstructor struct {
	F       int
	Thrifty bool
	*genericsmr.Replica
}