tbft_engine

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTbft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTbft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTbft = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Step_name = map[int32]string{
	0: "NEW_HEIGHT",
	1: "NEW_ROUND",
	2: "PROPOSE",
	3: "PREVOTE",
	4: "PREVOTE_WAIT",
	5: "PRECOMMIT",
	6: "PRECOMMIT_WAIT",
	7: "COMMIT",
}
View Source 
var Step_value = map[string]int32{
	"NEW_HEIGHT":     0,
	"NEW_ROUND":      1,
	"PROPOSE":        2,
	"PREVOTE":        3,
	"PREVOTE_WAIT":   4,
	"PRECOMMIT":      5,
	"PRECOMMIT_WAIT": 6,
	"COMMIT":         7,
}
View Source 
var TBFTMsgType_name = map[int32]string{
	0: "MSG_PROPOSE",
	1: "MSG_PREVOTE",
	2: "MSG_PRECOMMIT",
	3: "MSG_STATE",
	4: "MSG_FETCH_ROUNDQC",
	5: "MSG_SEND_ROUND_QC",
}
View Source 
var TBFTMsgType_value = map[string]int32{
	"MSG_PROPOSE":       0,
	"MSG_PREVOTE":       1,
	"MSG_PRECOMMIT":     2,
	"MSG_STATE":         3,
	"MSG_FETCH_ROUNDQC": 4,
	"MSG_SEND_ROUND_QC": 5,
}
View Source 
var VerifyResult_Code_name = map[int32]string{
	0: "VerifyResult_SUCCESS",
	1: "VerifyResult_FAIL",
}
View Source 
var VerifyResult_Code_value = map[string]int32{
	"VerifyResult_SUCCESS": 0,
	"VerifyResult_FAIL":    1,
}
View Source 
var VoteType_name = map[int32]string{
	0: "VOTE_PREVOTE",
	1: "VOTE_PRECOMMIT",
}
View Source 
var VoteType_value = map[string]int32{
	"VOTE_PREVOTE":   0,
	"VOTE_PRECOMMIT": 1,
}
View Source 
var WalEntryType_name = map[int32]string{
	0: "TIMEOUT_ENTRY",
	1: "PROPOSAL_ENTRY",
	2: "VOTE_ENTRY",
	3: "PROPOSAL_VOTE_ENTRY",
}
View Source 
var WalEntryType_value = map[string]int32{
	"TIMEOUT_ENTRY":       0,
	"PROPOSAL_ENTRY":      1,
	"VOTE_ENTRY":          2,
	"PROPOSAL_VOTE_ENTRY": 3,
}

Functions

This section is empty.

Types

type BlockVotes 

type BlockVotes struct {
	Votes map[string]*Vote `` /* 151-byte string literal not displayed */
	Sum   uint64           `protobuf:"varint,2,opt,name=sum,proto3" json:"sum,omitempty"`
}

BlockVotes represents votes as key-value form

func (*BlockVotes) Descriptor 

func (*BlockVotes) Descriptor() ([]byte, []int)

func (*BlockVotes) GetSum 

func (m *BlockVotes) GetSum() uint64

func (*BlockVotes) GetVotes 

func (m *BlockVotes) GetVotes() map[string]*Vote

func (*BlockVotes) Marshal 

func (m *BlockVotes) Marshal() (dAtA []byte, err error)

func (*BlockVotes) MarshalTo 

func (m *BlockVotes) MarshalTo(dAtA []byte) (int, error)

func (*BlockVotes) MarshalToSizedBuffer 

func (m *BlockVotes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockVotes) ProtoMessage 

func (*BlockVotes) ProtoMessage()

func (*BlockVotes) Reset 

func (m *BlockVotes) Reset()

func (*BlockVotes) Size 

func (m *BlockVotes) Size() (n int)

func (*BlockVotes) String 

func (m *BlockVotes) String() string

func (*BlockVotes) Unmarshal 

func (m *BlockVotes) Unmarshal(dAtA []byte) error

func (*BlockVotes) XXX_DiscardUnknown 

func (m *BlockVotes) XXX_DiscardUnknown()

func (*BlockVotes) XXX_Marshal 

func (m *BlockVotes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockVotes) XXX_Merge 

func (m *BlockVotes) XXX_Merge(src proto.Message)

func (*BlockVotes) XXX_Size 

func (m *BlockVotes) XXX_Size() int

func (*BlockVotes) XXX_Unmarshal 

func (m *BlockVotes) XXX_Unmarshal(b []byte) error

type ConsensusState 

type ConsensusState struct {
	Id                 string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Height             uint64              `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Round              int32               `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Step               Step                `protobuf:"varint,4,opt,name=step,proto3,enum=tbft_engine.Step" json:"step,omitempty"`
	Proposal           *Proposal           `protobuf:"bytes,5,opt,name=proposal,proto3" json:"proposal,omitempty"`
	VerifingProposal   *Proposal           `protobuf:"bytes,6,opt,name=verifing_proposal,json=verifingProposal,proto3" json:"verifing_proposal,omitempty"`
	LockedProposal     *Proposal           `protobuf:"bytes,7,opt,name=locked_proposal,json=lockedProposal,proto3" json:"locked_proposal,omitempty"`
	ValidProposal      *Proposal           `protobuf:"bytes,8,opt,name=valid_proposal,json=validProposal,proto3" json:"valid_proposal,omitempty"`
	HeightRoundVoteSet *HeightRoundVoteSet `protobuf:"bytes,9,opt,name=height_round_vote_set,json=heightRoundVoteSet,proto3" json:"height_round_vote_set,omitempty"`
}

