consensus

package
v0.34.24 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWal = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type BlockPart 

type BlockPart struct {
	Height int64      `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round  int32      `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Part   types.Part `protobuf:"bytes,3,opt,name=part,proto3" json:"part"`
}

BlockPart is sent when gossipping a piece of the proposed block.

func (*BlockPart) Descriptor 

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

func (*BlockPart) GetHeight 

func (m *BlockPart) GetHeight() int64

func (*BlockPart) GetPart 

func (m *BlockPart) GetPart() types.Part

func (*BlockPart) GetRound 

func (m *BlockPart) GetRound() int32

func (*BlockPart) Marshal 

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

func (*BlockPart) MarshalTo 

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

func (*BlockPart) MarshalToSizedBuffer 

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

func (*BlockPart) ProtoMessage 

func (*BlockPart) ProtoMessage()

func (*BlockPart) Reset 

func (m *BlockPart) Reset()

func (*BlockPart) Size 

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

func (*BlockPart) String 

func (m *BlockPart) String() string

func (*BlockPart) Unmarshal 

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

func (*BlockPart) Wrap 

func (m *BlockPart) Wrap() proto.Message

func (*BlockPart) XXX_DiscardUnknown 

func (m *BlockPart) XXX_DiscardUnknown()

func (*BlockPart) XXX_Marshal 

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

func (*BlockPart) XXX_Merge 

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

func (*BlockPart) XXX_Size 

func (m *BlockPart) XXX_Size() int

func (*BlockPart) XXX_Unmarshal 

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

type EndHeight 

type EndHeight struct {
	Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

EndHeight marks the end of the given height inside WAL. @internal used by scripts/wal2json util.

func (*EndHeight) Descriptor 

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

func (*EndHeight) GetHeight 

func (m *EndHeight) GetHeight() int64

func (*EndHeight) Marshal 

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

func (*EndHeight) MarshalTo 

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

func (*EndHeight) MarshalToSizedBuffer 

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

func (*EndHeight) ProtoMessage 

func (*EndHeight) ProtoMessage()

func (*EndHeight) Reset 

func (m *EndHeight) Reset()

func (*EndHeight) Size 

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

func (*EndHeight) String 

func (m *EndHeight) String() string

func (*EndHeight) Unmarshal 

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

func (*EndHeight) XXX_DiscardUnknown 

func (m *EndHeight) XXX_DiscardUnknown()

func (*EndHeight) XXX_Marshal 

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

func (*EndHeight) XXX_Merge 

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

func (*EndHeight) XXX_Size 

func (m *EndHeight) XXX_Size() int

func (*EndHeight) XXX_Unmarshal 

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

type HasVote 

type HasVote struct {
	Height int64               `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round  int32               `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Type   types.SignedMsgType `protobuf:"varint,3,opt,name=type,proto3,enum=tendermint.types.SignedMsgType" json:"type,omitempty"`
	Index  int32               `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
}

HasVote is sent to indicate that a particular vote has been received.

func (*HasVote) Descriptor 

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

func (*HasVote) GetHeight 

func (m *HasVote) GetHeight() int64

func (*HasVote) GetIndex 

func (m *HasVote) GetIndex() int32

func (*HasVote) GetRound 

func (m *HasVote) GetRound() int32

func (*HasVote) GetType 

func (m *HasVote) GetType() types.SignedMsgType

func (*HasVote) Marshal 

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

func (*HasVote) MarshalTo 

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

func (*HasVote) MarshalToSizedBuffer 

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

func (*HasVote) ProtoMessage 

func (*HasVote) ProtoMessage()

func (*HasVote) Reset 

func (m *HasVote) Reset()

func (*HasVote) Size 

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

func (*HasVote) String 

func (m *HasVote) String() string

func (*HasVote) Unmarshal 

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

func (*HasVote) Wrap 

func (m *HasVote) Wrap() proto.Message

func (*HasVote) XXX_DiscardUnknown 

func (m *HasVote) XXX_DiscardUnknown()

func (*HasVote) XXX_Marshal 

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

func (*HasVote) XXX_Merge 

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

func (*HasVote) XXX_Size 

func (m *HasVote) XXX_Size() int

func (*HasVote) XXX_Unmarshal 

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

type Message 

type Message struct {
	// Types that are valid to be assigned to Sum:
	//	*Message_NewRoundStep
	//	*Message_NewValidBlock
	//	*Message_Proposal
	//	*Message_ProposalPol
	//	*Message_BlockPart
	//	*Message_Vote
	//	*Message_HasVote
	//	*Message_VoteSetMaj23
	//	*Message_VoteSetBits
	Sum isMessage_Sum `protobuf_oneof:"sum"`
}

func (*Message) Descriptor 

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

func (*Message) GetBlockPart 

func (m *Message) GetBlockPart() *BlockPart

func (*Message) GetHasVote 

func (m *Message) GetHasVote() *HasVote

func (*Message) GetNewRoundStep 

func (m *Message) GetNewRoundStep() *NewRoundStep

func (*Message) GetNewValidBlock 

func (m *Message) GetNewValidBlock() *NewValidBlock

func (*Message) GetProposal 

func (m *Message) GetProposal() *Proposal

func (*Message) GetProposalPol 

func (m *Message) GetProposalPol() *ProposalPOL

func (*Message) GetSum 

func (m *Message) GetSum() isMessage_Sum

func (*Message) GetVote 

func (m *Message) GetVote() *Vote

func (*Message) GetVoteSetBits 

func (m *Message) GetVoteSetBits() *VoteSetBits

func (*Message) GetVoteSetMaj23 

func (m *Message) GetVoteSetMaj23() *VoteSetMaj23

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) Unwrap 

func (m *Message) Unwrap() (proto.Message, error)

Unwrap implements the p2p Wrapper interface and unwraps a wrapped consensus proto message.

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_OneofWrappers 

func (*Message) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_BlockPart 

type Message_BlockPart struct {
	BlockPart *BlockPart `protobuf:"bytes,5,opt,name=block_part,json=blockPart,proto3,oneof" json:"block_part,omitempty"`
}

func (*Message_BlockPart) MarshalTo 

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

func (*Message_BlockPart) MarshalToSizedBuffer 

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

func (*Message_BlockPart) Size 

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

type Message_HasVote 

type Message_HasVote struct {
	HasVote *HasVote `protobuf:"bytes,7,opt,name=has_vote,json=hasVote,proto3,oneof" json:"has_vote,omitempty"`
}

func (*Message_HasVote) MarshalTo 

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

func (*Message_HasVote) MarshalToSizedBuffer 

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

func (*Message_HasVote) Size 

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

type Message_NewRoundStep 

type Message_NewRoundStep struct {
	NewRoundStep *NewRoundStep `protobuf:"bytes,1,opt,name=new_round_step,json=newRoundStep,proto3,oneof" json:"new_round_step,omitempty"`
}

func (*Message_NewRoundStep) MarshalTo 

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

func (*Message_NewRoundStep) MarshalToSizedBuffer 

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

func (*Message_NewRoundStep) Size 

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

type Message_NewValidBlock 

type Message_NewValidBlock struct {
	NewValidBlock *NewValidBlock `protobuf:"bytes,2,opt,name=new_valid_block,json=newValidBlock,proto3,oneof" json:"new_valid_block,omitempty"`
}

func (*Message_NewValidBlock) MarshalTo 

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

func (*Message_NewValidBlock) MarshalToSizedBuffer 

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

func (*Message_NewValidBlock) Size 

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

type Message_Proposal 

type Message_Proposal struct {
	Proposal *Proposal `protobuf:"bytes,3,opt,name=proposal,proto3,oneof" json:"proposal,omitempty"`
}

func (*Message_Proposal) MarshalTo 

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

func (*Message_Proposal) MarshalToSizedBuffer 

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

func (*Message_Proposal) Size 

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

type Message_ProposalPol 

type Message_ProposalPol struct {
	ProposalPol *ProposalPOL `protobuf:"bytes,4,opt,name=proposal_pol,json=proposalPol,proto3,oneof" json:"proposal_pol,omitempty"`
}

func (*Message_ProposalPol) MarshalTo 

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

func (*Message_ProposalPol) MarshalToSizedBuffer 

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

func (*Message_ProposalPol) Size 

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

type Message_Vote 

type Message_Vote struct {
	Vote *Vote `protobuf:"bytes,6,opt,name=vote,proto3,oneof" json:"vote,omitempty"`
}

func (*Message_Vote) MarshalTo 

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

func (*Message_Vote) MarshalToSizedBuffer 

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

func (*Message_Vote) Size 

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

type Message_VoteSetBits 

type Message_VoteSetBits struct {
	VoteSetBits *VoteSetBits `protobuf:"bytes,9,opt,name=vote_set_bits,json=voteSetBits,proto3,oneof" json:"vote_set_bits,omitempty"`
}

func (*Message_VoteSetBits) MarshalTo 

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

func (*Message_VoteSetBits) MarshalToSizedBuffer 

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

func (*Message_VoteSetBits) Size 

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

type Message_VoteSetMaj23 

type Message_VoteSetMaj23 struct {
	VoteSetMaj23 *VoteSetMaj23 `protobuf:"bytes,8,opt,name=vote_set_maj23,json=voteSetMaj23,proto3,oneof" json:"vote_set_maj23,omitempty"`
}

func (*Message_VoteSetMaj23) MarshalTo 

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

func (*Message_VoteSetMaj23) MarshalToSizedBuffer 

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

func (*Message_VoteSetMaj23) Size 

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

type MsgInfo 

type MsgInfo struct {
	Msg    Message `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg"`
	PeerID string  `protobuf:"bytes,2,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
}

MsgInfo are msgs from the reactor which may update the state

func (*MsgInfo) Descriptor 

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

func (*MsgInfo) GetMsg 

func (m *MsgInfo) GetMsg() Message

func (*MsgInfo) GetPeerID 

func (m *MsgInfo) GetPeerID() string

func (*MsgInfo) Marshal 

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

func (*MsgInfo) MarshalTo 

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

func (*MsgInfo) MarshalToSizedBuffer 

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

func (*MsgInfo) ProtoMessage 

func (*MsgInfo) ProtoMessage()

func (*MsgInfo) Reset 

func (m *MsgInfo) Reset()

func (*MsgInfo) Size 

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

func (*MsgInfo) String 

func (m *MsgInfo) String() string

func (*MsgInfo) Unmarshal 

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

func (*MsgInfo) XXX_DiscardUnknown 

func (m *MsgInfo) XXX_DiscardUnknown()

func (*MsgInfo) XXX_Marshal 

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

func (*MsgInfo) XXX_Merge 

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

func (*MsgInfo) XXX_Size 

func (m *MsgInfo) XXX_Size() int

func (*MsgInfo) XXX_Unmarshal 

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

type NewRoundStep 

type NewRoundStep struct {
	Height                int64  `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round                 int32  `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Step                  uint32 `protobuf:"varint,3,opt,name=step,proto3" json:"step,omitempty"`
	SecondsSinceStartTime int64  `` /* 129-byte string literal not displayed */
	LastCommitRound       int32  `protobuf:"varint,5,opt,name=last_commit_round,json=lastCommitRound,proto3" json:"last_commit_round,omitempty"`
}

NewRoundStep is sent for every step taken in the ConsensusState. For every height/round/step transition

func (*NewRoundStep) Descriptor 

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

func (*NewRoundStep) GetHeight 

func (m *NewRoundStep) GetHeight() int64

func (*NewRoundStep) GetLastCommitRound 

func (m *NewRoundStep) GetLastCommitRound() int32

func (*NewRoundStep) GetRound 

func (m *NewRoundStep) GetRound() int32

func (*NewRoundStep) GetSecondsSinceStartTime 

func (m *NewRoundStep) GetSecondsSinceStartTime() int64

func (*NewRoundStep) GetStep 

func (m *NewRoundStep) GetStep() uint32

func (*NewRoundStep) Marshal 

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

func (*NewRoundStep) MarshalTo 

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

func (*NewRoundStep) MarshalToSizedBuffer 

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

func (*NewRoundStep) ProtoMessage 

func (*NewRoundStep) ProtoMessage()

func (*NewRoundStep) Reset 

func (m *NewRoundStep) Reset()

func (*NewRoundStep) Size 

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

func (*NewRoundStep) String 

func (m *NewRoundStep) String() string

func (*NewRoundStep) Unmarshal 

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

func (*NewRoundStep) Wrap 

func (m *NewRoundStep) Wrap() proto.Message

func (*NewRoundStep) XXX_DiscardUnknown 

func (m *NewRoundStep) XXX_DiscardUnknown()

func (*NewRoundStep) XXX_Marshal 

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

func (*NewRoundStep) XXX_Merge 

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

func (*NewRoundStep) XXX_Size 

func (m *NewRoundStep) XXX_Size() int

func (*NewRoundStep) XXX_Unmarshal 

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

type NewValidBlock 

type NewValidBlock struct {
	Height             int64               `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round              int32               `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	BlockPartSetHeader types.PartSetHeader `protobuf:"bytes,3,opt,name=block_part_set_header,json=blockPartSetHeader,proto3" json:"block_part_set_header"`
	BlockParts         *bits.BitArray      `protobuf:"bytes,4,opt,name=block_parts,json=blockParts,proto3" json:"block_parts,omitempty"`
	IsCommit           bool                `protobuf:"varint,5,opt,name=is_commit,json=isCommit,proto3" json:"is_commit,omitempty"`
}

NewValidBlock is sent when a validator observes a valid block B in some round r, i.e., there is a Proposal for block B and 2/3+ prevotes for the block B in the round r. In case the block is also committed, then IsCommit flag is set to true.

func (*NewValidBlock) Descriptor 

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

func (*NewValidBlock) GetBlockPartSetHeader 

func (m *NewValidBlock) GetBlockPartSetHeader() types.PartSetHeader

func (*NewValidBlock) GetBlockParts 

func (m *NewValidBlock) GetBlockParts() *bits.BitArray

func (*NewValidBlock) GetHeight 

func (m *NewValidBlock) GetHeight() int64

func (*NewValidBlock) GetIsCommit 

func (m *NewValidBlock) GetIsCommit() bool

func (*NewValidBlock) GetRound 

func (m *NewValidBlock) GetRound() int32

func (*NewValidBlock) Marshal 

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

func (*NewValidBlock) MarshalTo 

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

func (*NewValidBlock) MarshalToSizedBuffer 

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

func (*NewValidBlock) ProtoMessage 

func (*NewValidBlock) ProtoMessage()

func (*NewValidBlock) Reset 

func (m *NewValidBlock) Reset()

func (*NewValidBlock) Size 

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

func (*NewValidBlock) String 

func (m *NewValidBlock) String() string

func (*NewValidBlock) Unmarshal 

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

func (*NewValidBlock) Wrap 

func (m *NewValidBlock) Wrap() proto.Message

func (*NewValidBlock) XXX_DiscardUnknown 

func (m *NewValidBlock) XXX_DiscardUnknown()

func (*NewValidBlock) XXX_Marshal 

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

func (*NewValidBlock) XXX_Merge 

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

func (*NewValidBlock) XXX_Size 

func (m *NewValidBlock) XXX_Size() int

func (*NewValidBlock) XXX_Unmarshal 

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

type Proposal 

type Proposal struct {
	Proposal types.Proposal `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal"`
}

Proposal is sent when a new block is proposed.

func (*Proposal) Descriptor 

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

func (*Proposal) GetProposal 

func (m *Proposal) GetProposal() types.Proposal

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) Wrap 

func (m *Proposal) Wrap() proto.Message

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 ProposalPOL 

type ProposalPOL struct {
	Height           int64         `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	ProposalPolRound int32         `protobuf:"varint,2,opt,name=proposal_pol_round,json=proposalPolRound,proto3" json:"proposal_pol_round,omitempty"`
	ProposalPol      bits.BitArray `protobuf:"bytes,3,opt,name=proposal_pol,json=proposalPol,proto3" json:"proposal_pol"`
}

ProposalPOL is sent when a previous proposal is re-proposed.

func (*ProposalPOL) Descriptor 

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

func (*ProposalPOL) GetHeight 

func (m *ProposalPOL) GetHeight() int64

func (*ProposalPOL) GetProposalPol 

func (m *ProposalPOL) GetProposalPol() bits.BitArray

func (*ProposalPOL) GetProposalPolRound 

func (m *ProposalPOL) GetProposalPolRound() int32

func (*ProposalPOL) Marshal 

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

func (*ProposalPOL) MarshalTo 

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

func (*ProposalPOL) MarshalToSizedBuffer 

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

func (*ProposalPOL) ProtoMessage 

func (*ProposalPOL) ProtoMessage()

func (*ProposalPOL) Reset 

func (m *ProposalPOL) Reset()

func (*ProposalPOL) Size 

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

func (*ProposalPOL) String 

func (m *ProposalPOL) String() string

func (*ProposalPOL) Unmarshal 

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

func (*ProposalPOL) Wrap 

func (m *ProposalPOL) Wrap() proto.Message

func (*ProposalPOL) XXX_DiscardUnknown 

func (m *ProposalPOL) XXX_DiscardUnknown()

func (*ProposalPOL) XXX_Marshal 

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

func (*ProposalPOL) XXX_Merge 

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

func (*ProposalPOL) XXX_Size 

func (m *ProposalPOL) XXX_Size() int

func (*ProposalPOL) XXX_Unmarshal 

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

type TimedWALMessage 

type TimedWALMessage struct {
	Time time.Time   `protobuf:"bytes,1,opt,name=time,proto3,stdtime" json:"time"`
	Msg  *WALMessage `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

TimedWALMessage wraps WALMessage and adds Time for debugging purposes.

func (*TimedWALMessage) Descriptor 

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

func (*TimedWALMessage) GetMsg 

func (m *TimedWALMessage) GetMsg() *WALMessage

func (*TimedWALMessage) GetTime 

func (m *TimedWALMessage) GetTime() time.Time

func (*TimedWALMessage) Marshal 

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

func (*TimedWALMessage) MarshalTo 

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

func (*TimedWALMessage) MarshalToSizedBuffer 

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

func (*TimedWALMessage) ProtoMessage 

func (*TimedWALMessage) ProtoMessage()

func (*TimedWALMessage) Reset 

func (m *TimedWALMessage) Reset()

func (*TimedWALMessage) Size 

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

func (*TimedWALMessage) String 

func (m *TimedWALMessage) String() string

func (*TimedWALMessage) Unmarshal 

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

func (*TimedWALMessage) XXX_DiscardUnknown 

func (m *TimedWALMessage) XXX_DiscardUnknown()

func (*TimedWALMessage) XXX_Marshal 

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

func (*TimedWALMessage) XXX_Merge 

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

func (*TimedWALMessage) XXX_Size 

func (m *TimedWALMessage) XXX_Size() int

func (*TimedWALMessage) XXX_Unmarshal 

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

type TimeoutInfo 

type TimeoutInfo struct {
	Duration time.Duration `protobuf:"bytes,1,opt,name=duration,proto3,stdduration" json:"duration"`
	Height   int64         `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Round    int32         `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	Step     uint32        `protobuf:"varint,4,opt,name=step,proto3" json:"step,omitempty"`
}

TimeoutInfo internally generated messages which may update the state

func (*TimeoutInfo) Descriptor 

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

func (*TimeoutInfo) GetDuration 

func (m *TimeoutInfo) GetDuration() time.Duration

func (*TimeoutInfo) GetHeight 

func (m *TimeoutInfo) GetHeight() int64

func (*TimeoutInfo) GetRound 

func (m *TimeoutInfo) GetRound() int32

func (*TimeoutInfo) GetStep 

func (m *TimeoutInfo) GetStep() uint32

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 Vote 

type Vote struct {
	Vote *types.Vote `protobuf:"bytes,1,opt,name=vote,proto3" json:"vote,omitempty"`
}

Vote is sent when voting for a proposal (or lack thereof).

func (*Vote) Descriptor 

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

func (*Vote) GetVote 

func (m *Vote) GetVote() *types.Vote

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) Wrap 

