qbft

package

Go to main page

Versions in this module

v0

v0.3.9

Apr 11, 2024

v0.3.8

Apr 9, 2024

Changes in this version

type Config

+ OperatorSigner types.OperatorSigner

+ ShareSigner types.ShareSigner

+ func (c *Config) GetOperatorSigner() types.OperatorSigner

+ func (c *Config) GetShareSigner() types.ShareSigner

type SignedMessage

+ func (signedMsg *SignedMessage) CheckSignersInCommittee(committee []*types.Operator) bool

v0.3.7

Mar 28, 2024

v0.3.7-b

Jul 30, 2024

v0.3.6

Feb 1, 2024

v0.3.5

Jan 21, 2024

v0.3.4

Nov 7, 2023

v0.3.3

Oct 19, 2023

v0.3.2

Sep 11, 2023

Changes in this version

type Instance

+ func (i *Instance) MarshalJSON() ([]byte, error)

+ func (i *Instance) UnmarshalJSON(data []byte) error

v0.3.1

Jul 12, 2023

Changes in this version

+ var CutoffRound = 15

type Instance

+ func (i *Instance) CanProcessMessages() bool

+ func (i *Instance) ForceStop()

v0.3.0

Mar 12, 2023

Changes in this version

+ func HashDataRoot(data []byte) ([32]byte, error)

+ func IsDecidedMsg(share *types.Share, signedDecided *SignedMessage) bool

+ func MarshalJustifications(msgs []*SignedMessage) ([][]byte, error)

+ func ValidateDecided(config IConfig, signedDecided *SignedMessage, share *types.Share) error

+ func ValidateFutureMsg(config IConfig, msg *SignedMessage, operators []*types.Operator) error

type Controller

+ func (c *Controller) BaseMsgValidation(msg *SignedMessage) error

+ func (c *Controller) CanStartInstance() error

type Instance

+ func (i *Instance) BaseMsgValidation(msg *SignedMessage) error

type Message

+ DataRound Round

+ PrepareJustification [][]byte

+ Root [32]byte

+ RoundChangeJustification [][]byte

+ func (m *Message) GetTree() (*ssz.Node, error)

+ func (m *Message) HashTreeRoot() ([32]byte, error)

+ func (m *Message) HashTreeRootWith(hh ssz.HashWalker) (err error)

+ func (m *Message) MarshalSSZ() ([]byte, error)

+ func (m *Message) MarshalSSZTo(buf []byte) (dst []byte, err error)

+ func (m *Message) SizeSSZ() (size int)

+ func (m *Message) UnmarshalSSZ(buf []byte) error

+ func (msg *Message) GetPrepareJustifications() ([]*SignedMessage, error)

+ func (msg *Message) GetRoundChangeJustifications() ([]*SignedMessage, error)

+ func (msg *Message) RoundChangePrepared() bool

type MsgContainer

+ func (c *MsgContainer) AddMsg(msg *SignedMessage)

+ func (c *MsgContainer) LongestUniqueSignersForRoundAndRoot(round Round, root [32]byte) ([]types.OperatorID, []*SignedMessage)

+ func (c *MsgContainer) MessagesForRoundAndRoot(round Round, root [32]byte) []*SignedMessage

type SignedMessage

+ FullData []byte

+ func (s *SignedMessage) GetTree() (*ssz.Node, error)

+ func (s *SignedMessage) HashTreeRoot() ([32]byte, error)

+ func (s *SignedMessage) HashTreeRootWith(hh ssz.HashWalker) (err error)

+ func (s *SignedMessage) MarshalSSZ() ([]byte, error)

+ func (s *SignedMessage) MarshalSSZTo(buf []byte) (dst []byte, err error)

+ func (s *SignedMessage) SizeSSZ() (size int)

+ func (s *SignedMessage) UnmarshalSSZ(buf []byte) error

+ func (signedMsg *SignedMessage) WithoutFUllData() *SignedMessage

type Syncer

+ SyncDecidedByRange func(identifier types.MessageID, to, from Height)

v0.2.7

Nov 2, 2022

Changes in this version

type Controller

+ FutureMsgsContainer map[types.OperatorID]Height

+ func (c *Controller) GetConfig() IConfig

+ func (c *Controller) GetRoot() ([]byte, error)

+ func (c *Controller) UponDecided(msg *SignedMessage) (*SignedMessage, error)

+ func (c *Controller) UponExistingInstanceMsg(msg *SignedMessage) (*SignedMessage, error)

+ func (c *Controller) UponFutureMsg(msg *SignedMessage) (*SignedMessage, error)

type Instance

+ func (i *Instance) GetRoot() ([]byte, error)

