selection

Jan 26, 2022

Changes in this version

type Handler

+ func NewHandler(keys key.Keys, p user.Provisioners, seed []byte) *Handler

+ func (b *Handler) AmMember(round uint64, step uint8) bool

+ func (b *Handler) Committee(round uint64, step uint8) user.VotingCommittee

+ func (b *Handler) IsMember(pubKeyBLS []byte, round uint64, step uint8) bool

+ func (b *Handler) VerifySignature(scr message.NewBlock) error

Mar 20, 2021

Changes in this version

+ var ProvisionerNr = 10

type Helper

+ P *user.Provisioners

+ Round uint64

+ Step uint8

+ func (h *Helper) RoundUpdate() consensus.RoundUpdate

+ type Phase struct

+ func New(next consensus.Phase, g blockgenerator.BlockGenerator, e *consensus.Emitter, ...) *Phase

+ func (p *Phase) Initialize(_ consensus.InternalPacket) consensus.PhaseFn

+ func (p *Phase) Run(parentCtx context.Context, queue *consensus.Queue, evChan chan message.Message, ...) consensus.PhaseFn

+ func (p *Phase) String() string

Dec 24, 2019

Changes in this version

+ func MarshalScore(r *bytes.Buffer, ev wire.Event) error

+ func UnmarshalScore(r *bytes.Buffer, ev wire.Event) error

+ type Factory struct

+ Bus eventbus.Broker

+ func NewFactory(bus eventbus.Broker, timeout time.Duration) *Factory

+ func (f *Factory) Instantiate() consensus.Component

+ type Handler interface

+ LowerThreshold func()

+ Priority func(Score, Score) bool

+ ResetThreshold func()

+ Verify func(Score) error

+ type Helper struct

+ BestScoreChan chan bytes.Buffer

+ BidList user.BidList

+ Selector *Selector

+ func NewHelper(eb *eventbus.EventBus) *Helper

+ func (h *Helper) GenerateEd25519Fields(ev consensus.Event) []byte

+ func (h *Helper) Initialize(ru consensus.RoundUpdate)

+ func (h *Helper) SendBatch(hash []byte)

+ func (h *Helper) SetHandler(handler Handler)

+ func (h *Helper) Spawn(hash []byte) []consensus.Event

+ func (h *Helper) StartSelection()

+ type Score struct

+ BidListSubset []byte

+ PrevHash []byte

+ Proof []byte

+ Score []byte

+ Seed []byte

+ VoteHash []byte

+ Z []byte

+ func (e Score) Equal(ev wire.Event) bool

+ func (e Score) Sender() []byte

+ type ScoreHandler struct

+ func NewScoreHandler(bidList user.BidList) *ScoreHandler

+ func (sh *ScoreHandler) LowerThreshold()

+ func (sh *ScoreHandler) Priority(first, second Score) bool

+ func (sh *ScoreHandler) ResetThreshold()

+ func (sh *ScoreHandler) Verify(m Score) error

+ type Selector struct

+ func NewComponent(publisher eventbus.Publisher, timeout time.Duration) *Selector

+ func (s *Selector) CollectGeneration(e consensus.Event) error

+ func (s *Selector) CollectScoreEvent(e consensus.Event) error

+ func (s *Selector) Finalize()

+ func (s *Selector) ID() uint32

+ func (s *Selector) IncreaseTimeOut()

+ func (s *Selector) Initialize(eventPlayer consensus.EventPlayer, signer consensus.Signer, ...) []consensus.TopicListener

Jul 27, 2019

Changes in this version

+ func Launch(eventBroker wire.EventBroker, handler ScoreEventHandler, timeout time.Duration)

+ func LaunchNotification(eventbus wire.EventSubscriber) <-chan *ScoreEvent

+ func MarshalScoreEvent(r *bytes.Buffer, ev wire.Event) error

+ func MockSelectionEventBuffer(round uint64, hash []byte) *bytes.Buffer

+ func UnmarshalScoreEvent(r *bytes.Buffer, ev wire.Event) error

+ type ScoreEvent struct

+ BidListSubset []byte

+ Certificate *block.Certificate

+ PrevHash []byte

+ Proof []byte

+ Round uint64

+ Score []byte

+ Seed []byte

+ VoteHash []byte

+ Z []byte

+ func MockSelectionEvent(round uint64, hash []byte) *ScoreEvent

+ func (e *ScoreEvent) Equal(ev wire.Event) bool

+ func (e *ScoreEvent) Sender() []byte

+ type ScoreEventHandler interface

+ LowerThreshold func()

+ RemoveExpiredBids func(uint64)

+ ResetThreshold func()

+ UpdateBidList func(user.Bid)