func (m *Vote) Wrap() proto.Message

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 VoteSetBits 

type VoteSetBits struct {
	Height  int64               `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round   int32               `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Type    types.SignedMsgType `protobuf:"varint,3,opt,name=type,proto3,enum=tendermint.types.SignedMsgType" json:"type,omitempty"`
	BlockID types.BlockID       `protobuf:"bytes,4,opt,name=block_id,json=blockId,proto3" json:"block_id"`
	Votes   bits.BitArray       `protobuf:"bytes,5,opt,name=votes,proto3" json:"votes"`
}

VoteSetBits is sent to communicate the bit-array of votes seen for the BlockID.

func (*VoteSetBits) Descriptor 

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

func (*VoteSetBits) GetBlockID 

func (m *VoteSetBits) GetBlockID() types.BlockID

func (*VoteSetBits) GetHeight 

func (m *VoteSetBits) GetHeight() int64

func (*VoteSetBits) GetRound 

func (m *VoteSetBits) GetRound() int32

func (*VoteSetBits) GetType 

func (m *VoteSetBits) GetType() types.SignedMsgType

func (*VoteSetBits) GetVotes 

func (m *VoteSetBits) GetVotes() bits.BitArray

func (*VoteSetBits) Marshal 

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

func (*VoteSetBits) MarshalTo 

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

