instance

package

Go to main page

Versions in this module

v0

v0.3.4

Oct 20, 2022

v0.3.3

Oct 14, 2022

v0.3.2

Sep 21, 2022

Changes in this version

+ func GenerateState(opts *Options) *qbft.State

type ControllerStartInstanceOptions

+ Height specqbft.Height

type Instance

+ ContainersMap map[specqbft.MessageType]msgcont.MessageContainer

+ SsvSigner spectypes.SSVSigner

+ func (i *Instance) GenerateChangeRoundMessage() (*specqbft.Message, error)

+ func (i *Instance) GenerateCommitMessage(value []byte) (*specqbft.Message, error)

+ func (i *Instance) GeneratePrepareMessage(value []byte) (*specqbft.Message, error)

+ func (i *Instance) GenerateProposalMessage(proposalMsg *specqbft.ProposalData) (specqbft.Message, error)

+ func (i *Instance) GetState() *qbft.State

+ func (i *Instance) HighestRoundTimeoutSeconds() time.Duration

+ func (i *Instance) PrepareMsgValidationPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) ProposalMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) UponProposalMsg() pipelines.SignedMessagePipeline

type Instancer

+ GetState func() *qbft.State

+ HighestRoundTimeoutSeconds func() time.Duration

v0.3.2-rc.1

Sep 20, 2022

v0.3.1

Aug 29, 2022

v0.3.0

Aug 17, 2022

Changes in this version

+ func UpdateChangeRoundMessage(logger *zap.Logger, changeRoundStorage qbftstorage.ChangeRoundStore, ...) error

type Instance

+ func (i *Instance) Containers() map[specqbft.MessageType]msgcont.MessageContainer

type Instancer

+ Containers func() map[specqbft.MessageType]msgcont.MessageContainer

type Options

+ SSVSigner spectypes.SSVSigner

v0.3.0-rc.1

Aug 8, 2022

v0.3.0-rc.0

Aug 4, 2022

v0.2.1-rc.7

Aug 2, 2022

v0.2.1-rc.6

Aug 1, 2022

v0.2.1-rc.5

Jul 13, 2022

v0.2.1-rc.4

Jun 30, 2022

v0.2.1-rc.3

Jun 28, 2022

v0.2.1-rc.2

Jun 27, 2022

v0.2.1-rc.1

Jun 23, 2022

v0.2.0

Jun 15, 2022

Changes in this version

+ func ProcessLateCommitMsg(msg *message.SignedMessage, qbftStore qbftstorage.QBFTStore, ...) (*message.SignedMessage, error)

+ type ControllerStartInstanceOptions struct

+ Logger *zap.Logger

+ RequireMinPeers bool

+ SeqNumber message.Height

+ Value []byte

+ type Instance struct

+ ChangeRoundMessages msgcont.MessageContainer

+ CommitMessages msgcont.MessageContainer

+ Config *qbft.InstanceConfig

+ LeaderSelector leader.Selector

+ Logger *zap.Logger

+ PrePrepareMessages msgcont.MessageContainer

+ PrepareMessages msgcont.MessageContainer

+ ValidatorShare *beaconprotocol.Share

+ func (i *Instance) BroadcastChangeRound() error

+ func (i *Instance) BumpRound()

+ func (i *Instance) ChangeRoundMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) ChangeRoundMsgValidationPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) ChangeRoundPartialQuorumMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) CommitMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) CommitMsgValidationPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) CommittedAggregatedMsg() (*message.SignedMessage, error)

+ func (i *Instance) DecidedMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) ForceDecide(msg *message.SignedMessage)

+ func (i *Instance) GetCommittedAggSSVMessage() (message.SSVMessage, error)

+ func (i *Instance) GetStageChan() chan qbft.RoundState

+ func (i *Instance) HighestPrepared(round message.Round) (notPrepared bool, highestPrepared *message.RoundChangeData, err error)

+ func (i *Instance) Init()

+ func (i *Instance) IsLeader() bool

+ func (i *Instance) JustifyPrePrepare(round uint64, preparedValue []byte) error

+ func (i *Instance) JustifyRoundChange(round message.Round) error

+ func (i *Instance) PrePrepareMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) PrepareMsgPipeline() pipelines.SignedMessagePipeline

+ func (i *Instance) PreparedAggregatedMsg() (*message.SignedMessage, error)

+ func (i *Instance) ProcessMsg(msg *message.SignedMessage) (bool, error)

+ func (i *Instance) ProcessStageChange(stage qbft.RoundState)

+ func (i *Instance) ResetRoundTimer()

+ func (i *Instance) RoundLeader(round message.Round) uint64

+ func (i *Instance) SignAndBroadcast(msg *message.ConsensusMessage) error

+ func (i *Instance) Start(inputValue []byte) error

+ func (i *Instance) State() *qbft.State

+ func (i *Instance) Stop()

+ func (i *Instance) Stopped() bool

+ func (i *Instance) ThisRoundLeader() uint64

+ func (i *Instance) UponPrePrepareMsg() pipelines.SignedMessagePipeline

+ type Instancer interface

+ BroadcastChangeRound func() error

+ CommittedAggregatedMsg func() (*message.SignedMessage, error)

+ ForceDecide func(msg *message.SignedMessage)

+ GetCommittedAggSSVMessage func() (message.SSVMessage, error)

+ GetStageChan func() chan qbft.RoundState

+ Init func()

+ ProcessMsg func(msg *message.SignedMessage) (bool, error)

+ ResetRoundTimer func()

+ Start func(inputValue []byte) error

+ State func() *qbft.State

+ Stop func()

+ func NewInstance(opts *Options) Instancer

+ func NewInstanceWithState(state *qbft.State) Instancer

+ type Options struct

+ ChangeRoundStore qbftstorage.ChangeRoundStore

+ Config *qbft.InstanceConfig

+ Fork forks.Fork

+ Height message.Height

+ Identifier message.Identifier

+ LeaderSelector leader.Selector

+ Logger *zap.Logger

+ Network protcolp2p.Network

+ RequireMinPeers bool

+ Signer beaconprotocol.Signer

+ ValidatorShare *beaconprotocol.Share

+ type Result struct

+ Decided bool

+ Msg *message.SignedMessage

v0.2.0-rc.1

Jun 15, 2022

v0.2.0-rc

Jun 8, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL