agreement

Sep 7, 2022

Changes in this version

+ func CheckBlockCertificate(provisioners user.Provisioners, blk block.Block, seed []byte) error

Jan 26, 2022

Changes in this version

+ func AggregatePks(p *user.Provisioners, subcommittee sortedset.Set) ([]byte, error)

Mar 20, 2021

Changes in this version

+ var WorkerAmount = 4

type Helper

+ Nr int

+ ProvisionersKeys []key.Keys

+ Round uint64

+ func (hlp *Helper) RoundUpdate(hash []byte) consensus.RoundUpdate

+ type Loop struct

+ func (s *Loop) GetControlFn() consensus.ControlFn

+ func (s *Loop) Run(ctx context.Context, roundQueue *consensus.Queue, ...) consensus.Results

Apr 27, 2020

Changes in this version

+ func NewHandler(keys key.Keys, p user.Provisioners) *handler

type Factory

+ Republisher *republisher.Republisher

type Helper

+ func WireAgreement(nrProvisioners int) (*consensus.Coordinator, *Helper)

Dec 24, 2019

Changes in this version

+ const MaxCommitteeSize

+ func CreateCommitteeVoteSet(p *user.Provisioners, k []key.ConsensusKeys, hash []byte, committeeSize int, ...) []consensus.Event

+ func Marshal(r *bytes.Buffer, a Agreement) error

+ func MockConsensusEvent(hash []byte, round uint64, step uint8, keys []key.ConsensusKeys, ...) consensus.Event

+ func MockWire(hash []byte, round uint64, step uint8, keys []key.ConsensusKeys, ...) *bytes.Buffer

+ func Unmarshal(r *bytes.Buffer, a *Agreement) error

+ type Accumulator struct

+ CollectedVotesChan chan []Agreement

+ func (a *Accumulator) Accumulate()

+ func (a *Accumulator) CreateWorkers(amount int)

+ func (a *Accumulator) Process(ev Agreement)

+ func (a *Accumulator) Stop()

type Agreement

+ func (a *Agreement) SetSignature(signedVotes []byte)

+ func (a Agreement) Cmp(other Agreement) int

+ func (a Agreement) Equal(ev wire.Event) bool

+ func (a Agreement) Sender() []byte

+ type Factory struct

+ func NewFactory(publisher eventbus.Publisher, keys key.ConsensusKeys) *Factory

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

+ type Handler interface

+ AmMember func(uint64, uint8) bool

+ Committee func(uint64, uint8) user.VotingCommittee

+ IsMember func([]byte, uint64, uint8) bool

+ Quorum func(uint64) int

+ Verify func(Agreement) error

+ VotesFor func([]byte, uint64, uint8) int

+ type Helper struct

+ Aggro *agreement

+ Bus *eventbus.EventBus

+ CertificateChan chan bytes.Buffer

+ Keys []key.ConsensusKeys

+ P *user.Provisioners

+ func LaunchHelper(eb *eventbus.EventBus, nr int) (*Helper, []byte)

+ func NewHelper(eb *eventbus.EventBus, provisioners int) *Helper

+ func ProduceWinningHash(eb *eventbus.EventBus, nr int) (*Helper, []byte)

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

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

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

Jul 27, 2019

Changes in this version

+ func Launch(eventBroker wire.EventBroker, c committee.Foldable, keys user.Keys)

+ func MarshalStepVotes(r *bytes.Buffer, vote *StepVotes) error

+ func MarshalVotes(r *bytes.Buffer, votes []*StepVotes) error

+ func MockAgreement(hash []byte, round uint64, step uint8, keys []user.Keys) *bytes.Buffer

+ func MockCommittee(quorum int, isMember bool, membersNr int) (*mocks.Foldable, []user.Keys)

+ func ReconstructApk(subcommittee sortedset.Set) (*bls.Apk, error)

+ func Sign(a *Agreement, keys user.Keys) error

+ func UnmarshalVotes(r *bytes.Buffer, votes *[]*StepVotes) error

+ func VerifySignatures(round uint64, step uint8, blockHash []byte, apk *bls.Apk, sig *bls.Signature) error

+ type Agreement struct

+ SignedVotes []byte

+ VotesPerStep []*StepVotes

+ func MockAgreementEvent(hash []byte, round uint64, step uint8, keys []user.Keys) *Agreement

+ func New() *Agreement

+ type StepVotes struct

+ Apk *bls.Apk

+ BitSet uint64

+ Signature *bls.Signature

+ Step uint8

+ func GenVotes(hash []byte, round uint64, step uint8, keys []user.Keys) []*StepVotes

+ func NewStepVotes() *StepVotes

+ func UnmarshalStepVotes(r *bytes.Buffer) (*StepVotes, error)

+ func (sv *StepVotes) Add(signature, sender []byte, step uint8) error

+ func (sv *StepVotes) Equal(other *StepVotes) bool

+ type UnMarshaller struct

+ func NewUnMarshaller() *UnMarshaller

+ func (au *UnMarshaller) Deserialize(r *bytes.Buffer) (wire.Event, error)

+ func (au *UnMarshaller) Marshal(r *bytes.Buffer, ev wire.Event) error

+ func (au *UnMarshaller) Unmarshal(r *bytes.Buffer, ev wire.Event) error