func (*VoteSetBits) MarshalToSizedBuffer 

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

func (*VoteSetBits) ProtoMessage 

func (*VoteSetBits) ProtoMessage()

func (*VoteSetBits) Reset 

func (m *VoteSetBits) Reset()

func (*VoteSetBits) Size 

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

func (*VoteSetBits) String 

func (m *VoteSetBits) String() string

func (*VoteSetBits) Unmarshal 

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

func (*VoteSetBits) Wrap 

func (m *VoteSetBits) Wrap() proto.Message

func (*VoteSetBits) XXX_DiscardUnknown 

func (m *VoteSetBits) XXX_DiscardUnknown()

func (*VoteSetBits) XXX_Marshal 

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

func (*VoteSetBits) XXX_Merge 

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

func (*VoteSetBits) XXX_Size 

func (m *VoteSetBits) XXX_Size() int

func (*VoteSetBits) XXX_Unmarshal 

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

type VoteSetMaj23 

type VoteSetMaj23 struct {
	Height  int64               `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Round   int32               `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"`
	Type    types.SignedMsgType `protobuf:"varint,3,opt,name=type,proto3,enum=tendermint.types.SignedMsgType" json:"type,omitempty"`
	BlockID types.BlockID       `protobuf:"bytes,4,opt,name=block_id,json=blockId,proto3" json:"block_id"`
}

