secondstep

Documentation

Index

• type Phase
  • func New(e *consensus.Emitter, verifyFn consensus.CandidateVerificationFunc, ...) *Phase
  • func (p *Phase) Initialize(re consensus.InternalPacket) consensus.PhaseFn
  • func (p *Phase) Run(ctx context.Context, queue *consensus.Queue, ...) consensus.PhaseFn
  • func (p *Phase) SetNext(next consensus.Phase)
  • func (p *Phase) String() string

Types

type Phase

type Phase struct {
	*reduction.Reduction
	// contains filtered or unexported fields
}

Phase is the implementation of the Selection step component.

func New

func New(e *consensus.Emitter, verifyFn consensus.CandidateVerificationFunc, timeOut time.Duration) *Phase

New creates and launches the component which responsibility is to reduce the candidates gathered as winner of the selection of all nodes in the committee and reduce them to just one candidate obtaining 64% of the committee vote. NB: we cannot push the agreement directly within the agreementChannel until we have a way to deduplicate it from the peer (the dupemap will not be notified of duplicates).

func (*Phase) Initialize

func (p *Phase) Initialize(re consensus.InternalPacket) consensus.PhaseFn

Initialize passes to this reduction step the best score collected during selection.

func (*Phase) Run

func (p *Phase) Run(ctx context.Context, queue *consensus.Queue, _, reductionChan chan message.Message, r consensus.RoundUpdate, step uint8) consensus.PhaseFn

Run the first reduction step until either there is a timeout, we reach 64% of votes, or we experience an unrecoverable error.

func (*Phase) SetNext

func (p *Phase) SetNext(next consensus.Phase)

SetNext sets the next step to be returned at the end of this one.

func (*Phase) String

func (p *Phase) String() string

String representation of this Phase.