ConsensusState represents the state of tbft instance

func (*ConsensusState) Descriptor 

func (*ConsensusState) Descriptor() ([]byte, []int)

func (*ConsensusState) GetHeight 

func (m *ConsensusState) GetHeight() uint64

func (*ConsensusState) GetHeightRoundVoteSet 

func (m *ConsensusState) GetHeightRoundVoteSet() *HeightRoundVoteSet

func (*ConsensusState) GetId 

func (m *ConsensusState) GetId() string

func (*ConsensusState) GetLockedProposal 

func (m *ConsensusState) GetLockedProposal() *Proposal

func (*ConsensusState) GetProposal 

func (m *ConsensusState) GetProposal() *Proposal

func (*ConsensusState) GetRound 

func (m *ConsensusState) GetRound() int32

func (*ConsensusState) GetStep 

func (m *ConsensusState) GetStep() Step

func (*ConsensusState) GetValidProposal 

func (m *ConsensusState) GetValidProposal() *Proposal

func (*ConsensusState) GetVerifingProposal 

func (m *ConsensusState) GetVerifingProposal() *Proposal

func (*ConsensusState) Marshal 

func (m *ConsensusState) Marshal() (dAtA []byte, err error)

func (*ConsensusState) MarshalTo 

func (m *ConsensusState) MarshalTo(dAtA []byte) (int, error)

func (*ConsensusState) MarshalToSizedBuffer 

func (m *ConsensusState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConsensusState) ProtoMessage 

func (*ConsensusState) ProtoMessage()

func (*ConsensusState) Reset 

func (m *ConsensusState) Reset()

func (*ConsensusState) Size 

func (m *ConsensusState) Size() (n int)

func (*ConsensusState) String 

func (m *ConsensusState) String() string

func (*ConsensusState) Unmarshal 

func (m *ConsensusState) Unmarshal(dAtA []byte) error

func (*ConsensusState) XXX_DiscardUnknown 

func (m *ConsensusState) XXX_DiscardUnknown()

func (*ConsensusState) XXX_Marshal 

func (m *ConsensusState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConsensusState) XXX_Merge 

func (m *ConsensusState) XXX_Merge(src proto.Message)

func (*ConsensusState) XXX_Size 

func (m *ConsensusState) XXX_Size() int

func (*ConsensusState) XXX_Unmarshal 

func (m *ConsensusState) XXX_Unmarshal(b []byte) error

type FetchRoundQC 

type FetchRoundQC struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round    int32  `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
}

FetchRoundQC defined a fetch roundQC request which can be gossiped to other node

func (*FetchRoundQC) Descriptor 

func (*FetchRoundQC) Descriptor() ([]byte, []int)

func (*FetchRoundQC) GetId 

func (m *FetchRoundQC) GetId() string

func (*FetchRoundQC) GetRound 

func (m *FetchRoundQC) GetRound() int32

func (*FetchRoundQC) GetSequence 

func (m *FetchRoundQC) GetSequence() uint64

func (*FetchRoundQC) Marshal 

func (m *FetchRoundQC) Marshal() (dAtA []byte, err error)

func (*FetchRoundQC) MarshalTo 

func (m *FetchRoundQC) MarshalTo(dAtA []byte) (int, error)

func (*FetchRoundQC) MarshalToSizedBuffer 

func (m *FetchRoundQC) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FetchRoundQC) ProtoMessage 

func (*FetchRoundQC) ProtoMessage()

func (*FetchRoundQC) Reset 

func (m *FetchRoundQC) Reset()

func (*FetchRoundQC) Size 

func (m *FetchRoundQC) Size() (n int)

func (*FetchRoundQC) String 

func (m *FetchRoundQC) String() string

func (*FetchRoundQC) Unmarshal 

func (m *FetchRoundQC) Unmarshal(dAtA []byte) error

func (*FetchRoundQC) XXX_DiscardUnknown 

func (m *FetchRoundQC) XXX_DiscardUnknown()

func (*FetchRoundQC) XXX_Marshal 

func (m *FetchRoundQC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchRoundQC) XXX_Merge 

func (m *FetchRoundQC) XXX_Merge(src proto.Message)

func (*FetchRoundQC) XXX_Size 

func (m *FetchRoundQC) XXX_Size() int

func (*FetchRoundQC) XXX_Unmarshal 

func (m *FetchRoundQC) XXX_Unmarshal(b []byte) error

type GossipState 

type GossipState struct {
	Id               string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Height           uint64        `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Round            int32         `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Step             Step          `protobuf:"varint,4,opt,name=step,proto3,enum=tbft_engine.Step" json:"step,omitempty"`
	Proposal         []byte        `protobuf:"bytes,5,opt,name=proposal,proto3" json:"proposal,omitempty"`
	VerifingProposal []byte        `protobuf:"bytes,6,opt,name=verifing_proposal,json=verifingProposal,proto3" json:"verifing_proposal,omitempty"`
	RoundVoteSet     *RoundVoteSet `protobuf:"bytes,7,opt,name=round_vote_set,json=roundVoteSet,proto3" json:"round_vote_set,omitempty"`
}

GossipState represents the state of tbft instance

func (*GossipState) Descriptor 

func (*GossipState) Descriptor() ([]byte, []int)

func (*GossipState) GetHeight 

func (m *GossipState) GetHeight() uint64

func (*GossipState) GetId 

func (m *GossipState) GetId() string

func (*GossipState) GetProposal 

func (m *GossipState) GetProposal() []byte

func (*GossipState) GetRound 

func (m *GossipState) GetRound() int32

func (*GossipState) GetRoundVoteSet 

func (m *GossipState) GetRoundVoteSet() *RoundVoteSet

func (*GossipState) GetStep 

func (m *GossipState) GetStep() Step

func (*GossipState) GetVerifingProposal 

func (m *GossipState) GetVerifingProposal() []byte

func (*GossipState) Marshal 

func (m *GossipState) Marshal() (dAtA []byte, err error)

func (*GossipState) MarshalTo 

func (m *GossipState) MarshalTo(dAtA []byte) (int, error)

func (*GossipState) MarshalToSizedBuffer 

func (m *GossipState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GossipState) ProtoMessage 

func (*GossipState) ProtoMessage()

func (*GossipState) Reset 

func (m *GossipState) Reset()

func (*GossipState) Size 

func (m *GossipState) Size() (n int)

func (*GossipState) String 

func (m *GossipState) String() string

func (*GossipState) Unmarshal 

func (m *GossipState) Unmarshal(dAtA []byte) error

func (*GossipState) XXX_DiscardUnknown 

func (m *GossipState) XXX_DiscardUnknown()

func (*GossipState) XXX_Marshal 

func (m *GossipState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GossipState) XXX_Merge 

func (m *GossipState) XXX_Merge(src proto.Message)

func (*GossipState) XXX_Size 

func (m *GossipState) XXX_Size() int

func (*GossipState) XXX_Unmarshal 

func (m *GossipState) XXX_Unmarshal(b []byte) error

type HeightRoundVoteSet 

type HeightRoundVoteSet struct {
	Sequence      uint64                  `protobuf:"varint,1,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round         int32                   `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	RoundVoteSets map[int32]*RoundVoteSet `` /* 191-byte string literal not displayed */
}