+ func (i *Instance) RoundTimeout(round Round) uint64

+ func (i *Instance) UponRoundTimeout() error

type MsgContainer

+ func (c *MsgContainer) AddFirstMsgForSignerAndRound(msg *SignedMessage) (bool, error)

+ type Syncer interface

+ SyncHighestDecided func(identifier types.MessageID) error

+ SyncHighestRoundChange func(identifier types.MessageID, height Height) error

v0.2.2

Aug 2, 2022

Changes in this version

+ func ControllerIdToMessageID(identifier []byte) types.MessageID

type Config

+ func (c *Config) GetStorage() Storage

type Controller

+ func (c *Controller) GenerateConfig() IConfig

type IConfig

+ GetStorage func() Storage

type Storage

+ GetHighestDecided func(identifier []byte) (*SignedMessage, error)

v0.1.1

Jul 12, 2022

Changes in this version

+ const FirstHeight

+ const FirstRound

+ const HistoricalInstanceCapacity

+ const NoRound

+ var SignMsg = func(sk *bls.SecretKey, id types.OperatorID, msg *Message) *SignedMessage

+ var TestingMessage = &Message

+ var TestingSK = func() *bls.SecretKey { ... }()

+ func HasPartialQuorum(share *types.Share, msgs []*SignedMessage) bool

+ func HasQuorum(share *types.Share, msgs []*SignedMessage) bool

+ func RoundRobinProposer(state *State, round Round) types.OperatorID

+ type CommitData struct

+ Data []byte

+ func (d *CommitData) Decode(data []byte) error

+ func (d *CommitData) Encode() ([]byte, error)

+ func (d *CommitData) Validate() error

+ type Config struct

+ Domain types.DomainType

+ Network Network

+ ProposerF ProposerF

+ Signer types.SSVSigner

+ SigningPK []byte

+ Storage Storage

+ Timer Timer

+ ValueCheckF ProposedValueCheckF

+ func (c *Config) GetNetwork() Network

+ func (c *Config) GetProposerF() ProposerF

+ func (c *Config) GetSignatureDomainType() types.DomainType

+ func (c *Config) GetSigner() types.SSVSigner

+ func (c *Config) GetSigningPubKey() []byte

+ func (c *Config) GetTimer() Timer

+ func (c *Config) GetValueCheckF() ProposedValueCheckF

+ type Controller struct

+ Domain types.DomainType

+ Height Height

+ Identifier []byte

+ Share *types.Share

+ StoredInstances InstanceContainer

+ func NewController(identifier []byte, share *types.Share, domain types.DomainType, ...) *Controller

+ func (c *Controller) Decode(data []byte) error

+ func (c *Controller) Encode() ([]byte, error)

+ func (c *Controller) GetIdentifier() []byte

+ func (c *Controller) InstanceForHeight(height Height) *Instance

+ func (c *Controller) ProcessMsg(msg *SignedMessage) (bool, []byte, error)

+ func (c *Controller) StartNewInstance(value []byte) error

+ type DecidedMessage struct

+ SignedMessage *SignedMessage

+ func (msg *DecidedMessage) Decode(data []byte) error

+ func (msg *DecidedMessage) Encode() ([]byte, error)

+ type Height int64

+ type IConfig interface

+ GetNetwork func() Network

+ GetProposerF func() ProposerF

+ GetTimer func() Timer

+ GetValueCheckF func() ProposedValueCheckF

+ type Instance struct

+ StartValue []byte

+ State *State

+ func NewInstance(config IConfig, share *types.Share, identifier []byte, height Height) *Instance

+ func (i *Instance) Broadcast(msg *SignedMessage) error

+ func (i *Instance) Decode(data []byte) error

+ func (i *Instance) Encode() ([]byte, error)

+ func (i *Instance) GetConfig() IConfig

+ func (i *Instance) GetHeight() Height

+ func (i *Instance) IsDecided() (bool, []byte)

+ func (i *Instance) ProcessMsg(msg *SignedMessage) (decided bool, decidedValue []byte, aggregatedCommit *SignedMessage, err error)

+ func (i *Instance) Start(value []byte, height Height)

+ func (i *Instance) UponCommit(signedCommit *SignedMessage, commitMsgContainer *MsgContainer) (bool, []byte, *SignedMessage, error)

+ type InstanceContainer [HistoricalInstanceCapacity]*Instance

+ func (i InstanceContainer) FindInstance(height Height) *Instance

+ type Message struct

+ Data []byte

+ Height Height

+ Identifier []byte

+ MsgType MessageType

+ Round Round

+ func (msg *Message) Decode(data []byte) error

+ func (msg *Message) Encode() ([]byte, error)