VoteSetMaj23 is sent to indicate that a given BlockID has seen +2/3 votes.

func (*VoteSetMaj23) Descriptor 

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

func (*VoteSetMaj23) GetBlockID 

func (m *VoteSetMaj23) GetBlockID() types.BlockID

func (*VoteSetMaj23) GetHeight 

func (m *VoteSetMaj23) GetHeight() int64

func (*VoteSetMaj23) GetRound 

func (m *VoteSetMaj23) GetRound() int32

func (*VoteSetMaj23) GetType 

func (m *VoteSetMaj23) GetType() types.SignedMsgType

func (*VoteSetMaj23) Marshal 

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

func (*VoteSetMaj23) MarshalTo 

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

func (*VoteSetMaj23) MarshalToSizedBuffer 

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

func (*VoteSetMaj23) ProtoMessage 

func (*VoteSetMaj23) ProtoMessage()

func (*VoteSetMaj23) Reset 

func (m *VoteSetMaj23) Reset()

func (*VoteSetMaj23) Size 

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

func (*VoteSetMaj23) String 

func (m *VoteSetMaj23) String() string

func (*VoteSetMaj23) Unmarshal 

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

func (*VoteSetMaj23) Wrap 

func (m *VoteSetMaj23) Wrap() proto.Message

func (*VoteSetMaj23) XXX_DiscardUnknown 

