Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommittedBlock ¶
type CommittedBlock struct {
Block *drctypes.BlockData
Ir []*InputData
Qc *drctypes.QuorumCert // block's quorum certificate (from next view)
CommitQc *drctypes.QuorumCert // commit certificate
// contains filtered or unexported fields
}
func (*CommittedBlock) GetRound ¶
func (r *CommittedBlock) GetRound() uint64
func (*CommittedBlock) IsValid ¶
func (r *CommittedBlock) IsValid() error
type GetStateMsg ¶
type GetStateMsg struct {
// ID of the node which requested the state, ie response should
// be sent to that node
NodeId string
// contains filtered or unexported fields
}
type InputData ¶
type InputData struct {
SysID types.SystemID
Ir *types.InputRecord
Sdrh []byte
// contains filtered or unexported fields
}
type IrChangeReqMsg ¶
type IrChangeReqMsg struct {
Author string `json:"author,omitempty"`
IrChangeReq *abdrc.IRChangeReq `json:"ir_change_req,omitempty"`
Signature []byte `json:"signature,omitempty"`
// contains filtered or unexported fields
}
func (*IrChangeReqMsg) IsValid ¶
func (x *IrChangeReqMsg) IsValid() error
type ProposalMsg ¶
type ProposalMsg struct {
Block *types.BlockData `json:"block,omitempty"` // Proposed change
LastRoundTc *types.TimeoutCert `json:"last_round_tc,omitempty"` // Last timeout certificate for block.round - 1 if block.qc.round != block.round - 1
Signature []byte `json:"signature,omitempty"`
// contains filtered or unexported fields
}
func (*ProposalMsg) IsValid ¶
func (x *ProposalMsg) IsValid() error
type StateMsg ¶
type StateMsg struct {
Certificates []*types.UnicityCertificate
CommittedHead *CommittedBlock
BlockData []*drctypes.BlockData
// contains filtered or unexported fields
}
func (*StateMsg) CanRecoverToRound ¶
CanRecoverToRound returns non-nil error when the state message is not suitable for recovery into round "round".
type TimeoutMsg ¶
type TimeoutMsg struct {
Timeout *abdrc.Timeout `json:"timeout,omitempty"`
Author string `json:"author,omitempty"`
Signature []byte `json:"signature,omitempty"`
// contains filtered or unexported fields
}
func NewTimeoutMsg ¶
func NewTimeoutMsg(timeout *abdrc.Timeout, author string) *TimeoutMsg
NewTimeoutMsg constructs a new atomic broadcast timeout message
func (*TimeoutMsg) Bytes ¶
func (x *TimeoutMsg) Bytes() []byte
func (*TimeoutMsg) GetRound ¶
func (x *TimeoutMsg) GetRound() uint64
func (*TimeoutMsg) IsValid ¶
func (x *TimeoutMsg) IsValid() error
type VoteMsg ¶
type VoteMsg struct {
VoteInfo *drctypes.RoundInfo `json:"vote_info,omitempty"` // Proposed block hash and resulting state hash
LedgerCommitInfo *types.UnicitySeal `json:"ledger_commit_info,omitempty"` // Commit info
HighQc *drctypes.QuorumCert `json:"high_qc,omitempty"` // Sync with highest QC
Author string `json:"author,omitempty"` // Voter node identifier
Signature []byte `json:"signature,omitempty"` // Vote signature on hash of consensus info
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.