HeightRoundVoteSet represents voteSet of a `height`

func (*HeightRoundVoteSet) Descriptor 

func (*HeightRoundVoteSet) Descriptor() ([]byte, []int)

func (*HeightRoundVoteSet) GetRound 

func (m *HeightRoundVoteSet) GetRound() int32

func (*HeightRoundVoteSet) GetRoundVoteSets 

func (m *HeightRoundVoteSet) GetRoundVoteSets() map[int32]*RoundVoteSet

func (*HeightRoundVoteSet) GetSequence 

func (m *HeightRoundVoteSet) GetSequence() uint64

func (*HeightRoundVoteSet) Marshal 

func (m *HeightRoundVoteSet) Marshal() (dAtA []byte, err error)

func (*HeightRoundVoteSet) MarshalTo 

func (m *HeightRoundVoteSet) MarshalTo(dAtA []byte) (int, error)

func (*HeightRoundVoteSet) MarshalToSizedBuffer 

func (m *HeightRoundVoteSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeightRoundVoteSet) ProtoMessage 

func (*HeightRoundVoteSet) ProtoMessage()

func (*HeightRoundVoteSet) Reset 

func (m *HeightRoundVoteSet) Reset()

func (*HeightRoundVoteSet) Size 

func (m *HeightRoundVoteSet) Size() (n int)

func (*HeightRoundVoteSet) String 

func (m *HeightRoundVoteSet) String() string

func (*HeightRoundVoteSet) Unmarshal 

func (m *HeightRoundVoteSet) Unmarshal(dAtA []byte) error

func (*HeightRoundVoteSet) XXX_DiscardUnknown 

func (m *HeightRoundVoteSet) XXX_DiscardUnknown()

func (*HeightRoundVoteSet) XXX_Marshal 

func (m *HeightRoundVoteSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeightRoundVoteSet) XXX_Merge 

func (m *HeightRoundVoteSet) XXX_Merge(src proto.Message)

func (*HeightRoundVoteSet) XXX_Size 

func (m *HeightRoundVoteSet) XXX_Size() int

func (*HeightRoundVoteSet) XXX_Unmarshal 

func (m *HeightRoundVoteSet) XXX_Unmarshal(b []byte) error

type NetMsg 

type NetMsg struct {
	// payload of the message
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// nodeId
	To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
}

net message

func (*NetMsg) Descriptor 

func (*NetMsg) Descriptor() ([]byte, []int)

func (*NetMsg) GetPayload 

func (m *NetMsg) GetPayload() []byte

func (*NetMsg) GetTo 

func (m *NetMsg) GetTo() string

func (*NetMsg) Marshal 

func (m *NetMsg) Marshal() (dAtA []byte, err error)

func (*NetMsg) MarshalTo 

func (m *NetMsg) MarshalTo(dAtA []byte) (int, error)

func (*NetMsg) MarshalToSizedBuffer 

func (m *NetMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NetMsg) ProtoMessage 

func (*NetMsg) ProtoMessage()

func (*NetMsg) Reset 

func (m *NetMsg) Reset()

func (*NetMsg) Size 

