firststep

Documentation

Index

• type Phase
  • func New(next consensus.Phase, e *consensus.Emitter, ...) *Phase
  • func (p *Phase) Initialize(re consensus.InternalPacket) consensus.PhaseFn
  • func (p *Phase) Run(ctx context.Context, queue *consensus.Queue, evChan chan message.Message, ...) consensus.PhaseFn
  • 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(next consensus.Phase, e *consensus.Emitter, verifyFn consensus.CandidateVerificationFunc, timeOut time.Duration, db database.DB, requestor *candidate.Requestor) *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.

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, evChan 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) String

func (p *Phase) String() string

String returns the reduction.