func (m *VoteSetMaj23) XXX_DiscardUnknown()

func (*VoteSetMaj23) XXX_Marshal 

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

func (*VoteSetMaj23) XXX_Merge 

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

func (*VoteSetMaj23) XXX_Size 

func (m *VoteSetMaj23) XXX_Size() int

func (*VoteSetMaj23) XXX_Unmarshal 

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

type WALMessage 

type WALMessage struct {
	// Types that are valid to be assigned to Sum:
	//	*WALMessage_EventDataRoundState
	//	*WALMessage_MsgInfo
	//	*WALMessage_TimeoutInfo
	//	*WALMessage_EndHeight
	Sum isWALMessage_Sum `protobuf_oneof:"sum"`
}

func (*WALMessage) Descriptor 

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

func (*WALMessage) GetEndHeight 

func (m *WALMessage) GetEndHeight() *EndHeight

func (*WALMessage) GetEventDataRoundState 

func (m *WALMessage) GetEventDataRoundState() *types.EventDataRoundState

func (*WALMessage) GetMsgInfo 

func (m *WALMessage) GetMsgInfo() *MsgInfo

func (*WALMessage) GetSum 

func (m *WALMessage) GetSum() isWALMessage_Sum

func (*WALMessage) GetTimeoutInfo 

func (m *WALMessage) GetTimeoutInfo() *TimeoutInfo

func (*WALMessage) Marshal 

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

func (*WALMessage) MarshalTo 

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

func (*WALMessage) MarshalToSizedBuffer 

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

func (*WALMessage) ProtoMessage 

func (*WALMessage) ProtoMessage()

func (*WALMessage) Reset 

func (m *WALMessage) Reset()

func (*WALMessage) Size 

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

func (*WALMessage) String 

func (m *WALMessage) String() string

func (*WALMessage) Unmarshal 

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

func (*WALMessage) XXX_DiscardUnknown 

func (m *WALMessage) XXX_DiscardUnknown()

func (*WALMessage) XXX_Marshal 

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

func (*WALMessage) XXX_Merge 

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

func (*WALMessage) XXX_OneofWrappers 

func (*WALMessage) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WALMessage) XXX_Size 

func (m *WALMessage) XXX_Size() int

func (*WALMessage) XXX_Unmarshal 

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

type WALMessage_EndHeight 

type WALMessage_EndHeight struct {
	EndHeight *EndHeight `protobuf:"bytes,4,opt,name=end_height,json=endHeight,proto3,oneof" json:"end_height,omitempty"`
}

func (*WALMessage_EndHeight) MarshalTo 

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

func (*WALMessage_EndHeight) MarshalToSizedBuffer 

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

func (*WALMessage_EndHeight) Size 

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

type WALMessage_EventDataRoundState 

type WALMessage_EventDataRoundState struct {
	EventDataRoundState *types.EventDataRoundState `` /* 128-byte string literal not displayed */
}

func (*WALMessage_EventDataRoundState) MarshalTo 

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

func (*WALMessage_EventDataRoundState) MarshalToSizedBuffer 

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

func (*WALMessage_EventDataRoundState) Size 

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

type WALMessage_MsgInfo 

type WALMessage_MsgInfo struct {
	MsgInfo *MsgInfo `protobuf:"bytes,2,opt,name=msg_info,json=msgInfo,proto3,oneof" json:"msg_info,omitempty"`
}

func (*WALMessage_MsgInfo) MarshalTo 

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

func (*WALMessage_MsgInfo) MarshalToSizedBuffer 

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

func (*WALMessage_MsgInfo) Size 

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

type WALMessage_TimeoutInfo 

type WALMessage_TimeoutInfo struct {
	TimeoutInfo *TimeoutInfo `protobuf:"bytes,3,opt,name=timeout_info,json=timeoutInfo,proto3,oneof" json:"timeout_info,omitempty"`
}

func (*WALMessage_TimeoutInfo) MarshalTo 

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

func (*WALMessage_TimeoutInfo) MarshalToSizedBuffer 

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

func (*WALMessage_TimeoutInfo) Size 

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

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.