func (m *NetMsg) Size() (n int)

func (*NetMsg) String 

func (m *NetMsg) String() string

func (*NetMsg) Unmarshal 

func (m *NetMsg) Unmarshal(dAtA []byte) error

func (*NetMsg) XXX_DiscardUnknown 

func (m *NetMsg) XXX_DiscardUnknown()

func (*NetMsg) XXX_Marshal 

func (m *NetMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetMsg) XXX_Merge 

func (m *NetMsg) XXX_Merge(src proto.Message)

func (*NetMsg) XXX_Size 

func (m *NetMsg) XXX_Size() int

func (*NetMsg) XXX_Unmarshal 

func (m *NetMsg) XXX_Unmarshal(b []byte) error

type Proposal 

type Proposal struct {
	Voter     string `protobuf:"bytes,1,opt,name=voter,proto3" json:"voter,omitempty"`
	Sequence  uint64 `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round     int32  `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Content   []byte `protobuf:"bytes,4,opt,name=Content,proto3" json:"Content,omitempty"`
	Key       []byte `protobuf:"bytes,5,opt,name=Key,proto3" json:"Key,omitempty"`
	Signature []byte `protobuf:"bytes,6,opt,name=Signature,proto3" json:"Signature,omitempty"`
}

Proposal defined a consesensus proposal which can be gossiped to other node and can be serilized for persistent store.

func (*Proposal) Descriptor 

func (*Proposal) Descriptor() ([]byte, []int)

func (*Proposal) GetContent 

func (m *Proposal) GetContent() []byte

func (*Proposal) GetKey 

func (m *Proposal) GetKey() []byte

func (*Proposal) GetRound 

func (m *Proposal) GetRound() int32

func (*Proposal) GetSequence 

func (m *Proposal) GetSequence() uint64

func (*Proposal) GetSignature 

func (m *Proposal) GetSignature() []byte

func (*Proposal) GetVoter 

func (m *Proposal) GetVoter() string

func (*Proposal) Marshal 

func (m *Proposal) Marshal() (dAtA []byte, err error)

func (*Proposal) MarshalTo 

func (m *Proposal) MarshalTo(dAtA []byte) (int, error)

func (*Proposal) MarshalToSizedBuffer 

func (m *Proposal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Proposal) ProtoMessage 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset 

func (m *Proposal) Reset()

func (*Proposal) Size 

func (m *Proposal) Size() (n int)

func (*Proposal) String 

func (m *Proposal) String() string

func (*Proposal) Unmarshal 

func (m *Proposal) Unmarshal(dAtA []byte) error

func (*Proposal) XXX_DiscardUnknown 

func (m *Proposal) XXX_DiscardUnknown()

func (*Proposal) XXX_Marshal 

func (m *Proposal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Proposal) XXX_Merge 

func (m *Proposal) XXX_Merge(src proto.Message)

func (*Proposal) XXX_Size 

func (m *Proposal) XXX_Size() int

func (*Proposal) XXX_Unmarshal 

func (m *Proposal) XXX_Unmarshal(b []byte) error

type ProposalVoteRemix 

type ProposalVoteRemix struct {
	Proposal      *Proposal `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal,omitempty"`
	PrecommitVote *Vote     `protobuf:"bytes,2,opt,name=precommitVote,proto3" json:"precommitVote,omitempty"`
}

func (*ProposalVoteRemix) Descriptor 

func (*ProposalVoteRemix) Descriptor() ([]byte, []int)

func (*ProposalVoteRemix) GetPrecommitVote 

func (m *ProposalVoteRemix) GetPrecommitVote() *Vote

func (*ProposalVoteRemix) GetProposal 

func (m *ProposalVoteRemix) GetProposal() *Proposal

func (*ProposalVoteRemix) Marshal 

func (m *ProposalVoteRemix) Marshal() (dAtA []byte, err error)

func (*ProposalVoteRemix) MarshalTo 

func (m *ProposalVoteRemix) MarshalTo(dAtA []byte) (int, error)

func (*ProposalVoteRemix) MarshalToSizedBuffer 

func (m *ProposalVoteRemix) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProposalVoteRemix) ProtoMessage 

func (*ProposalVoteRemix) ProtoMessage()

func (*ProposalVoteRemix) Reset 

func (m *ProposalVoteRemix) Reset()

func (*ProposalVoteRemix) Size 

func (m *ProposalVoteRemix) Size() (n int)

func (*ProposalVoteRemix) String 

func (m *ProposalVoteRemix) String() string

func (*ProposalVoteRemix) Unmarshal 

func (m *ProposalVoteRemix) Unmarshal(dAtA []byte) error

func (*ProposalVoteRemix) XXX_DiscardUnknown 

func (m *ProposalVoteRemix) XXX_DiscardUnknown()

func (*ProposalVoteRemix) XXX_Marshal 

func (m *ProposalVoteRemix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProposalVoteRemix) XXX_Merge 

func (m *ProposalVoteRemix) XXX_Merge(src proto.Message)

func (*ProposalVoteRemix) XXX_Size 

func (m *ProposalVoteRemix) XXX_Size() int

func (*ProposalVoteRemix) XXX_Unmarshal 

func (m *ProposalVoteRemix) XXX_Unmarshal(b []byte) error

type RoundQC 

