Documentation ¶
Index ¶
- Variables
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)
- func (m *Commit) GetAssist() bool
- func (m *Commit) GetDigest() string
- func (m *Commit) GetSeq() uint64
- func (m *Commit) GetSignature() *Signature
- func (m *Commit) GetView() uint64
- func (m *Commit) Marshal() (dAtA []byte, err error)
- func (m *Commit) MarshalTo(dAtA []byte) (int, error)
- func (m *Commit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Commit) ProtoMessage()
- func (m *Commit) Reset()
- func (m *Commit) Size() (n int)
- func (m *Commit) String() string
- func (m *Commit) Unmarshal(dAtA []byte) error
- func (m *Commit) XXX_DiscardUnknown()
- func (m *Commit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Commit) XXX_Merge(src proto.Message)
- func (m *Commit) XXX_Size() int
- func (m *Commit) XXX_Unmarshal(b []byte) error
- type HeartBeat
- func (*HeartBeat) Descriptor() ([]byte, []int)
- func (m *HeartBeat) GetSeq() uint64
- func (m *HeartBeat) GetView() uint64
- func (m *HeartBeat) Marshal() (dAtA []byte, err error)
- func (m *HeartBeat) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartBeat) ProtoMessage()
- func (m *HeartBeat) Reset()
- func (m *HeartBeat) Size() (n int)
- func (m *HeartBeat) String() string
- func (m *HeartBeat) Unmarshal(dAtA []byte) error
- func (m *HeartBeat) XXX_DiscardUnknown()
- func (m *HeartBeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartBeat) XXX_Merge(src proto.Message)
- func (m *HeartBeat) XXX_Size() int
- func (m *HeartBeat) XXX_Unmarshal(b []byte) error
- type HeartBeatResponse
- func (*HeartBeatResponse) Descriptor() ([]byte, []int)
- func (m *HeartBeatResponse) GetView() uint64
- func (m *HeartBeatResponse) Marshal() (dAtA []byte, err error)
- func (m *HeartBeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *HeartBeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HeartBeatResponse) ProtoMessage()
- func (m *HeartBeatResponse) Reset()
- func (m *HeartBeatResponse) Size() (n int)
- func (m *HeartBeatResponse) String() string
- func (m *HeartBeatResponse) Unmarshal(dAtA []byte) error
- func (m *HeartBeatResponse) XXX_DiscardUnknown()
- func (m *HeartBeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartBeatResponse) XXX_Merge(src proto.Message)
- func (m *HeartBeatResponse) XXX_Size() int
- func (m *HeartBeatResponse) XXX_Unmarshal(b []byte) error
- type LogRecord
- func (*LogRecord) Descriptor() ([]byte, []int)
- func (m *LogRecord) GetData() []byte
- func (m *LogRecord) GetTruncateTo() bool
- func (m *LogRecord) GetType() LogRecord_Type
- func (m *LogRecord) Marshal() (dAtA []byte, err error)
- func (m *LogRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *LogRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogRecord) ProtoMessage()
- func (m *LogRecord) Reset()
- func (m *LogRecord) Size() (n int)
- func (m *LogRecord) String() string
- func (m *LogRecord) Unmarshal(dAtA []byte) error
- func (m *LogRecord) XXX_DiscardUnknown()
- func (m *LogRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogRecord) XXX_Merge(src proto.Message)
- func (m *LogRecord) XXX_Size() int
- func (m *LogRecord) XXX_Unmarshal(b []byte) error
- type LogRecord_Type
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetCommit() *Commit
- func (m *Message) GetContent() isMessage_Content
- func (m *Message) GetHeartBeat() *HeartBeat
- func (m *Message) GetHeartBeatResponse() *HeartBeatResponse
- func (m *Message) GetNewView() *NewView
- func (m *Message) GetPrePrepare() *PrePrepare
- func (m *Message) GetPrepare() *Prepare
- func (m *Message) GetStateTransferRequest() *StateTransferRequest
- func (m *Message) GetStateTransferResponse() *StateTransferResponse
- func (m *Message) GetViewChange() *ViewChange
- func (m *Message) GetViewData() *SignedViewData
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (*Message) XXX_OneofWrappers() []interface{}
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type Message_Commit
- type Message_HeartBeat
- type Message_HeartBeatResponse
- type Message_NewView
- type Message_PrePrepare
- type Message_Prepare
- type Message_StateTransferRequest
- type Message_StateTransferResponse
- type Message_ViewChange
- type Message_ViewData
- type NewView
- func (*NewView) Descriptor() ([]byte, []int)
- func (m *NewView) GetSignedViewData() []*SignedViewData
- func (m *NewView) Marshal() (dAtA []byte, err error)
- func (m *NewView) MarshalTo(dAtA []byte) (int, error)
- func (m *NewView) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NewView) ProtoMessage()
- func (m *NewView) Reset()
- func (m *NewView) Size() (n int)
- func (m *NewView) String() string
- func (m *NewView) Unmarshal(dAtA []byte) error
- func (m *NewView) XXX_DiscardUnknown()
- func (m *NewView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewView) XXX_Merge(src proto.Message)
- func (m *NewView) XXX_Size() int
- func (m *NewView) XXX_Unmarshal(b []byte) error
- type PrePrepare
- func (*PrePrepare) Descriptor() ([]byte, []int)
- func (m *PrePrepare) GetPrevCommitSignatures() []*Signature
- func (m *PrePrepare) GetProposal() *Proposal
- func (m *PrePrepare) GetSeq() uint64
- func (m *PrePrepare) GetView() uint64
- func (m *PrePrepare) Marshal() (dAtA []byte, err error)
- func (m *PrePrepare) MarshalTo(dAtA []byte) (int, error)
- func (m *PrePrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrePrepare) ProtoMessage()
- func (m *PrePrepare) Reset()
- func (m *PrePrepare) Size() (n int)
- func (m *PrePrepare) String() string
- func (m *PrePrepare) Unmarshal(dAtA []byte) error
- func (m *PrePrepare) XXX_DiscardUnknown()
- func (m *PrePrepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrePrepare) XXX_Merge(src proto.Message)
- func (m *PrePrepare) XXX_Size() int
- func (m *PrePrepare) XXX_Unmarshal(b []byte) error
- type Prepare
- func (*Prepare) Descriptor() ([]byte, []int)
- func (m *Prepare) GetAssist() bool
- func (m *Prepare) GetDigest() string
- func (m *Prepare) GetSeq() uint64
- func (m *Prepare) GetView() uint64
- func (m *Prepare) Marshal() (dAtA []byte, err error)
- func (m *Prepare) MarshalTo(dAtA []byte) (int, error)
- func (m *Prepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Prepare) ProtoMessage()
- func (m *Prepare) Reset()
- func (m *Prepare) Size() (n int)
- func (m *Prepare) String() string
- func (m *Prepare) Unmarshal(dAtA []byte) error
- func (m *Prepare) XXX_DiscardUnknown()
- func (m *Prepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Prepare) XXX_Merge(src proto.Message)
- func (m *Prepare) XXX_Size() int
- func (m *Prepare) XXX_Unmarshal(b []byte) error
- type PreparesFrom
- func (*PreparesFrom) Descriptor() ([]byte, []int)
- func (m *PreparesFrom) GetIds() []uint64
- func (m *PreparesFrom) Marshal() (dAtA []byte, err error)
- func (m *PreparesFrom) MarshalTo(dAtA []byte) (int, error)
- func (m *PreparesFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PreparesFrom) ProtoMessage()
- func (m *PreparesFrom) Reset()
- func (m *PreparesFrom) Size() (n int)
- func (m *PreparesFrom) String() string
- func (m *PreparesFrom) Unmarshal(dAtA []byte) error
- func (m *PreparesFrom) XXX_DiscardUnknown()
- func (m *PreparesFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PreparesFrom) XXX_Merge(src proto.Message)
- func (m *PreparesFrom) XXX_Size() int
- func (m *PreparesFrom) XXX_Unmarshal(b []byte) error
- type Proposal
- func (*Proposal) Descriptor() ([]byte, []int)
- func (m *Proposal) GetHeader() []byte
- func (m *Proposal) GetMetadata() []byte
- func (m *Proposal) GetPayload() []byte
- func (m *Proposal) GetVerificationSequence() uint64
- func (m *Proposal) Marshal() (dAtA []byte, err error)
- func (m *Proposal) MarshalTo(dAtA []byte) (int, error)
- func (m *Proposal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Proposal) ProtoMessage()
- func (m *Proposal) Reset()
- func (m *Proposal) Size() (n int)
- func (m *Proposal) String() string
- func (m *Proposal) Unmarshal(dAtA []byte) error
- func (m *Proposal) XXX_DiscardUnknown()
- func (m *Proposal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Proposal) XXX_Merge(src proto.Message)
- func (m *Proposal) XXX_Size() int
- func (m *Proposal) XXX_Unmarshal(b []byte) error
- type ProposedRecord
- func (*ProposedRecord) Descriptor() ([]byte, []int)
- func (m *ProposedRecord) GetPrePrepare() *PrePrepare
- func (m *ProposedRecord) GetPrepare() *Prepare
- func (m *ProposedRecord) Marshal() (dAtA []byte, err error)
- func (m *ProposedRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *ProposedRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ProposedRecord) ProtoMessage()
- func (m *ProposedRecord) Reset()
- func (m *ProposedRecord) Size() (n int)
- func (m *ProposedRecord) String() string
- func (m *ProposedRecord) Unmarshal(dAtA []byte) error
- func (m *ProposedRecord) XXX_DiscardUnknown()
- func (m *ProposedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProposedRecord) XXX_Merge(src proto.Message)
- func (m *ProposedRecord) XXX_Size() int
- func (m *ProposedRecord) XXX_Unmarshal(b []byte) error
- type SavedMessage
- func (*SavedMessage) Descriptor() ([]byte, []int)
- func (m *SavedMessage) GetCommit() *Message
- func (m *SavedMessage) GetContent() isSavedMessage_Content
- func (m *SavedMessage) GetNewView() *ViewMetadata
- func (m *SavedMessage) GetProposedRecord() *ProposedRecord
- func (m *SavedMessage) GetViewChange() *ViewChange
- func (m *SavedMessage) Marshal() (dAtA []byte, err error)
- func (m *SavedMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *SavedMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SavedMessage) ProtoMessage()
- func (m *SavedMessage) Reset()
- func (m *SavedMessage) Size() (n int)
- func (m *SavedMessage) String() string
- func (m *SavedMessage) Unmarshal(dAtA []byte) error
- func (m *SavedMessage) XXX_DiscardUnknown()
- func (m *SavedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SavedMessage) XXX_Merge(src proto.Message)
- func (*SavedMessage) XXX_OneofWrappers() []interface{}
- func (m *SavedMessage) XXX_Size() int
- func (m *SavedMessage) XXX_Unmarshal(b []byte) error
- type SavedMessage_Commit
- type SavedMessage_NewView
- type SavedMessage_ProposedRecord
- type SavedMessage_ViewChange
- type Signature
- func (*Signature) Descriptor() ([]byte, []int)
- func (m *Signature) GetMsg() []byte
- func (m *Signature) GetSigner() uint64
- func (m *Signature) GetValue() []byte
- func (m *Signature) Marshal() (dAtA []byte, err error)
- func (m *Signature) MarshalTo(dAtA []byte) (int, error)
- func (m *Signature) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Signature) ProtoMessage()
- func (m *Signature) Reset()
- func (m *Signature) Size() (n int)
- func (m *Signature) String() string
- func (m *Signature) Unmarshal(dAtA []byte) error
- func (m *Signature) XXX_DiscardUnknown()
- func (m *Signature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Signature) XXX_Merge(src proto.Message)
- func (m *Signature) XXX_Size() int
- func (m *Signature) XXX_Unmarshal(b []byte) error
- type SignedViewData
- func (*SignedViewData) Descriptor() ([]byte, []int)
- func (m *SignedViewData) GetRawViewData() []byte
- func (m *SignedViewData) GetSignature() []byte
- func (m *SignedViewData) GetSigner() uint64
- func (m *SignedViewData) Marshal() (dAtA []byte, err error)
- func (m *SignedViewData) MarshalTo(dAtA []byte) (int, error)
- func (m *SignedViewData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SignedViewData) ProtoMessage()
- func (m *SignedViewData) Reset()
- func (m *SignedViewData) Size() (n int)
- func (m *SignedViewData) String() string
- func (m *SignedViewData) Unmarshal(dAtA []byte) error
- func (m *SignedViewData) XXX_DiscardUnknown()
- func (m *SignedViewData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignedViewData) XXX_Merge(src proto.Message)
- func (m *SignedViewData) XXX_Size() int
- func (m *SignedViewData) XXX_Unmarshal(b []byte) error
- type StateTransferRequest
- func (*StateTransferRequest) Descriptor() ([]byte, []int)
- func (m *StateTransferRequest) Marshal() (dAtA []byte, err error)
- func (m *StateTransferRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StateTransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StateTransferRequest) ProtoMessage()
- func (m *StateTransferRequest) Reset()
- func (m *StateTransferRequest) Size() (n int)
- func (m *StateTransferRequest) String() string
- func (m *StateTransferRequest) Unmarshal(dAtA []byte) error
- func (m *StateTransferRequest) XXX_DiscardUnknown()
- func (m *StateTransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateTransferRequest) XXX_Merge(src proto.Message)
- func (m *StateTransferRequest) XXX_Size() int
- func (m *StateTransferRequest) XXX_Unmarshal(b []byte) error
- type StateTransferResponse
- func (*StateTransferResponse) Descriptor() ([]byte, []int)
- func (m *StateTransferResponse) GetSequence() uint64
- func (m *StateTransferResponse) GetViewNum() uint64
- func (m *StateTransferResponse) Marshal() (dAtA []byte, err error)
- func (m *StateTransferResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StateTransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StateTransferResponse) ProtoMessage()
- func (m *StateTransferResponse) Reset()
- func (m *StateTransferResponse) Size() (n int)
- func (m *StateTransferResponse) String() string
- func (m *StateTransferResponse) Unmarshal(dAtA []byte) error
- func (m *StateTransferResponse) XXX_DiscardUnknown()
- func (m *StateTransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateTransferResponse) XXX_Merge(src proto.Message)
- func (m *StateTransferResponse) XXX_Size() int
- func (m *StateTransferResponse) XXX_Unmarshal(b []byte) error
- type ViewChange
- func (*ViewChange) Descriptor() ([]byte, []int)
- func (m *ViewChange) GetNextView() uint64
- func (m *ViewChange) GetReason() string
- func (m *ViewChange) Marshal() (dAtA []byte, err error)
- func (m *ViewChange) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewChange) ProtoMessage()
- func (m *ViewChange) Reset()
- func (m *ViewChange) Size() (n int)
- func (m *ViewChange) String() string
- func (m *ViewChange) Unmarshal(dAtA []byte) error
- func (m *ViewChange) XXX_DiscardUnknown()
- func (m *ViewChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewChange) XXX_Merge(src proto.Message)
- func (m *ViewChange) XXX_Size() int
- func (m *ViewChange) XXX_Unmarshal(b []byte) error
- type ViewData
- func (*ViewData) Descriptor() ([]byte, []int)
- func (m *ViewData) GetInFlightPrepared() bool
- func (m *ViewData) GetInFlightProposal() *Proposal
- func (m *ViewData) GetLastDecision() *Proposal
- func (m *ViewData) GetLastDecisionSignatures() []*Signature
- func (m *ViewData) GetNextView() uint64
- func (m *ViewData) Marshal() (dAtA []byte, err error)
- func (m *ViewData) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewData) ProtoMessage()
- func (m *ViewData) Reset()
- func (m *ViewData) Size() (n int)
- func (m *ViewData) String() string
- func (m *ViewData) Unmarshal(dAtA []byte) error
- func (m *ViewData) XXX_DiscardUnknown()
- func (m *ViewData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewData) XXX_Merge(src proto.Message)
- func (m *ViewData) XXX_Size() int
- func (m *ViewData) XXX_Unmarshal(b []byte) error
- type ViewMetadata
- func (*ViewMetadata) Descriptor() ([]byte, []int)
- func (m *ViewMetadata) GetBlackList() []uint64
- func (m *ViewMetadata) GetDecisionsInView() uint64
- func (m *ViewMetadata) GetLatestSequence() uint64
- func (m *ViewMetadata) GetPrevCommitSignatureDigest() []byte
- func (m *ViewMetadata) GetViewId() uint64
- func (m *ViewMetadata) Marshal() (dAtA []byte, err error)
- func (m *ViewMetadata) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewMetadata) ProtoMessage()
- func (m *ViewMetadata) Reset()
- func (m *ViewMetadata) Size() (n int)
- func (m *ViewMetadata) String() string
- func (m *ViewMetadata) Unmarshal(dAtA []byte) error
- func (m *ViewMetadata) XXX_DiscardUnknown()
- func (m *ViewMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewMetadata) XXX_Merge(src proto.Message)
- func (m *ViewMetadata) XXX_Size() int
- func (m *ViewMetadata) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthLogrecord = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLogrecord = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupLogrecord = fmt.Errorf("proto: unexpected end of group") )
View Source
var ( ErrInvalidLengthMessages = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessages = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group") )
View Source
var LogRecord_Type_name = map[int32]string{
0: "ENTRY",
1: "CONTROL",
2: "CRC_ANCHOR",
}
View Source
var LogRecord_Type_value = map[string]int32{
"ENTRY": 0,
"CONTROL": 1,
"CRC_ANCHOR": 2,
}
Functions ¶
This section is empty.
Types ¶
type Commit ¶
type Commit struct { View uint64 `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"` Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` Digest string `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"` Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"` Assist bool `protobuf:"varint,5,opt,name=assist,proto3" json:"assist,omitempty"` }
func (*Commit) Descriptor ¶
func (*Commit) GetSignature ¶
func (*Commit) MarshalToSizedBuffer ¶
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) XXX_DiscardUnknown ¶
func (m *Commit) XXX_DiscardUnknown()
func (*Commit) XXX_Marshal ¶
func (*Commit) XXX_Unmarshal ¶
type HeartBeat ¶
type HeartBeat struct { View uint64 `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"` Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` }
func (*HeartBeat) Descriptor ¶
func (*HeartBeat) MarshalToSizedBuffer ¶
func (*HeartBeat) ProtoMessage ¶
func (*HeartBeat) ProtoMessage()
func (*HeartBeat) XXX_DiscardUnknown ¶
func (m *HeartBeat) XXX_DiscardUnknown()
func (*HeartBeat) XXX_Marshal ¶
func (*HeartBeat) XXX_Unmarshal ¶
type HeartBeatResponse ¶
type HeartBeatResponse struct {
View uint64 `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"`
}
func (*HeartBeatResponse) Descriptor ¶
func (*HeartBeatResponse) Descriptor() ([]byte, []int)
func (*HeartBeatResponse) GetView ¶
func (m *HeartBeatResponse) GetView() uint64
func (*HeartBeatResponse) Marshal ¶
func (m *HeartBeatResponse) Marshal() (dAtA []byte, err error)
func (*HeartBeatResponse) MarshalTo ¶
func (m *HeartBeatResponse) MarshalTo(dAtA []byte) (int, error)
func (*HeartBeatResponse) MarshalToSizedBuffer ¶
func (m *HeartBeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HeartBeatResponse) ProtoMessage ¶
func (*HeartBeatResponse) ProtoMessage()
func (*HeartBeatResponse) Reset ¶
func (m *HeartBeatResponse) Reset()
func (*HeartBeatResponse) Size ¶
func (m *HeartBeatResponse) Size() (n int)
func (*HeartBeatResponse) String ¶
func (m *HeartBeatResponse) String() string
func (*HeartBeatResponse) Unmarshal ¶
func (m *HeartBeatResponse) Unmarshal(dAtA []byte) error
func (*HeartBeatResponse) XXX_DiscardUnknown ¶
func (m *HeartBeatResponse) XXX_DiscardUnknown()
func (*HeartBeatResponse) XXX_Marshal ¶
func (m *HeartBeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartBeatResponse) XXX_Merge ¶
func (m *HeartBeatResponse) XXX_Merge(src proto.Message)
func (*HeartBeatResponse) XXX_Size ¶
func (m *HeartBeatResponse) XXX_Size() int
func (*HeartBeatResponse) XXX_Unmarshal ¶
func (m *HeartBeatResponse) XXX_Unmarshal(b []byte) error
type LogRecord ¶
type LogRecord struct { Type LogRecord_Type `protobuf:"varint,1,opt,name=type,proto3,enum=smartbftprotos.LogRecord_Type" json:"type,omitempty"` TruncateTo bool `protobuf:"varint,2,opt,name=truncate_to,json=truncateTo,proto3" json:"truncate_to,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` }
func (*LogRecord) Descriptor ¶
func (*LogRecord) GetTruncateTo ¶
func (*LogRecord) GetType ¶
func (m *LogRecord) GetType() LogRecord_Type
func (*LogRecord) MarshalToSizedBuffer ¶
func (*LogRecord) ProtoMessage ¶
func (*LogRecord) ProtoMessage()
func (*LogRecord) XXX_DiscardUnknown ¶
func (m *LogRecord) XXX_DiscardUnknown()
func (*LogRecord) XXX_Marshal ¶
func (*LogRecord) XXX_Unmarshal ¶
type LogRecord_Type ¶
type LogRecord_Type int32
const ( LogRecord_ENTRY LogRecord_Type = 0 LogRecord_CONTROL LogRecord_Type = 1 LogRecord_CRC_ANCHOR LogRecord_Type = 2 )
func (LogRecord_Type) EnumDescriptor ¶
func (LogRecord_Type) EnumDescriptor() ([]byte, []int)
func (LogRecord_Type) String ¶
func (x LogRecord_Type) String() string
type Message ¶
type Message struct { // Types that are valid to be assigned to Content: // *Message_PrePrepare // *Message_Prepare // *Message_Commit // *Message_ViewChange // *Message_ViewData // *Message_NewView // *Message_HeartBeat // *Message_HeartBeatResponse // *Message_StateTransferRequest // *Message_StateTransferResponse Content isMessage_Content `protobuf_oneof:"content"` }
func (*Message) Descriptor ¶
func (*Message) GetContent ¶
func (m *Message) GetContent() isMessage_Content
func (*Message) GetHeartBeat ¶
func (*Message) GetHeartBeatResponse ¶
func (m *Message) GetHeartBeatResponse() *HeartBeatResponse
func (*Message) GetNewView ¶
func (*Message) GetPrePrepare ¶
func (m *Message) GetPrePrepare() *PrePrepare
func (*Message) GetPrepare ¶
func (*Message) GetStateTransferRequest ¶
func (m *Message) GetStateTransferRequest() *StateTransferRequest
func (*Message) GetStateTransferResponse ¶
func (m *Message) GetStateTransferResponse() *StateTransferResponse
func (*Message) GetViewChange ¶
func (m *Message) GetViewChange() *ViewChange
func (*Message) GetViewData ¶
func (m *Message) GetViewData() *SignedViewData
func (*Message) MarshalToSizedBuffer ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_OneofWrappers ¶
func (*Message) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Message) XXX_Unmarshal ¶
type Message_Commit ¶
type Message_Commit struct {
Commit *Commit `protobuf:"bytes,3,opt,name=commit,proto3,oneof" json:"commit,omitempty"`
}
func (*Message_Commit) MarshalToSizedBuffer ¶
func (m *Message_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_Commit) Size ¶
func (m *Message_Commit) Size() (n int)
type Message_HeartBeat ¶
type Message_HeartBeat struct {
HeartBeat *HeartBeat `protobuf:"bytes,7,opt,name=heart_beat,json=heartBeat,proto3,oneof" json:"heart_beat,omitempty"`
}
func (*Message_HeartBeat) MarshalTo ¶
func (m *Message_HeartBeat) MarshalTo(dAtA []byte) (int, error)
func (*Message_HeartBeat) MarshalToSizedBuffer ¶
func (m *Message_HeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_HeartBeat) Size ¶
func (m *Message_HeartBeat) Size() (n int)
type Message_HeartBeatResponse ¶
type Message_HeartBeatResponse struct {
HeartBeatResponse *HeartBeatResponse `protobuf:"bytes,8,opt,name=heart_beat_response,json=heartBeatResponse,proto3,oneof" json:"heart_beat_response,omitempty"`
}
func (*Message_HeartBeatResponse) MarshalTo ¶
func (m *Message_HeartBeatResponse) MarshalTo(dAtA []byte) (int, error)
func (*Message_HeartBeatResponse) MarshalToSizedBuffer ¶
func (m *Message_HeartBeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_HeartBeatResponse) Size ¶
func (m *Message_HeartBeatResponse) Size() (n int)
type Message_NewView ¶
type Message_NewView struct {
NewView *NewView `protobuf:"bytes,6,opt,name=new_view,json=newView,proto3,oneof" json:"new_view,omitempty"`
}
func (*Message_NewView) MarshalToSizedBuffer ¶
func (m *Message_NewView) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_NewView) Size ¶
func (m *Message_NewView) Size() (n int)
type Message_PrePrepare ¶
type Message_PrePrepare struct {
PrePrepare *PrePrepare `protobuf:"bytes,1,opt,name=pre_prepare,json=prePrepare,proto3,oneof" json:"pre_prepare,omitempty"`
}
func (*Message_PrePrepare) MarshalTo ¶
func (m *Message_PrePrepare) MarshalTo(dAtA []byte) (int, error)
func (*Message_PrePrepare) MarshalToSizedBuffer ¶
func (m *Message_PrePrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_PrePrepare) Size ¶
func (m *Message_PrePrepare) Size() (n int)
type Message_Prepare ¶
type Message_Prepare struct {
Prepare *Prepare `protobuf:"bytes,2,opt,name=prepare,proto3,oneof" json:"prepare,omitempty"`
}
func (*Message_Prepare) MarshalToSizedBuffer ¶
func (m *Message_Prepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_Prepare) Size ¶
func (m *Message_Prepare) Size() (n int)
type Message_StateTransferRequest ¶
type Message_StateTransferRequest struct {
StateTransferRequest *StateTransferRequest `` /* 129-byte string literal not displayed */
}
func (*Message_StateTransferRequest) MarshalTo ¶
func (m *Message_StateTransferRequest) MarshalTo(dAtA []byte) (int, error)
func (*Message_StateTransferRequest) MarshalToSizedBuffer ¶
func (m *Message_StateTransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_StateTransferRequest) Size ¶
func (m *Message_StateTransferRequest) Size() (n int)
type Message_StateTransferResponse ¶
type Message_StateTransferResponse struct {
StateTransferResponse *StateTransferResponse `` /* 133-byte string literal not displayed */
}
func (*Message_StateTransferResponse) MarshalTo ¶
func (m *Message_StateTransferResponse) MarshalTo(dAtA []byte) (int, error)
func (*Message_StateTransferResponse) MarshalToSizedBuffer ¶
func (m *Message_StateTransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_StateTransferResponse) Size ¶
func (m *Message_StateTransferResponse) Size() (n int)
type Message_ViewChange ¶
type Message_ViewChange struct {
ViewChange *ViewChange `protobuf:"bytes,4,opt,name=view_change,json=viewChange,proto3,oneof" json:"view_change,omitempty"`
}
func (*Message_ViewChange) MarshalTo ¶
func (m *Message_ViewChange) MarshalTo(dAtA []byte) (int, error)
func (*Message_ViewChange) MarshalToSizedBuffer ¶
func (m *Message_ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_ViewChange) Size ¶
func (m *Message_ViewChange) Size() (n int)
type Message_ViewData ¶
type Message_ViewData struct {
ViewData *SignedViewData `protobuf:"bytes,5,opt,name=view_data,json=viewData,proto3,oneof" json:"view_data,omitempty"`
}
func (*Message_ViewData) MarshalToSizedBuffer ¶
func (m *Message_ViewData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Message_ViewData) Size ¶
func (m *Message_ViewData) Size() (n int)
type NewView ¶
type NewView struct {
SignedViewData []*SignedViewData `protobuf:"bytes,2,rep,name=signed_view_data,json=signedViewData,proto3" json:"signed_view_data,omitempty"`
}
func (*NewView) Descriptor ¶
func (*NewView) GetSignedViewData ¶
func (m *NewView) GetSignedViewData() []*SignedViewData
func (*NewView) MarshalToSizedBuffer ¶
func (*NewView) ProtoMessage ¶
func (*NewView) ProtoMessage()
func (*NewView) XXX_DiscardUnknown ¶
func (m *NewView) XXX_DiscardUnknown()
func (*NewView) XXX_Marshal ¶
func (*NewView) XXX_Unmarshal ¶
type PrePrepare ¶
type PrePrepare struct { View uint64 `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"` Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` Proposal *Proposal `protobuf:"bytes,3,opt,name=proposal,proto3" json:"proposal,omitempty"` PrevCommitSignatures []*Signature `protobuf:"bytes,4,rep,name=prev_commit_signatures,json=prevCommitSignatures,proto3" json:"prev_commit_signatures,omitempty"` }
func (*PrePrepare) Descriptor ¶
func (*PrePrepare) Descriptor() ([]byte, []int)
func (*PrePrepare) GetPrevCommitSignatures ¶
func (m *PrePrepare) GetPrevCommitSignatures() []*Signature
func (*PrePrepare) GetProposal ¶
func (m *PrePrepare) GetProposal() *Proposal
func (*PrePrepare) GetSeq ¶
func (m *PrePrepare) GetSeq() uint64
func (*PrePrepare) GetView ¶
func (m *PrePrepare) GetView() uint64
func (*PrePrepare) Marshal ¶
func (m *PrePrepare) Marshal() (dAtA []byte, err error)
func (*PrePrepare) MarshalToSizedBuffer ¶
func (m *PrePrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrePrepare) ProtoMessage ¶
func (*PrePrepare) ProtoMessage()
func (*PrePrepare) Reset ¶
func (m *PrePrepare) Reset()
func (*PrePrepare) Size ¶
func (m *PrePrepare) Size() (n int)
func (*PrePrepare) String ¶
func (m *PrePrepare) String() string
func (*PrePrepare) Unmarshal ¶
func (m *PrePrepare) Unmarshal(dAtA []byte) error
func (*PrePrepare) XXX_DiscardUnknown ¶
func (m *PrePrepare) XXX_DiscardUnknown()
func (*PrePrepare) XXX_Marshal ¶
func (m *PrePrepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrePrepare) XXX_Merge ¶
func (m *PrePrepare) XXX_Merge(src proto.Message)
func (*PrePrepare) XXX_Size ¶
func (m *PrePrepare) XXX_Size() int
func (*PrePrepare) XXX_Unmarshal ¶
func (m *PrePrepare) XXX_Unmarshal(b []byte) error
type Prepare ¶
type Prepare struct { View uint64 `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"` Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` Digest string `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"` Assist bool `protobuf:"varint,4,opt,name=assist,proto3" json:"assist,omitempty"` }
func (*Prepare) Descriptor ¶
func (*Prepare) MarshalToSizedBuffer ¶
func (*Prepare) ProtoMessage ¶
func (*Prepare) ProtoMessage()
func (*Prepare) XXX_DiscardUnknown ¶
func (m *Prepare) XXX_DiscardUnknown()
func (*Prepare) XXX_Marshal ¶
func (*Prepare) XXX_Unmarshal ¶
type PreparesFrom ¶
type PreparesFrom struct {
Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
}
func (*PreparesFrom) Descriptor ¶
func (*PreparesFrom) Descriptor() ([]byte, []int)
func (*PreparesFrom) GetIds ¶
func (m *PreparesFrom) GetIds() []uint64
func (*PreparesFrom) Marshal ¶
func (m *PreparesFrom) Marshal() (dAtA []byte, err error)
func (*PreparesFrom) MarshalToSizedBuffer ¶
func (m *PreparesFrom) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PreparesFrom) ProtoMessage ¶
func (*PreparesFrom) ProtoMessage()
func (*PreparesFrom) Reset ¶
func (m *PreparesFrom) Reset()
func (*PreparesFrom) Size ¶
func (m *PreparesFrom) Size() (n int)
func (*PreparesFrom) String ¶
func (m *PreparesFrom) String() string
func (*PreparesFrom) Unmarshal ¶
func (m *PreparesFrom) Unmarshal(dAtA []byte) error
func (*PreparesFrom) XXX_DiscardUnknown ¶
func (m *PreparesFrom) XXX_DiscardUnknown()
func (*PreparesFrom) XXX_Marshal ¶
func (m *PreparesFrom) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PreparesFrom) XXX_Merge ¶
func (m *PreparesFrom) XXX_Merge(src proto.Message)
func (*PreparesFrom) XXX_Size ¶
func (m *PreparesFrom) XXX_Size() int
func (*PreparesFrom) XXX_Unmarshal ¶
func (m *PreparesFrom) XXX_Unmarshal(b []byte) error
type Proposal ¶
type Proposal struct { Header []byte `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` Metadata []byte `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` VerificationSequence uint64 `protobuf:"varint,4,opt,name=verification_sequence,json=verificationSequence,proto3" json:"verification_sequence,omitempty"` }
func (*Proposal) Descriptor ¶
func (*Proposal) GetMetadata ¶
func (*Proposal) GetPayload ¶
func (*Proposal) GetVerificationSequence ¶
func (*Proposal) MarshalToSizedBuffer ¶
func (*Proposal) ProtoMessage ¶
func (*Proposal) ProtoMessage()
func (*Proposal) XXX_DiscardUnknown ¶
func (m *Proposal) XXX_DiscardUnknown()
func (*Proposal) XXX_Marshal ¶
func (*Proposal) XXX_Unmarshal ¶
type ProposedRecord ¶
type ProposedRecord struct { PrePrepare *PrePrepare `protobuf:"bytes,1,opt,name=pre_prepare,json=prePrepare,proto3" json:"pre_prepare,omitempty"` Prepare *Prepare `protobuf:"bytes,2,opt,name=prepare,proto3" json:"prepare,omitempty"` }
func (*ProposedRecord) Descriptor ¶
func (*ProposedRecord) Descriptor() ([]byte, []int)
func (*ProposedRecord) GetPrePrepare ¶
func (m *ProposedRecord) GetPrePrepare() *PrePrepare
func (*ProposedRecord) GetPrepare ¶
func (m *ProposedRecord) GetPrepare() *Prepare
func (*ProposedRecord) Marshal ¶
func (m *ProposedRecord) Marshal() (dAtA []byte, err error)
func (*ProposedRecord) MarshalToSizedBuffer ¶
func (m *ProposedRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ProposedRecord) ProtoMessage ¶
func (*ProposedRecord) ProtoMessage()
func (*ProposedRecord) Reset ¶
func (m *ProposedRecord) Reset()
func (*ProposedRecord) Size ¶
func (m *ProposedRecord) Size() (n int)
func (*ProposedRecord) String ¶
func (m *ProposedRecord) String() string
func (*ProposedRecord) Unmarshal ¶
func (m *ProposedRecord) Unmarshal(dAtA []byte) error
func (*ProposedRecord) XXX_DiscardUnknown ¶
func (m *ProposedRecord) XXX_DiscardUnknown()
func (*ProposedRecord) XXX_Marshal ¶
func (m *ProposedRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProposedRecord) XXX_Merge ¶
func (m *ProposedRecord) XXX_Merge(src proto.Message)
func (*ProposedRecord) XXX_Size ¶
func (m *ProposedRecord) XXX_Size() int
func (*ProposedRecord) XXX_Unmarshal ¶
func (m *ProposedRecord) XXX_Unmarshal(b []byte) error
type SavedMessage ¶
type SavedMessage struct { // Types that are valid to be assigned to Content: // *SavedMessage_ProposedRecord // *SavedMessage_Commit // *SavedMessage_NewView // *SavedMessage_ViewChange Content isSavedMessage_Content `protobuf_oneof:"content"` }
func (*SavedMessage) Descriptor ¶
func (*SavedMessage) Descriptor() ([]byte, []int)
func (*SavedMessage) GetCommit ¶
func (m *SavedMessage) GetCommit() *Message
func (*SavedMessage) GetContent ¶
func (m *SavedMessage) GetContent() isSavedMessage_Content
func (*SavedMessage) GetNewView ¶
func (m *SavedMessage) GetNewView() *ViewMetadata
func (*SavedMessage) GetProposedRecord ¶
func (m *SavedMessage) GetProposedRecord() *ProposedRecord
func (*SavedMessage) GetViewChange ¶
func (m *SavedMessage) GetViewChange() *ViewChange
func (*SavedMessage) Marshal ¶
func (m *SavedMessage) Marshal() (dAtA []byte, err error)
func (*SavedMessage) MarshalToSizedBuffer ¶
func (m *SavedMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SavedMessage) ProtoMessage ¶
func (*SavedMessage) ProtoMessage()
func (*SavedMessage) Reset ¶
func (m *SavedMessage) Reset()
func (*SavedMessage) Size ¶
func (m *SavedMessage) Size() (n int)
func (*SavedMessage) String ¶
func (m *SavedMessage) String() string
func (*SavedMessage) Unmarshal ¶
func (m *SavedMessage) Unmarshal(dAtA []byte) error
func (*SavedMessage) XXX_DiscardUnknown ¶
func (m *SavedMessage) XXX_DiscardUnknown()
func (*SavedMessage) XXX_Marshal ¶
func (m *SavedMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SavedMessage) XXX_Merge ¶
func (m *SavedMessage) XXX_Merge(src proto.Message)
func (*SavedMessage) XXX_OneofWrappers ¶
func (*SavedMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SavedMessage) XXX_Size ¶
func (m *SavedMessage) XXX_Size() int
func (*SavedMessage) XXX_Unmarshal ¶
func (m *SavedMessage) XXX_Unmarshal(b []byte) error
type SavedMessage_Commit ¶
type SavedMessage_Commit struct {
Commit *Message `protobuf:"bytes,2,opt,name=commit,proto3,oneof" json:"commit,omitempty"`
}
func (*SavedMessage_Commit) MarshalTo ¶
func (m *SavedMessage_Commit) MarshalTo(dAtA []byte) (int, error)
func (*SavedMessage_Commit) MarshalToSizedBuffer ¶
func (m *SavedMessage_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SavedMessage_Commit) Size ¶
func (m *SavedMessage_Commit) Size() (n int)
type SavedMessage_NewView ¶
type SavedMessage_NewView struct {
NewView *ViewMetadata `protobuf:"bytes,3,opt,name=new_view,json=newView,proto3,oneof" json:"new_view,omitempty"`
}
func (*SavedMessage_NewView) MarshalTo ¶
func (m *SavedMessage_NewView) MarshalTo(dAtA []byte) (int, error)
func (*SavedMessage_NewView) MarshalToSizedBuffer ¶
func (m *SavedMessage_NewView) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SavedMessage_NewView) Size ¶
func (m *SavedMessage_NewView) Size() (n int)
type SavedMessage_ProposedRecord ¶
type SavedMessage_ProposedRecord struct {
ProposedRecord *ProposedRecord `protobuf:"bytes,1,opt,name=proposed_record,json=proposedRecord,proto3,oneof" json:"proposed_record,omitempty"`
}
func (*SavedMessage_ProposedRecord) MarshalTo ¶
func (m *SavedMessage_ProposedRecord) MarshalTo(dAtA []byte) (int, error)
func (*SavedMessage_ProposedRecord) MarshalToSizedBuffer ¶
func (m *SavedMessage_ProposedRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SavedMessage_ProposedRecord) Size ¶
func (m *SavedMessage_ProposedRecord) Size() (n int)
type SavedMessage_ViewChange ¶
type SavedMessage_ViewChange struct {
ViewChange *ViewChange `protobuf:"bytes,4,opt,name=view_change,json=viewChange,proto3,oneof" json:"view_change,omitempty"`
}
func (*SavedMessage_ViewChange) MarshalTo ¶
func (m *SavedMessage_ViewChange) MarshalTo(dAtA []byte) (int, error)
func (*SavedMessage_ViewChange) MarshalToSizedBuffer ¶
func (m *SavedMessage_ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SavedMessage_ViewChange) Size ¶
func (m *SavedMessage_ViewChange) Size() (n int)
type Signature ¶
type Signature struct { Signer uint64 `protobuf:"varint,1,opt,name=signer,proto3" json:"signer,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Msg []byte `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` }
func (*Signature) Descriptor ¶
func (*Signature) MarshalToSizedBuffer ¶
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) XXX_DiscardUnknown ¶
func (m *Signature) XXX_DiscardUnknown()
func (*Signature) XXX_Marshal ¶
func (*Signature) XXX_Unmarshal ¶
type SignedViewData ¶
type SignedViewData struct { RawViewData []byte `protobuf:"bytes,1,opt,name=raw_view_data,json=rawViewData,proto3" json:"raw_view_data,omitempty"` Signer uint64 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` }
func (*SignedViewData) Descriptor ¶
func (*SignedViewData) Descriptor() ([]byte, []int)
func (*SignedViewData) GetRawViewData ¶
func (m *SignedViewData) GetRawViewData() []byte
func (*SignedViewData) GetSignature ¶
func (m *SignedViewData) GetSignature() []byte
func (*SignedViewData) GetSigner ¶
func (m *SignedViewData) GetSigner() uint64
func (*SignedViewData) Marshal ¶
func (m *SignedViewData) Marshal() (dAtA []byte, err error)
func (*SignedViewData) MarshalToSizedBuffer ¶
func (m *SignedViewData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SignedViewData) ProtoMessage ¶
func (*SignedViewData) ProtoMessage()
func (*SignedViewData) Reset ¶
func (m *SignedViewData) Reset()
func (*SignedViewData) Size ¶
func (m *SignedViewData) Size() (n int)
func (*SignedViewData) String ¶
func (m *SignedViewData) String() string
func (*SignedViewData) Unmarshal ¶
func (m *SignedViewData) Unmarshal(dAtA []byte) error
func (*SignedViewData) XXX_DiscardUnknown ¶
func (m *SignedViewData) XXX_DiscardUnknown()
func (*SignedViewData) XXX_Marshal ¶
func (m *SignedViewData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignedViewData) XXX_Merge ¶
func (m *SignedViewData) XXX_Merge(src proto.Message)
func (*SignedViewData) XXX_Size ¶
func (m *SignedViewData) XXX_Size() int
func (*SignedViewData) XXX_Unmarshal ¶
func (m *SignedViewData) XXX_Unmarshal(b []byte) error
type StateTransferRequest ¶
type StateTransferRequest struct { }
func (*StateTransferRequest) Descriptor ¶
func (*StateTransferRequest) Descriptor() ([]byte, []int)
func (*StateTransferRequest) Marshal ¶
func (m *StateTransferRequest) Marshal() (dAtA []byte, err error)
func (*StateTransferRequest) MarshalTo ¶
func (m *StateTransferRequest) MarshalTo(dAtA []byte) (int, error)
func (*StateTransferRequest) MarshalToSizedBuffer ¶
func (m *StateTransferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StateTransferRequest) ProtoMessage ¶
func (*StateTransferRequest) ProtoMessage()
func (*StateTransferRequest) Reset ¶
func (m *StateTransferRequest) Reset()
func (*StateTransferRequest) Size ¶
func (m *StateTransferRequest) Size() (n int)
func (*StateTransferRequest) String ¶
func (m *StateTransferRequest) String() string
func (*StateTransferRequest) Unmarshal ¶
func (m *StateTransferRequest) Unmarshal(dAtA []byte) error
func (*StateTransferRequest) XXX_DiscardUnknown ¶
func (m *StateTransferRequest) XXX_DiscardUnknown()
func (*StateTransferRequest) XXX_Marshal ¶
func (m *StateTransferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateTransferRequest) XXX_Merge ¶
func (m *StateTransferRequest) XXX_Merge(src proto.Message)
func (*StateTransferRequest) XXX_Size ¶
func (m *StateTransferRequest) XXX_Size() int
func (*StateTransferRequest) XXX_Unmarshal ¶
func (m *StateTransferRequest) XXX_Unmarshal(b []byte) error
type StateTransferResponse ¶
type StateTransferResponse struct { ViewNum uint64 `protobuf:"varint,1,opt,name=view_num,json=viewNum,proto3" json:"view_num,omitempty"` Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` }
func (*StateTransferResponse) Descriptor ¶
func (*StateTransferResponse) Descriptor() ([]byte, []int)
func (*StateTransferResponse) GetSequence ¶
func (m *StateTransferResponse) GetSequence() uint64
func (*StateTransferResponse) GetViewNum ¶
func (m *StateTransferResponse) GetViewNum() uint64
func (*StateTransferResponse) Marshal ¶
func (m *StateTransferResponse) Marshal() (dAtA []byte, err error)
func (*StateTransferResponse) MarshalTo ¶
func (m *StateTransferResponse) MarshalTo(dAtA []byte) (int, error)
func (*StateTransferResponse) MarshalToSizedBuffer ¶
func (m *StateTransferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StateTransferResponse) ProtoMessage ¶
func (*StateTransferResponse) ProtoMessage()
func (*StateTransferResponse) Reset ¶
func (m *StateTransferResponse) Reset()
func (*StateTransferResponse) Size ¶
func (m *StateTransferResponse) Size() (n int)
func (*StateTransferResponse) String ¶
func (m *StateTransferResponse) String() string
func (*StateTransferResponse) Unmarshal ¶
func (m *StateTransferResponse) Unmarshal(dAtA []byte) error
func (*StateTransferResponse) XXX_DiscardUnknown ¶
func (m *StateTransferResponse) XXX_DiscardUnknown()
func (*StateTransferResponse) XXX_Marshal ¶
func (m *StateTransferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateTransferResponse) XXX_Merge ¶
func (m *StateTransferResponse) XXX_Merge(src proto.Message)
func (*StateTransferResponse) XXX_Size ¶
func (m *StateTransferResponse) XXX_Size() int
func (*StateTransferResponse) XXX_Unmarshal ¶
func (m *StateTransferResponse) XXX_Unmarshal(b []byte) error
type ViewChange ¶
type ViewChange struct { NextView uint64 `protobuf:"varint,1,opt,name=next_view,json=nextView,proto3" json:"next_view,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` }
func (*ViewChange) Descriptor ¶
func (*ViewChange) Descriptor() ([]byte, []int)
func (*ViewChange) GetNextView ¶
func (m *ViewChange) GetNextView() uint64
func (*ViewChange) GetReason ¶
func (m *ViewChange) GetReason() string
func (*ViewChange) Marshal ¶
func (m *ViewChange) Marshal() (dAtA []byte, err error)
func (*ViewChange) MarshalToSizedBuffer ¶
func (m *ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewChange) ProtoMessage ¶
func (*ViewChange) ProtoMessage()
func (*ViewChange) Reset ¶
func (m *ViewChange) Reset()
func (*ViewChange) Size ¶
func (m *ViewChange) Size() (n int)
func (*ViewChange) String ¶
func (m *ViewChange) String() string
func (*ViewChange) Unmarshal ¶
func (m *ViewChange) Unmarshal(dAtA []byte) error
func (*ViewChange) XXX_DiscardUnknown ¶
func (m *ViewChange) XXX_DiscardUnknown()
func (*ViewChange) XXX_Marshal ¶
func (m *ViewChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewChange) XXX_Merge ¶
func (m *ViewChange) XXX_Merge(src proto.Message)
func (*ViewChange) XXX_Size ¶
func (m *ViewChange) XXX_Size() int
func (*ViewChange) XXX_Unmarshal ¶
func (m *ViewChange) XXX_Unmarshal(b []byte) error
type ViewData ¶
type ViewData struct { NextView uint64 `protobuf:"varint,1,opt,name=next_view,json=nextView,proto3" json:"next_view,omitempty"` LastDecision *Proposal `protobuf:"bytes,2,opt,name=last_decision,json=lastDecision,proto3" json:"last_decision,omitempty"` LastDecisionSignatures []*Signature `` /* 129-byte string literal not displayed */ InFlightProposal *Proposal `protobuf:"bytes,4,opt,name=in_flight_proposal,json=inFlightProposal,proto3" json:"in_flight_proposal,omitempty"` InFlightPrepared bool `protobuf:"varint,5,opt,name=in_flight_prepared,json=inFlightPrepared,proto3" json:"in_flight_prepared,omitempty"` }
func (*ViewData) Descriptor ¶
func (*ViewData) GetInFlightPrepared ¶
func (*ViewData) GetInFlightProposal ¶
func (*ViewData) GetLastDecision ¶
func (*ViewData) GetLastDecisionSignatures ¶
func (*ViewData) GetNextView ¶
func (*ViewData) MarshalToSizedBuffer ¶
func (*ViewData) ProtoMessage ¶
func (*ViewData) ProtoMessage()
func (*ViewData) XXX_DiscardUnknown ¶
func (m *ViewData) XXX_DiscardUnknown()
func (*ViewData) XXX_Marshal ¶
func (*ViewData) XXX_Unmarshal ¶
type ViewMetadata ¶
type ViewMetadata struct { ViewId uint64 `protobuf:"varint,1,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` LatestSequence uint64 `protobuf:"varint,2,opt,name=latest_sequence,json=latestSequence,proto3" json:"latest_sequence,omitempty"` DecisionsInView uint64 `protobuf:"varint,3,opt,name=decisions_in_view,json=decisionsInView,proto3" json:"decisions_in_view,omitempty"` BlackList []uint64 `protobuf:"varint,4,rep,packed,name=black_list,json=blackList,proto3" json:"black_list,omitempty"` PrevCommitSignatureDigest []byte `` /* 140-byte string literal not displayed */ }
func (*ViewMetadata) Descriptor ¶
func (*ViewMetadata) Descriptor() ([]byte, []int)
func (*ViewMetadata) GetBlackList ¶
func (m *ViewMetadata) GetBlackList() []uint64
func (*ViewMetadata) GetDecisionsInView ¶
func (m *ViewMetadata) GetDecisionsInView() uint64
func (*ViewMetadata) GetLatestSequence ¶
func (m *ViewMetadata) GetLatestSequence() uint64
func (*ViewMetadata) GetPrevCommitSignatureDigest ¶
func (m *ViewMetadata) GetPrevCommitSignatureDigest() []byte
func (*ViewMetadata) GetViewId ¶
func (m *ViewMetadata) GetViewId() uint64
func (*ViewMetadata) Marshal ¶
func (m *ViewMetadata) Marshal() (dAtA []byte, err error)
func (*ViewMetadata) MarshalToSizedBuffer ¶
func (m *ViewMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewMetadata) ProtoMessage ¶
func (*ViewMetadata) ProtoMessage()
func (*ViewMetadata) Reset ¶
func (m *ViewMetadata) Reset()
func (*ViewMetadata) Size ¶
func (m *ViewMetadata) Size() (n int)
func (*ViewMetadata) String ¶
func (m *ViewMetadata) String() string
func (*ViewMetadata) Unmarshal ¶
func (m *ViewMetadata) Unmarshal(dAtA []byte) error
func (*ViewMetadata) XXX_DiscardUnknown ¶
func (m *ViewMetadata) XXX_DiscardUnknown()
func (*ViewMetadata) XXX_Marshal ¶
func (m *ViewMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewMetadata) XXX_Merge ¶
func (m *ViewMetadata) XXX_Merge(src proto.Message)
func (*ViewMetadata) XXX_Size ¶
func (m *ViewMetadata) XXX_Size() int
func (*ViewMetadata) XXX_Unmarshal ¶
func (m *ViewMetadata) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.