learner

Documentation

Index

• type AQConstructor
• type BcastAcceptLearner
  • func GetBcastAcceptLearner(qrmC AQConstructor) BcastAcceptLearner
  • func (l *BcastAcceptLearner) GetChosen(inst int32) (stdpaxosproto.Ballot, []*state.Command, int32)
  • func (l *BcastAcceptLearner) HasLearntValue(inst int32) bool
  • func (l *BcastAcceptLearner) IsChosen(inst int32) bool
  • func (l *BcastAcceptLearner) ProposalAccepted(inst int32, ballot stdpaxosproto.Ballot, aid int32)
  • func (l *BcastAcceptLearner) ProposalChosen(inst int32, ballot stdpaxosproto.Ballot)
  • func (l *BcastAcceptLearner) ProposalValue(inst int32, ballot stdpaxosproto.Ballot, commands []*state.Command, ...)
• type DesignatedLearner
  • func GetDesignedLearner(qrmC AQConstructor) DesignatedLearner
  • func (l *DesignatedLearner) GetChosen(inst int32) (stdpaxosproto.Ballot, []*state.Command, int32)
  • func (l *DesignatedLearner) HasLearntValue(inst int32) bool
  • func (l *DesignatedLearner) IsChosen(inst int32) bool
  • func (l *DesignatedLearner) ProposalAccepted(inst int32, ballot stdpaxosproto.Ballot, aid int32)
  • func (l *DesignatedLearner) ProposalChosen(inst int32, ballot stdpaxosproto.Ballot)
  • func (l *DesignatedLearner) ProposalValue(inst int32, ballot stdpaxosproto.Ballot, commands []*state.Command, ...)
• type Learner
• type Minimal
  • func GetMinimalGroupAQConstructorr(n, f int32, ids []int32, constructor quorumsystem.AcceptanceQuorumsConstructor, ...) Minimal
  • func (q *Minimal) CreateTally(inst int32) quorum.QuorumTally
• type Standard
  • func GetStandardGroupAQConstructorr(ids []int32, constructor quorumsystem.AcceptanceQuorumsConstructor, me int32) Standard
  • func (q *Standard) CreateTally(inst int32) quorum.QuorumTally
• type StaticDefined
  • func GetStaticDefinedAQConstructor(instags [][]int32, constructor quorumsystem.AcceptanceQuorumsConstructor) StaticDefined

Types

type AQConstructor

type AQConstructor interface {
	CreateTally(inst int32) quorum.QuorumTally
}

type BcastAcceptLearner

type BcastAcceptLearner struct {
	AQConstructor
	// contains filtered or unexported fields
}

find out that a ballot is chosen, find out the value of a ballot equal to or greater than

func GetBcastAcceptLearner

func GetBcastAcceptLearner(qrmC AQConstructor) BcastAcceptLearner

func (*BcastAcceptLearner) GetChosen

func (l *BcastAcceptLearner) GetChosen(inst int32) (stdpaxosproto.Ballot, []*state.Command, int32)

func (*BcastAcceptLearner) HasLearntValue

func (l *BcastAcceptLearner) HasLearntValue(inst int32) bool

func (*BcastAcceptLearner) IsChosen

func (l *BcastAcceptLearner) IsChosen(inst int32) bool

func (*BcastAcceptLearner) ProposalAccepted

func (l *BcastAcceptLearner) ProposalAccepted(inst int32, ballot stdpaxosproto.Ballot, aid int32)

func (*BcastAcceptLearner) ProposalChosen

func (l *BcastAcceptLearner) ProposalChosen(inst int32, ballot stdpaxosproto.Ballot)

func (*BcastAcceptLearner) ProposalValue

func (l *BcastAcceptLearner) ProposalValue(inst int32, ballot stdpaxosproto.Ballot, commands []*state.Command, whose int32)

type DesignatedLearner

type DesignatedLearner struct {
	AQConstructor
	// contains filtered or unexported fields
}

func GetDesignedLearner

func GetDesignedLearner(qrmC AQConstructor) DesignatedLearner

func (*DesignatedLearner) GetChosen

func (l *DesignatedLearner) GetChosen(inst int32) (stdpaxosproto.Ballot, []*state.Command, int32)

func (*DesignatedLearner) HasLearntValue

func (l *DesignatedLearner) HasLearntValue(inst int32) bool

func (*DesignatedLearner) IsChosen

func (l *DesignatedLearner) IsChosen(inst int32) bool

func (*DesignatedLearner) ProposalAccepted

func (l *DesignatedLearner) ProposalAccepted(inst int32, ballot stdpaxosproto.Ballot, aid int32)

func (*DesignatedLearner) ProposalChosen

func (l *DesignatedLearner) ProposalChosen(inst int32, ballot stdpaxosproto.Ballot)

func (*DesignatedLearner) ProposalValue

func (l *DesignatedLearner) ProposalValue(inst int32, ballot stdpaxosproto.Ballot, commands []*state.Command, whose int32)

type Learner

type Learner interface {
	//ClientValueProposed(inst32, batching.ProposalBatch)
	ProposalAccepted(inst int32, ballot stdpaxosproto.Ballot, by int32)
	ProposalValue(inst int32, ballot stdpaxosproto.Ballot, cmd []*state.Command, whosecmd int32)
	ProposalChosen(inst int32, ballot stdpaxosproto.Ballot)
	IsChosen(int32) bool       // has chosen ballot
	HasLearntValue(int32) bool // has learnt value
	GetChosen(int32) (stdpaxosproto.Ballot, []*state.Command, int32)
}

type Minimal

type Minimal struct {
	AcceptorMapper instanceagentmapper.InstanceAgentMapper
	quorumsystem.AcceptanceQuorumsConstructor
	MyID int32
}

func GetMinimalGroupAQConstructorr

func GetMinimalGroupAQConstructorr(n, f int32, ids []int32, constructor quorumsystem.AcceptanceQuorumsConstructor, me int32) Minimal

func (*Minimal) CreateTally

func (q *Minimal) CreateTally(inst int32) quorum.QuorumTally

type Standard

type Standard struct {
	quorumsystem.AcceptanceQuorumsConstructor
	Aids []int32
	MyID int32
}

func GetStandardGroupAQConstructorr

func GetStandardGroupAQConstructorr(ids []int32, constructor quorumsystem.AcceptanceQuorumsConstructor, me int32) Standard

func (*Standard) CreateTally

func (q *Standard) CreateTally(inst int32) quorum.QuorumTally

type StaticDefined

type StaticDefined struct {
	instanceagentmapper.FixedInstanceAgentMapping
	quorumsystem.AcceptanceQuorumsConstructor
}

func GetStaticDefinedAQConstructor

func GetStaticDefinedAQConstructor(instags [][]int32, constructor quorumsystem.AcceptanceQuorumsConstructor) StaticDefined