type RoundQC struct {
	Id         string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Sequence   uint64   `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round      int32    `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Precommits *VoteSet `protobuf:"bytes,4,opt,name=precommits,proto3" json:"precommits,omitempty"`
}

RoundQC represents the max round of qc

func (*RoundQC) Descriptor 

func (*RoundQC) Descriptor() ([]byte, []int)

func (*RoundQC) GetId 

func (m *RoundQC) GetId() string

func (*RoundQC) GetPrecommits 

func (m *RoundQC) GetPrecommits() *VoteSet

func (*RoundQC) GetRound 

func (m *RoundQC) GetRound() int32

func (*RoundQC) GetSequence 

func (m *RoundQC) GetSequence() uint64

func (*RoundQC) Marshal 

func (m *RoundQC) Marshal() (dAtA []byte, err error)

func (*RoundQC) MarshalTo 

func (m *RoundQC) MarshalTo(dAtA []byte) (int, error)

func (*RoundQC) MarshalToSizedBuffer 

func (m *RoundQC) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RoundQC) ProtoMessage 

func (*RoundQC) ProtoMessage()

func (*RoundQC) Reset 

func (m *RoundQC) Reset()

func (*RoundQC) Size 

func (m *RoundQC) Size() (n int)

func (*RoundQC) String 

func (m *RoundQC) String() string

func (*RoundQC) Unmarshal 

func (m *RoundQC) Unmarshal(dAtA []byte) error

func (*RoundQC) XXX_DiscardUnknown 

func (m *RoundQC) XXX_DiscardUnknown()

func (*RoundQC) XXX_Marshal 

func (m *RoundQC) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoundQC) XXX_Merge 

func (m *RoundQC) XXX_Merge(src proto.Message)

func (*RoundQC) XXX_Size 

func (m *RoundQC) XXX_Size() int

func (*RoundQC) XXX_Unmarshal 

func (m *RoundQC) XXX_Unmarshal(b []byte) error

type RoundVoteSet 

type RoundVoteSet struct {
	Sequence   uint64   `protobuf:"varint,1,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round      int32    `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Prevotes   *VoteSet `protobuf:"bytes,3,opt,name=prevotes,proto3" json:"prevotes,omitempty"`
	Precommits *VoteSet `protobuf:"bytes,4,opt,name=precommits,proto3" json:"precommits,omitempty"`
}

RoundVoteSet represents voteSet of a `round`

func (*RoundVoteSet) Descriptor 

func (*RoundVoteSet) Descriptor() ([]byte, []int)

func (*RoundVoteSet) GetPrecommits 

func (m *RoundVoteSet) GetPrecommits() *VoteSet

func (*RoundVoteSet) GetPrevotes 

func (m *RoundVoteSet) GetPrevotes() *VoteSet

func (*RoundVoteSet) GetRound 

func (m *RoundVoteSet) GetRound() int32

func (*RoundVoteSet) GetSequence 

func (m *RoundVoteSet) GetSequence() uint64

func (*RoundVoteSet) Marshal 

func (m *RoundVoteSet) Marshal() (dAtA []byte, err error)

func (*RoundVoteSet) MarshalTo 

func (m *RoundVoteSet) MarshalTo(dAtA []byte) (int, error)

func (*RoundVoteSet) MarshalToSizedBuffer 

func (m *RoundVoteSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RoundVoteSet) ProtoMessage 

func (*RoundVoteSet) ProtoMessage()

func (*RoundVoteSet) Reset 

func (m *RoundVoteSet) Reset()

func (*RoundVoteSet) Size 

func (m *RoundVoteSet) Size() (n int)

func (*RoundVoteSet) String 

func (m *RoundVoteSet) String() string

func (*RoundVoteSet) Unmarshal 

func (m *RoundVoteSet) Unmarshal(dAtA []byte) error

func (*RoundVoteSet) XXX_DiscardUnknown 

func (m *RoundVoteSet) XXX_DiscardUnknown()

func (*RoundVoteSet) XXX_Marshal 

func (m *RoundVoteSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RoundVoteSet) XXX_Merge 

func (m *RoundVoteSet) XXX_Merge(src proto.Message)

func (*RoundVoteSet) XXX_Size 

func (m *RoundVoteSet) XXX_Size() int

func (*RoundVoteSet) XXX_Unmarshal 

func (m *RoundVoteSet) XXX_Unmarshal(b []byte) error

type Status 

type Status struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round    int32  `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Step     Step   `protobuf:"varint,3,opt,name=step,proto3,enum=tbft_engine.Step" json:"step,omitempty"`
}

Status represents the consensus state

func (*Status) Descriptor 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) GetRound 

func (m *Status) GetRound() int32

func (*Status) GetSequence 

func (m *Status) GetSequence() uint64

func (*Status) GetStep 

func (m *Status) GetStep() Step

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer 

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

func (m *Status) Size() (n int)

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type Step 

type Step int32

Step represents the step in a round 

const (
	Step_NEW_HEIGHT     Step = 0
	Step_NEW_ROUND      Step = 1
	Step_PROPOSE        Step = 2
	Step_PREVOTE        Step = 3
	Step_PREVOTE_WAIT   Step = 4
	Step_PRECOMMIT      Step = 5
	Step_PRECOMMIT_WAIT Step = 6
	Step_COMMIT         Step = 7
)

func (Step) EnumDescriptor 

func (Step) EnumDescriptor() ([]byte, []int)

func (Step) String 

func (x Step) String() string

type TBFTMsg 

type TBFTMsg struct {
	Type TBFTMsgType `protobuf:"varint,1,opt,name=type,proto3,enum=tbft_engine.TBFTMsgType" json:"type,omitempty"`
	Msg  []byte      `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*TBFTMsg) Descriptor 