+ func (msg *Message) GetCommitData() (*CommitData, error)

+ func (msg *Message) GetPrepareData() (*PrepareData, error)

+ func (msg *Message) GetProposalData() (*ProposalData, error)

+ func (msg *Message) GetRoot() ([]byte, error)

+ func (msg *Message) GetRoundChangeData() (*RoundChangeData, error)

+ func (msg *Message) Validate() error

+ type MessageType int

+ const CommitMsgType

+ const PrepareMsgType

+ const ProposalMsgType

+ const RoundChangeMsgType

+ type MsgContainer struct

+ Msgs map[Round][]*SignedMessage

+ func NewMsgContainer() *MsgContainer

+ func (c *MsgContainer) AddIfDoesntExist(msg *SignedMessage) (bool, error)

+ func (c *MsgContainer) AllMessaged() []*SignedMessage

+ func (c *MsgContainer) Decode(data []byte) error

+ func (c *MsgContainer) Encode() ([]byte, error)

+ func (c *MsgContainer) LongestUniqueSignersForRoundAndValue(round Round, value []byte) ([]types.OperatorID, []*SignedMessage)

+ func (c *MsgContainer) MessagesForRound(round Round) []*SignedMessage

+ func (c *MsgContainer) MessagesForRoundAndValue(round Round, value []byte) []*SignedMessage

+ type Network interface

+ Broadcast func(msg types.Encoder) error

+ BroadcastDecided func(msg types.Encoder) error

+ type PrepareData struct

+ Data []byte

+ func (d *PrepareData) Decode(data []byte) error

+ func (d *PrepareData) Encode() ([]byte, error)

+ func (d *PrepareData) Validate() error

+ type ProposalData struct

+ Data []byte

+ PrepareJustification []*SignedMessage

+ RoundChangeJustification []*SignedMessage

+ func (d *ProposalData) Decode(data []byte) error

+ func (d *ProposalData) Encode() ([]byte, error)

+ func (d *ProposalData) Validate() error

+ type ProposedValueCheckF func(data []byte) error

+ type ProposerF func(state *State, round Round) types.OperatorID

+ type Round uint64

+ type RoundChangeData struct

+ NextProposalData []byte

+ PreparedRound Round

+ PreparedValue []byte

+ RoundChangeJustification []*SignedMessage

+ func (d *RoundChangeData) Decode(data []byte) error

+ func (d *RoundChangeData) Encode() ([]byte, error)

+ func (d *RoundChangeData) Prepared() bool

+ func (d *RoundChangeData) Validate() error

+ type SignedMessage struct

+ Message *Message

+ Signature types.Signature

+ Signers []types.OperatorID

+ func CreateCommit(state *State, config IConfig, value []byte) (*SignedMessage, error)

+ func CreatePrepare(state *State, config IConfig, newRound Round, value []byte) (*SignedMessage, error)

+ func CreateProposal(state *State, config IConfig, value []byte, ...) (*SignedMessage, error)

+ func CreateRoundChange(state *State, config IConfig, newRound Round, instanceStartValue []byte) (*SignedMessage, error)

+ func (signedMsg *SignedMessage) Aggregate(sig types.MessageSignature) error

+ func (signedMsg *SignedMessage) CommonSigners(ids []types.OperatorID) bool

+ func (signedMsg *SignedMessage) Decode(data []byte) error

+ func (signedMsg *SignedMessage) DeepCopy() *SignedMessage

+ func (signedMsg *SignedMessage) Encode() ([]byte, error)

+ func (signedMsg *SignedMessage) GetRoot() ([]byte, error)

+ func (signedMsg *SignedMessage) GetSignature() types.Signature

+ func (signedMsg *SignedMessage) GetSigners() []types.OperatorID

+ func (signedMsg *SignedMessage) MatchedSigners(ids []types.OperatorID) bool

+ func (signedMsg *SignedMessage) Validate() error

+ type State struct

+ CommitContainer *MsgContainer

+ Decided bool

+ DecidedValue []byte

+ Height Height

+ ID []byte

+ LastPreparedRound Round

+ LastPreparedValue []byte

+ PrepareContainer *MsgContainer

+ ProposalAcceptedForCurrentRound *SignedMessage

+ ProposeContainer *MsgContainer

+ Round Round

+ RoundChangeContainer *MsgContainer

+ Share *types.Share

+ func (s *State) Decode(data []byte) error

+ func (s *State) Encode() ([]byte, error)

+ func (s *State) GetRoot() ([]byte, error)

+ type Storage interface

+ SaveHighestDecided func(signedMsg *SignedMessage) error

+ type Timer interface

+ TimeoutForRound func(round Round)

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