func (*TBFTMsg) Descriptor() ([]byte, []int)

func (*TBFTMsg) GetMsg 

func (m *TBFTMsg) GetMsg() []byte

func (*TBFTMsg) GetType 

func (m *TBFTMsg) GetType() TBFTMsgType

func (*TBFTMsg) Marshal 

func (m *TBFTMsg) Marshal() (dAtA []byte, err error)

func (*TBFTMsg) MarshalTo 

func (m *TBFTMsg) MarshalTo(dAtA []byte) (int, error)

func (*TBFTMsg) MarshalToSizedBuffer 

func (m *TBFTMsg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TBFTMsg) ProtoMessage 

func (*TBFTMsg) ProtoMessage()

func (*TBFTMsg) Reset 

func (m *TBFTMsg) Reset()

func (*TBFTMsg) Size 

func (m *TBFTMsg) Size() (n int)

func (*TBFTMsg) String 

func (m *TBFTMsg) String() string

func (*TBFTMsg) Unmarshal 

func (m *TBFTMsg) Unmarshal(dAtA []byte) error

func (*TBFTMsg) XXX_DiscardUnknown 

func (m *TBFTMsg) XXX_DiscardUnknown()

func (*TBFTMsg) XXX_Marshal 

func (m *TBFTMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TBFTMsg) XXX_Merge 

func (m *TBFTMsg) XXX_Merge(src proto.Message)

func (*TBFTMsg) XXX_Size 

func (m *TBFTMsg) XXX_Size() int

func (*TBFTMsg) XXX_Unmarshal 

func (m *TBFTMsg) XXX_Unmarshal(b []byte) error

type TBFTMsgType 

type TBFTMsgType int32

TBFTMsgType defines different type message in tbft 

const (
	TBFTMsgType_MSG_PROPOSE       TBFTMsgType = 0
	TBFTMsgType_MSG_PREVOTE       TBFTMsgType = 1
	TBFTMsgType_MSG_PRECOMMIT     TBFTMsgType = 2
	TBFTMsgType_MSG_STATE         TBFTMsgType = 3
	TBFTMsgType_MSG_FETCH_ROUNDQC TBFTMsgType = 4
	TBFTMsgType_MSG_SEND_ROUND_QC TBFTMsgType = 5
)

func (TBFTMsgType) EnumDescriptor 

func (TBFTMsgType) EnumDescriptor() ([]byte, []int)

func (TBFTMsgType) String 

func (x TBFTMsgType) String() string

type TimeoutInfo 

type TimeoutInfo struct {
	Duration int64  `protobuf:"varint,1,opt,name=duration,proto3" json:"duration,omitempty"`
	Sequence uint64 `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round    int32  `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Step     Step   `protobuf:"varint,4,opt,name=step,proto3,enum=tbft_engine.Step" json:"step,omitempty"`
}

TimeoutInfo represents the timeout event

func (*TimeoutInfo) Descriptor 

func (*TimeoutInfo) Descriptor() ([]byte, []int)

func (*TimeoutInfo) GetDuration 

func (m *TimeoutInfo) GetDuration() int64

func (*TimeoutInfo) GetRound 

func (m *TimeoutInfo) GetRound() int32

func (*TimeoutInfo) GetSequence 

func (m *TimeoutInfo) GetSequence() uint64

func (*TimeoutInfo) GetStep 

func (m *TimeoutInfo) GetStep() Step

func (*TimeoutInfo) Marshal 

func (m *TimeoutInfo) Marshal() (dAtA []byte, err error)

func (*TimeoutInfo) MarshalTo 

func (m *TimeoutInfo) MarshalTo(dAtA []byte) (int, error)

func (*TimeoutInfo) MarshalToSizedBuffer 

func (m *TimeoutInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeoutInfo) ProtoMessage 

func (*TimeoutInfo) ProtoMessage()

func (*TimeoutInfo) Reset 

func (m *TimeoutInfo) Reset()

func (*TimeoutInfo) Size 

func (m *TimeoutInfo) Size() (n int)

func (*TimeoutInfo) String 

func (m *TimeoutInfo) String() string

func (*TimeoutInfo) Unmarshal 

func (m *TimeoutInfo) Unmarshal(dAtA []byte) error

func (*TimeoutInfo) XXX_DiscardUnknown 

func (m *TimeoutInfo) XXX_DiscardUnknown()

func (*TimeoutInfo) XXX_Marshal 

func (m *TimeoutInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeoutInfo) XXX_Merge 

func (m *TimeoutInfo) XXX_Merge(src proto.Message)

func (*TimeoutInfo) XXX_Size 

func (m *TimeoutInfo) XXX_Size() int

func (*TimeoutInfo) XXX_Unmarshal 

func (m *TimeoutInfo) XXX_Unmarshal(b []byte) error

type VerifyResult 

type VerifyResult struct {
	VerifiedBatchMsg []byte            `protobuf:"bytes,1,opt,name=VerifiedBatchMsg,proto3" json:"VerifiedBatchMsg,omitempty"`
	Code             VerifyResult_Code `protobuf:"varint,2,opt,name=Code,proto3,enum=tbft_engine.VerifyResult_Code" json:"Code,omitempty"`
	Msg              string            `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"`
}

VerifyResult represents the verify result

func (*VerifyResult) Descriptor 

func (*VerifyResult) Descriptor() ([]byte, []int)

func (*VerifyResult) GetCode 

func (m *VerifyResult) GetCode() VerifyResult_Code

func (*VerifyResult) GetMsg 

func (m *VerifyResult) GetMsg() string

func (*VerifyResult) GetVerifiedBatchMsg 

func (m *VerifyResult) GetVerifiedBatchMsg() []byte

func (*VerifyResult) Marshal 

func (m *VerifyResult) Marshal() (dAtA []byte, err error)

func (*VerifyResult) MarshalTo 

func (m *VerifyResult) MarshalTo(dAtA []byte) (int, error)

func (*VerifyResult) MarshalToSizedBuffer 

func (m *VerifyResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyResult) ProtoMessage 

func (*VerifyResult) ProtoMessage()

func (*VerifyResult) Reset 

func (m *VerifyResult) Reset()

func (*VerifyResult) Size 

func (m *VerifyResult) Size() (n int)

func (*VerifyResult) String 

func (m *VerifyResult) String() string

func (*VerifyResult) Unmarshal 

func (m *VerifyResult) Unmarshal(dAtA []byte) error

func (*VerifyResult) XXX_DiscardUnknown 

func (m *VerifyResult) XXX_DiscardUnknown()

func (*VerifyResult) XXX_Marshal 

func (m *VerifyResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyResult) XXX_Merge 

func (m *VerifyResult) XXX_Merge(src proto.Message)

func (*VerifyResult) XXX_Size 

func (m *VerifyResult) XXX_Size() int

func (*VerifyResult) XXX_Unmarshal 

func (m *VerifyResult) XXX_Unmarshal(b []byte) error

type VerifyResult_Code 

type VerifyResult_Code int32

VerifyResult_Code represents the Result_Code of verifying proposal 

const (
	VerifyResult_Code_VerifyResult_SUCCESS VerifyResult_Code = 0
	VerifyResult_Code_VerifyResult_FAIL    VerifyResult_Code = 1
)

func (VerifyResult_Code) EnumDescriptor 

func (VerifyResult_Code) EnumDescriptor() ([]byte, []int)

func (VerifyResult_Code) String 

func (x VerifyResult_Code) String() string

type Vote 

type Vote struct {
	Type       VoteType `protobuf:"varint,1,opt,name=type,proto3,enum=tbft_engine.VoteType" json:"type,omitempty"`
	Voter      string   `protobuf:"bytes,2,opt,name=voter,proto3" json:"voter,omitempty"`
	Sequence   uint64   `protobuf:"varint,3,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round      int32    `protobuf:"varint,4,opt,name=round,proto3" json:"round,omitempty"`
	Hash       []byte   `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	Signature  []byte   `protobuf:"bytes,6,opt,name=Signature,proto3" json:"Signature,omitempty"`
	InvalidTxs []string `protobuf:"bytes,7,rep,name=invalidTxs,proto3" json:"invalidTxs,omitempty"`
}

Vote represents a tbft vote

func (*Vote) Descriptor 

func (*Vote) Descriptor() ([]byte, []int)

func (*Vote) GetHash 

func (m *Vote) GetHash() []byte

func (*Vote) GetInvalidTxs 

func (m *Vote) GetInvalidTxs() []string

func (*Vote) GetRound 

func (m *Vote) GetRound() int32

func (*Vote) GetSequence 

func (m *Vote) GetSequence() uint64

func (*Vote) GetSignature 

func (m *Vote) GetSignature() []byte

func (*Vote) GetType 

func (m *Vote) GetType() VoteType

func (*Vote) GetVoter 

func (m *Vote) GetVoter() string

func (*Vote) Marshal 

func (m *Vote) Marshal() (dAtA []byte, err error)

func (*Vote) MarshalTo 

func (m *Vote) MarshalTo(dAtA []byte) (int, error)

func (*Vote) MarshalToSizedBuffer 

func (m *Vote) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Vote) ProtoMessage 

func (*Vote) ProtoMessage()

func (*Vote) Reset 

func (m *Vote) Reset()

func (*Vote) Size 

func (m *Vote) Size() (n int)

func (*Vote) String 

func (m *Vote) String() string

func (*Vote) Unmarshal 

func (m *Vote) Unmarshal(dAtA []byte) error

func (*Vote) XXX_DiscardUnknown 

func (m *Vote) XXX_DiscardUnknown()

func (*Vote) XXX_Marshal 

func (m *Vote) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Vote) XXX_Merge 

func (m *Vote) XXX_Merge(src proto.Message)

func (*Vote) XXX_Size 

func (m *Vote) XXX_Size() int

func (*Vote) XXX_Unmarshal 

func (m *Vote) XXX_Unmarshal(b []byte) error

type VoteSet 

type VoteSet struct {
	Type         VoteType               `protobuf:"varint,1,opt,name=type,proto3,enum=tbft_engine.VoteType" json:"type,omitempty"`
	Sequence     uint64                 `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	Round        int32                  `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Sum          uint64                 `protobuf:"varint,4,opt,name=sum,proto3" json:"sum,omitempty"`
	Maj23        []byte                 `protobuf:"bytes,5,opt,name=maj23,proto3" json:"maj23,omitempty"`
	Votes        map[string]*Vote       `` /* 151-byte string literal not displayed */
	VotesByBlock map[string]*BlockVotes `` /* 187-byte string literal not displayed */
}

VoteSet represents a set of vote at `height` and `round`

func (*VoteSet) Descriptor 

func (*VoteSet) Descriptor() ([]byte, []int)

func (*VoteSet) GetMaj23 

func (m *VoteSet) GetMaj23() []byte

func (*VoteSet) GetRound 

func (m *VoteSet) GetRound() int32

func (*VoteSet) GetSequence 

func (m *VoteSet) GetSequence() uint64

func (*VoteSet) GetSum 

func (m *VoteSet) GetSum() uint64

func (*VoteSet) GetType 

func (m *VoteSet) GetType() VoteType

func (*VoteSet) GetVotes 

func (m *VoteSet) GetVotes() map[string]*Vote

func (*VoteSet) GetVotesByBlock 

func (m *VoteSet) GetVotesByBlock() map[string]*BlockVotes

func (*VoteSet) Marshal 

func (m *VoteSet) Marshal() (dAtA []byte, err error)

func (*VoteSet) MarshalTo 

func (m *VoteSet) MarshalTo(dAtA []byte) (int, error)

func (*VoteSet) MarshalToSizedBuffer 

func (m *VoteSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VoteSet) ProtoMessage 

func (*VoteSet) ProtoMessage()

func (*VoteSet) Reset 

func (m *VoteSet) Reset()

func (*VoteSet) Size 

func (m *VoteSet) Size() (n int)

func (*VoteSet) String 

func (m *VoteSet) String() string

func (*VoteSet) Unmarshal 

func (m *VoteSet) Unmarshal(dAtA []byte) error

func (*VoteSet) XXX_DiscardUnknown 

func (m *VoteSet) XXX_DiscardUnknown()

func (*VoteSet) XXX_Marshal 

func (m *VoteSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VoteSet) XXX_Merge 

func (m *VoteSet) XXX_Merge(src proto.Message)

func (*VoteSet) XXX_Size 

func (m *VoteSet) XXX_Size() int

func (*VoteSet) XXX_Unmarshal 

func (m *VoteSet) XXX_Unmarshal(b []byte) error

type VoteType 

type VoteType int32

VoteType represents the type of vote 

const (
	VoteType_VOTE_PREVOTE   VoteType = 0
	VoteType_VOTE_PRECOMMIT VoteType = 1
)

func (VoteType) EnumDescriptor 

func (VoteType) EnumDescriptor() ([]byte, []int)

func (VoteType) String 

func (x VoteType) String() string

type WalEntry 

type WalEntry struct {
	Sequence uint64 `protobuf:"varint,1,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	// log entry type
	Type WalEntryType `protobuf:"varint,2,opt,name=type,proto3,enum=tbft_engine.WalEntryType" json:"type,omitempty"`
	// data of entry
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

WalEntry represents the log entry in Wal

func (*WalEntry) Descriptor 

func (*WalEntry) Descriptor() ([]byte, []int)

func (*WalEntry) GetData 

func (m *WalEntry) GetData() []byte

func (*WalEntry) GetSequence 

func (m *WalEntry) GetSequence() uint64

func (*WalEntry) GetType 

func (m *WalEntry) GetType() WalEntryType

func (*WalEntry) Marshal 

func (m *WalEntry) Marshal() (dAtA []byte, err error)

func (*WalEntry) MarshalTo 

func (m *WalEntry) MarshalTo(dAtA []byte) (int, error)

func (*WalEntry) MarshalToSizedBuffer 

func (m *WalEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WalEntry) ProtoMessage 

func (*WalEntry) ProtoMessage()

func (*WalEntry) Reset 

func (m *WalEntry) Reset()

func (*WalEntry) Size 

func (m *WalEntry) Size() (n int)

func (*WalEntry) String 

func (m *WalEntry) String() string

func (*WalEntry) Unmarshal 

func (m *WalEntry) Unmarshal(dAtA []byte) error

func (*WalEntry) XXX_DiscardUnknown 

func (m *WalEntry) XXX_DiscardUnknown()

func (*WalEntry) XXX_Marshal 

func (m *WalEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WalEntry) XXX_Merge 

func (m *WalEntry) XXX_Merge(src proto.Message)

func (*WalEntry) XXX_Size 

func (m *WalEntry) XXX_Size() int

func (*WalEntry) XXX_Unmarshal 

func (m *WalEntry) XXX_Unmarshal(b []byte) error

type WalEntryType 

type WalEntryType int32

WalEntryType represents different types of entries in Wal 

const (
	WalEntryType_TIMEOUT_ENTRY       WalEntryType = 0
	WalEntryType_PROPOSAL_ENTRY      WalEntryType = 1
	WalEntryType_VOTE_ENTRY          WalEntryType = 2
	WalEntryType_PROPOSAL_VOTE_ENTRY WalEntryType = 3
)

func (WalEntryType) EnumDescriptor 

func (WalEntryType) EnumDescriptor() ([]byte, []int)

func (WalEntryType) String 

func (x WalEntryType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.