Documentation ¶
Index ¶
- Variables
- func WrapMessageInner(msg proto.Message) isMirBFTMessage_Type
- type AgreementMessage
- func (*AgreementMessage) Descriptor() ([]byte, []int)
- func (m *AgreementMessage) Equals(other *AgreementMessage) bool
- func (m *AgreementMessage) GetCommand() *commandpb.Command
- func (m *AgreementMessage) GetCommandHash() []byte
- func (m *AgreementMessage) GetEpoch() Epoch
- func (m *AgreementMessage) GetIndex() Index
- func (m *AgreementMessage) GetType() AgreementMessage_Type
- func (m *AgreementMessage) Marshal() (dAtA []byte, err error)
- func (m *AgreementMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *AgreementMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AgreementMessage) ProtoMessage()
- func (m *AgreementMessage) Reset()
- func (m *AgreementMessage) Size() (n int)
- func (m *AgreementMessage) String() string
- func (m *AgreementMessage) Unmarshal(dAtA []byte) error
- func (m *AgreementMessage) XXX_DiscardUnknown()
- func (m *AgreementMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AgreementMessage) XXX_Merge(src proto.Message)
- func (m *AgreementMessage) XXX_Size() int
- func (m *AgreementMessage) XXX_Unmarshal(b []byte) error
- type AgreementMessage_Type
- type Epoch
- type EpochChangeAckMessage
- func (*EpochChangeAckMessage) Descriptor() ([]byte, []int)
- func (m *EpochChangeAckMessage) GetAckFor() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
- func (m *EpochChangeAckMessage) GetDigest() []byte
- func (m *EpochChangeAckMessage) GetNewEpoch() Epoch
- func (m *EpochChangeAckMessage) Marshal() (dAtA []byte, err error)
- func (m *EpochChangeAckMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *EpochChangeAckMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EpochChangeAckMessage) ProtoMessage()
- func (m *EpochChangeAckMessage) Reset()
- func (m *EpochChangeAckMessage) Size() (n int)
- func (m *EpochChangeAckMessage) String() string
- func (m *EpochChangeAckMessage) Unmarshal(dAtA []byte) error
- func (m *EpochChangeAckMessage) XXX_DiscardUnknown()
- func (m *EpochChangeAckMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EpochChangeAckMessage) XXX_Merge(src proto.Message)
- func (m *EpochChangeAckMessage) XXX_Size() int
- func (m *EpochChangeAckMessage) XXX_Unmarshal(b []byte) error
- type EpochChangeMessage
- func (*EpochChangeMessage) Descriptor() ([]byte, []int)
- func (m *EpochChangeMessage) GetHighIndex() Index
- func (m *EpochChangeMessage) GetLowIndex() Index
- func (m *EpochChangeMessage) GetNewEpoch() Epoch
- func (m *EpochChangeMessage) GetPSet() []InstanceState
- func (m *EpochChangeMessage) GetQSet() []InstanceState
- func (m *EpochChangeMessage) Marshal() (dAtA []byte, err error)
- func (m *EpochChangeMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *EpochChangeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EpochChangeMessage) ProtoMessage()
- func (m *EpochChangeMessage) Reset()
- func (m *EpochChangeMessage) Size() (n int)
- func (m *EpochChangeMessage) String() string
- func (m *EpochChangeMessage) Unmarshal(dAtA []byte) error
- func (m *EpochChangeMessage) XXX_DiscardUnknown()
- func (m *EpochChangeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EpochChangeMessage) XXX_Merge(src proto.Message)
- func (m *EpochChangeMessage) XXX_Size() int
- func (m *EpochChangeMessage) XXX_Unmarshal(b []byte) error
- type Index
- type InstanceState
- func (*InstanceState) Descriptor() ([]byte, []int)
- func (m *InstanceState) GetCommand() *commandpb.Command
- func (m *InstanceState) GetCommandHash() []byte
- func (m *InstanceState) GetEpoch() Epoch
- func (m *InstanceState) GetIndex() Index
- func (m *InstanceState) GetStatus() InstanceState_Status
- func (m *InstanceState) IsAtleastPrePrepared() bool
- func (m *InstanceState) IsAtleastPrepared() bool
- func (m *InstanceState) IsCommitted() bool
- func (m *InstanceState) IsPrePrepared() bool
- func (m *InstanceState) IsPrepared() bool
- func (m *InstanceState) Marshal() (dAtA []byte, err error)
- func (m *InstanceState) MarshalTo(dAtA []byte) (int, error)
- func (m *InstanceState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InstanceState) ProtoMessage()
- func (m *InstanceState) Reset()
- func (m *InstanceState) Size() (n int)
- func (m *InstanceState) String() string
- func (m *InstanceState) Unmarshal(dAtA []byte) error
- func (m *InstanceState) XXX_DiscardUnknown()
- func (m *InstanceState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstanceState) XXX_Merge(src proto.Message)
- func (m *InstanceState) XXX_Size() int
- func (m *InstanceState) XXX_Unmarshal(b []byte) error
- type InstanceState_Status
- type MirBFTMessage
- func (*MirBFTMessage) Descriptor() ([]byte, []int)
- func (m *MirBFTMessage) GetAgreement() *AgreementMessage
- func (m *MirBFTMessage) GetEpochChange() *EpochChangeMessage
- func (m *MirBFTMessage) GetEpochChangeAck() *EpochChangeAckMessage
- func (m *MirBFTMessage) GetNewEpoch() *NewEpochMessage
- func (m *MirBFTMessage) GetType() isMirBFTMessage_Type
- func (m *MirBFTMessage) Marshal() (dAtA []byte, err error)
- func (m *MirBFTMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *MirBFTMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MirBFTMessage) ProtoMessage()
- func (m *MirBFTMessage) Reset()
- func (m *MirBFTMessage) Size() (n int)
- func (m *MirBFTMessage) String() string
- func (m *MirBFTMessage) Unmarshal(dAtA []byte) error
- func (m *MirBFTMessage) XXX_DiscardUnknown()
- func (m *MirBFTMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MirBFTMessage) XXX_Merge(src proto.Message)
- func (*MirBFTMessage) XXX_OneofWrappers() []interface{}
- func (m *MirBFTMessage) XXX_Size() int
- func (m *MirBFTMessage) XXX_Unmarshal(b []byte) error
- type MirBFTMessage_Agreement
- type MirBFTMessage_EpochChange
- type MirBFTMessage_EpochChangeAck
- type MirBFTMessage_NewEpoch
- type NewEpochMessage
- func (*NewEpochMessage) Descriptor() ([]byte, []int)
- func (m *NewEpochMessage) GetInstances() map[Index]InstanceState
- func (m *NewEpochMessage) GetNewEpoch() Epoch
- func (m *NewEpochMessage) GetNvProof() []NewEpochProof
- func (m *NewEpochMessage) Marshal() (dAtA []byte, err error)
- func (m *NewEpochMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *NewEpochMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NewEpochMessage) ProtoMessage()
- func (m *NewEpochMessage) Reset()
- func (m *NewEpochMessage) Size() (n int)
- func (m *NewEpochMessage) String() string
- func (m *NewEpochMessage) Unmarshal(dAtA []byte) error
- func (m *NewEpochMessage) XXX_DiscardUnknown()
- func (m *NewEpochMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewEpochMessage) XXX_Merge(src proto.Message)
- func (m *NewEpochMessage) XXX_Size() int
- func (m *NewEpochMessage) XXX_Unmarshal(b []byte) error
- type NewEpochProof
- func (*NewEpochProof) Descriptor() ([]byte, []int)
- func (m *NewEpochProof) GetAckFor() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
- func (m *NewEpochProof) GetDigest() []byte
- func (m *NewEpochProof) Marshal() (dAtA []byte, err error)
- func (m *NewEpochProof) MarshalTo(dAtA []byte) (int, error)
- func (m *NewEpochProof) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NewEpochProof) ProtoMessage()
- func (m *NewEpochProof) Reset()
- func (m *NewEpochProof) Size() (n int)
- func (m *NewEpochProof) String() string
- func (m *NewEpochProof) Unmarshal(dAtA []byte) error
- func (m *NewEpochProof) XXX_DiscardUnknown()
- func (m *NewEpochProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewEpochProof) XXX_Merge(src proto.Message)
- func (m *NewEpochProof) XXX_Size() int
- func (m *NewEpochProof) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMirbft = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMirbft = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMirbft = fmt.Errorf("proto: unexpected end of group") )
View Source
var AgreementMessage_Type_name = map[int32]string{
0: "PrePrepare",
1: "Prepare",
2: "Commit",
}
View Source
var AgreementMessage_Type_value = map[string]int32{
"PrePrepare": 0,
"Prepare": 1,
"Commit": 2,
}
View Source
var InstanceState_Status_name = map[int32]string{
0: "None",
1: "PrePrepared",
2: "Prepared",
3: "Committed",
4: "Executed",
}
View Source
var InstanceState_Status_value = map[string]int32{
"None": 0,
"PrePrepared": 1,
"Prepared": 2,
"Committed": 3,
"Executed": 4,
}
Functions ¶
func WrapMessageInner ¶
WrapMessageInner wraps a union type of Message in a new isMessage_Type.
Types ¶
type AgreementMessage ¶
type AgreementMessage struct { Epoch Epoch `protobuf:"varint,1,opt,name=epoch,proto3,casttype=Epoch" json:"epoch,omitempty"` Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Type AgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=mirbftpb.AgreementMessage_Type" json:"type,omitempty"` Command *commandpb.Command `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` CommandHash []byte `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"` }
func (*AgreementMessage) Descriptor ¶
func (*AgreementMessage) Descriptor() ([]byte, []int)
func (*AgreementMessage) Equals ¶
func (m *AgreementMessage) Equals(other *AgreementMessage) bool
func (*AgreementMessage) GetCommand ¶
func (m *AgreementMessage) GetCommand() *commandpb.Command
func (*AgreementMessage) GetCommandHash ¶
func (m *AgreementMessage) GetCommandHash() []byte
func (*AgreementMessage) GetEpoch ¶
func (m *AgreementMessage) GetEpoch() Epoch
func (*AgreementMessage) GetIndex ¶
func (m *AgreementMessage) GetIndex() Index
func (*AgreementMessage) GetType ¶
func (m *AgreementMessage) GetType() AgreementMessage_Type
func (*AgreementMessage) Marshal ¶
func (m *AgreementMessage) Marshal() (dAtA []byte, err error)
func (*AgreementMessage) MarshalToSizedBuffer ¶
func (m *AgreementMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AgreementMessage) ProtoMessage ¶
func (*AgreementMessage) ProtoMessage()
func (*AgreementMessage) Reset ¶
func (m *AgreementMessage) Reset()
func (*AgreementMessage) Size ¶
func (m *AgreementMessage) Size() (n int)
func (*AgreementMessage) String ¶
func (m *AgreementMessage) String() string
func (*AgreementMessage) Unmarshal ¶
func (m *AgreementMessage) Unmarshal(dAtA []byte) error
func (*AgreementMessage) XXX_DiscardUnknown ¶
func (m *AgreementMessage) XXX_DiscardUnknown()
func (*AgreementMessage) XXX_Marshal ¶
func (m *AgreementMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AgreementMessage) XXX_Merge ¶
func (m *AgreementMessage) XXX_Merge(src proto.Message)
func (*AgreementMessage) XXX_Size ¶
func (m *AgreementMessage) XXX_Size() int
func (*AgreementMessage) XXX_Unmarshal ¶
func (m *AgreementMessage) XXX_Unmarshal(b []byte) error
type AgreementMessage_Type ¶
type AgreementMessage_Type int32
const ( AgreementMessage_PrePrepare AgreementMessage_Type = 0 AgreementMessage_Prepare AgreementMessage_Type = 1 AgreementMessage_Commit AgreementMessage_Type = 2 )
func (AgreementMessage_Type) EnumDescriptor ¶
func (AgreementMessage_Type) EnumDescriptor() ([]byte, []int)
func (AgreementMessage_Type) String ¶
func (x AgreementMessage_Type) String() string
type EpochChangeAckMessage ¶
type EpochChangeAckMessage struct { NewEpoch Epoch `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"` AckFor github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-byte string literal not displayed */ Digest []byte `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"` }
func (*EpochChangeAckMessage) Descriptor ¶
func (*EpochChangeAckMessage) Descriptor() ([]byte, []int)
func (*EpochChangeAckMessage) GetAckFor ¶
func (m *EpochChangeAckMessage) GetAckFor() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
func (*EpochChangeAckMessage) GetDigest ¶
func (m *EpochChangeAckMessage) GetDigest() []byte
func (*EpochChangeAckMessage) GetNewEpoch ¶
func (m *EpochChangeAckMessage) GetNewEpoch() Epoch
func (*EpochChangeAckMessage) Marshal ¶
func (m *EpochChangeAckMessage) Marshal() (dAtA []byte, err error)
func (*EpochChangeAckMessage) MarshalTo ¶
func (m *EpochChangeAckMessage) MarshalTo(dAtA []byte) (int, error)
func (*EpochChangeAckMessage) MarshalToSizedBuffer ¶
func (m *EpochChangeAckMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EpochChangeAckMessage) ProtoMessage ¶
func (*EpochChangeAckMessage) ProtoMessage()
func (*EpochChangeAckMessage) Reset ¶
func (m *EpochChangeAckMessage) Reset()
func (*EpochChangeAckMessage) Size ¶
func (m *EpochChangeAckMessage) Size() (n int)
func (*EpochChangeAckMessage) String ¶
func (m *EpochChangeAckMessage) String() string
func (*EpochChangeAckMessage) Unmarshal ¶
func (m *EpochChangeAckMessage) Unmarshal(dAtA []byte) error
func (*EpochChangeAckMessage) XXX_DiscardUnknown ¶
func (m *EpochChangeAckMessage) XXX_DiscardUnknown()
func (*EpochChangeAckMessage) XXX_Marshal ¶
func (m *EpochChangeAckMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EpochChangeAckMessage) XXX_Merge ¶
func (m *EpochChangeAckMessage) XXX_Merge(src proto.Message)
func (*EpochChangeAckMessage) XXX_Size ¶
func (m *EpochChangeAckMessage) XXX_Size() int
func (*EpochChangeAckMessage) XXX_Unmarshal ¶
func (m *EpochChangeAckMessage) XXX_Unmarshal(b []byte) error
type EpochChangeMessage ¶
type EpochChangeMessage struct { NewEpoch Epoch `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"` LowIndex Index `protobuf:"varint,2,opt,name=low_index,json=lowIndex,proto3,casttype=Index" json:"low_index,omitempty"` HighIndex Index `protobuf:"varint,3,opt,name=high_index,json=highIndex,proto3,casttype=Index" json:"high_index,omitempty"` PSet []InstanceState `protobuf:"bytes,4,rep,name=p_set,json=pSet,proto3" json:"p_set"` QSet []InstanceState `protobuf:"bytes,5,rep,name=q_set,json=qSet,proto3" json:"q_set"` }
func (*EpochChangeMessage) Descriptor ¶
func (*EpochChangeMessage) Descriptor() ([]byte, []int)
func (*EpochChangeMessage) GetHighIndex ¶
func (m *EpochChangeMessage) GetHighIndex() Index
func (*EpochChangeMessage) GetLowIndex ¶
func (m *EpochChangeMessage) GetLowIndex() Index
func (*EpochChangeMessage) GetNewEpoch ¶
func (m *EpochChangeMessage) GetNewEpoch() Epoch
func (*EpochChangeMessage) GetPSet ¶
func (m *EpochChangeMessage) GetPSet() []InstanceState
func (*EpochChangeMessage) GetQSet ¶
func (m *EpochChangeMessage) GetQSet() []InstanceState
func (*EpochChangeMessage) Marshal ¶
func (m *EpochChangeMessage) Marshal() (dAtA []byte, err error)
func (*EpochChangeMessage) MarshalTo ¶
func (m *EpochChangeMessage) MarshalTo(dAtA []byte) (int, error)
func (*EpochChangeMessage) MarshalToSizedBuffer ¶
func (m *EpochChangeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EpochChangeMessage) ProtoMessage ¶
func (*EpochChangeMessage) ProtoMessage()
func (*EpochChangeMessage) Reset ¶
func (m *EpochChangeMessage) Reset()
func (*EpochChangeMessage) Size ¶
func (m *EpochChangeMessage) Size() (n int)
func (*EpochChangeMessage) String ¶
func (m *EpochChangeMessage) String() string
func (*EpochChangeMessage) Unmarshal ¶
func (m *EpochChangeMessage) Unmarshal(dAtA []byte) error
func (*EpochChangeMessage) XXX_DiscardUnknown ¶
func (m *EpochChangeMessage) XXX_DiscardUnknown()
func (*EpochChangeMessage) XXX_Marshal ¶
func (m *EpochChangeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EpochChangeMessage) XXX_Merge ¶
func (m *EpochChangeMessage) XXX_Merge(src proto.Message)
func (*EpochChangeMessage) XXX_Size ¶
func (m *EpochChangeMessage) XXX_Size() int
func (*EpochChangeMessage) XXX_Unmarshal ¶
func (m *EpochChangeMessage) XXX_Unmarshal(b []byte) error
type InstanceState ¶
type InstanceState struct { Epoch Epoch `protobuf:"varint,1,opt,name=epoch,proto3,casttype=Epoch" json:"epoch,omitempty"` Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Status InstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=mirbftpb.InstanceState_Status" json:"status,omitempty"` Command *commandpb.Command `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` CommandHash []byte `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"` }
func (*InstanceState) Descriptor ¶
func (*InstanceState) Descriptor() ([]byte, []int)
func (*InstanceState) GetCommand ¶
func (m *InstanceState) GetCommand() *commandpb.Command
func (*InstanceState) GetCommandHash ¶
func (m *InstanceState) GetCommandHash() []byte
func (*InstanceState) GetEpoch ¶
func (m *InstanceState) GetEpoch() Epoch
func (*InstanceState) GetIndex ¶
func (m *InstanceState) GetIndex() Index
func (*InstanceState) GetStatus ¶
func (m *InstanceState) GetStatus() InstanceState_Status
func (*InstanceState) IsAtleastPrePrepared ¶
func (m *InstanceState) IsAtleastPrePrepared() bool
func (*InstanceState) IsAtleastPrepared ¶
func (m *InstanceState) IsAtleastPrepared() bool
func (*InstanceState) IsCommitted ¶
func (m *InstanceState) IsCommitted() bool
func (*InstanceState) IsPrePrepared ¶
func (m *InstanceState) IsPrePrepared() bool
func (*InstanceState) IsPrepared ¶
func (m *InstanceState) IsPrepared() bool
func (*InstanceState) Marshal ¶
func (m *InstanceState) Marshal() (dAtA []byte, err error)
func (*InstanceState) MarshalToSizedBuffer ¶
func (m *InstanceState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InstanceState) ProtoMessage ¶
func (*InstanceState) ProtoMessage()
func (*InstanceState) Reset ¶
func (m *InstanceState) Reset()
func (*InstanceState) Size ¶
func (m *InstanceState) Size() (n int)
func (*InstanceState) String ¶
func (m *InstanceState) String() string
func (*InstanceState) Unmarshal ¶
func (m *InstanceState) Unmarshal(dAtA []byte) error
func (*InstanceState) XXX_DiscardUnknown ¶
func (m *InstanceState) XXX_DiscardUnknown()
func (*InstanceState) XXX_Marshal ¶
func (m *InstanceState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstanceState) XXX_Merge ¶
func (m *InstanceState) XXX_Merge(src proto.Message)
func (*InstanceState) XXX_Size ¶
func (m *InstanceState) XXX_Size() int
func (*InstanceState) XXX_Unmarshal ¶
func (m *InstanceState) XXX_Unmarshal(b []byte) error
type InstanceState_Status ¶
type InstanceState_Status int32
const ( InstanceState_None InstanceState_Status = 0 InstanceState_PrePrepared InstanceState_Status = 1 InstanceState_Prepared InstanceState_Status = 2 InstanceState_Committed InstanceState_Status = 3 InstanceState_Executed InstanceState_Status = 4 )
func (InstanceState_Status) EnumDescriptor ¶
func (InstanceState_Status) EnumDescriptor() ([]byte, []int)
func (InstanceState_Status) String ¶
func (x InstanceState_Status) String() string
type MirBFTMessage ¶
type MirBFTMessage struct { // Types that are valid to be assigned to Type: // *MirBFTMessage_Agreement // *MirBFTMessage_EpochChange // *MirBFTMessage_EpochChangeAck // *MirBFTMessage_NewEpoch Type isMirBFTMessage_Type `protobuf_oneof:"type"` }
func WrapMirBFTMessage ¶
func WrapMirBFTMessage(msg proto.Message) *MirBFTMessage
WrapMirBFTMessage wraps a union type of Message in a new PBFTMessage without a destination.
func (*MirBFTMessage) Descriptor ¶
func (*MirBFTMessage) Descriptor() ([]byte, []int)
func (*MirBFTMessage) GetAgreement ¶
func (m *MirBFTMessage) GetAgreement() *AgreementMessage
func (*MirBFTMessage) GetEpochChange ¶
func (m *MirBFTMessage) GetEpochChange() *EpochChangeMessage
func (*MirBFTMessage) GetEpochChangeAck ¶
func (m *MirBFTMessage) GetEpochChangeAck() *EpochChangeAckMessage
func (*MirBFTMessage) GetNewEpoch ¶
func (m *MirBFTMessage) GetNewEpoch() *NewEpochMessage
func (*MirBFTMessage) GetType ¶
func (m *MirBFTMessage) GetType() isMirBFTMessage_Type
func (*MirBFTMessage) Marshal ¶
func (m *MirBFTMessage) Marshal() (dAtA []byte, err error)
func (*MirBFTMessage) MarshalToSizedBuffer ¶
func (m *MirBFTMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MirBFTMessage) ProtoMessage ¶
func (*MirBFTMessage) ProtoMessage()
func (*MirBFTMessage) Reset ¶
func (m *MirBFTMessage) Reset()
func (*MirBFTMessage) Size ¶
func (m *MirBFTMessage) Size() (n int)
func (*MirBFTMessage) String ¶
func (m *MirBFTMessage) String() string
func (*MirBFTMessage) Unmarshal ¶
func (m *MirBFTMessage) Unmarshal(dAtA []byte) error
func (*MirBFTMessage) XXX_DiscardUnknown ¶
func (m *MirBFTMessage) XXX_DiscardUnknown()
func (*MirBFTMessage) XXX_Marshal ¶
func (m *MirBFTMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MirBFTMessage) XXX_Merge ¶
func (m *MirBFTMessage) XXX_Merge(src proto.Message)
func (*MirBFTMessage) XXX_OneofWrappers ¶
func (*MirBFTMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*MirBFTMessage) XXX_Size ¶
func (m *MirBFTMessage) XXX_Size() int
func (*MirBFTMessage) XXX_Unmarshal ¶
func (m *MirBFTMessage) XXX_Unmarshal(b []byte) error
type MirBFTMessage_Agreement ¶
type MirBFTMessage_Agreement struct {
Agreement *AgreementMessage `protobuf:"bytes,1,opt,name=agreement,proto3,oneof" json:"agreement,omitempty"`
}
func (*MirBFTMessage_Agreement) MarshalTo ¶
func (m *MirBFTMessage_Agreement) MarshalTo(dAtA []byte) (int, error)
func (*MirBFTMessage_Agreement) MarshalToSizedBuffer ¶
func (m *MirBFTMessage_Agreement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MirBFTMessage_Agreement) Size ¶
func (m *MirBFTMessage_Agreement) Size() (n int)
type MirBFTMessage_EpochChange ¶
type MirBFTMessage_EpochChange struct {
EpochChange *EpochChangeMessage `protobuf:"bytes,2,opt,name=epoch_change,json=epochChange,proto3,oneof" json:"epoch_change,omitempty"`
}
func (*MirBFTMessage_EpochChange) MarshalTo ¶
func (m *MirBFTMessage_EpochChange) MarshalTo(dAtA []byte) (int, error)
func (*MirBFTMessage_EpochChange) MarshalToSizedBuffer ¶
func (m *MirBFTMessage_EpochChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MirBFTMessage_EpochChange) Size ¶
func (m *MirBFTMessage_EpochChange) Size() (n int)
type MirBFTMessage_EpochChangeAck ¶
type MirBFTMessage_EpochChangeAck struct {
EpochChangeAck *EpochChangeAckMessage `protobuf:"bytes,3,opt,name=epoch_change_ack,json=epochChangeAck,proto3,oneof" json:"epoch_change_ack,omitempty"`
}
func (*MirBFTMessage_EpochChangeAck) MarshalTo ¶
func (m *MirBFTMessage_EpochChangeAck) MarshalTo(dAtA []byte) (int, error)
func (*MirBFTMessage_EpochChangeAck) MarshalToSizedBuffer ¶
func (m *MirBFTMessage_EpochChangeAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MirBFTMessage_EpochChangeAck) Size ¶
func (m *MirBFTMessage_EpochChangeAck) Size() (n int)
type MirBFTMessage_NewEpoch ¶
type MirBFTMessage_NewEpoch struct {
NewEpoch *NewEpochMessage `protobuf:"bytes,4,opt,name=new_epoch,json=newEpoch,proto3,oneof" json:"new_epoch,omitempty"`
}
func (*MirBFTMessage_NewEpoch) MarshalTo ¶
func (m *MirBFTMessage_NewEpoch) MarshalTo(dAtA []byte) (int, error)
func (*MirBFTMessage_NewEpoch) MarshalToSizedBuffer ¶
func (m *MirBFTMessage_NewEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MirBFTMessage_NewEpoch) Size ¶
func (m *MirBFTMessage_NewEpoch) Size() (n int)
type NewEpochMessage ¶
type NewEpochMessage struct { NewEpoch Epoch `protobuf:"varint,1,opt,name=new_epoch,json=newEpoch,proto3,casttype=Epoch" json:"new_epoch,omitempty"` NvProof []NewEpochProof `protobuf:"bytes,2,rep,name=nv_proof,json=nvProof,proto3" json:"nv_proof"` Instances map[Index]InstanceState `` /* 164-byte string literal not displayed */ }
func (*NewEpochMessage) Descriptor ¶
func (*NewEpochMessage) Descriptor() ([]byte, []int)
func (*NewEpochMessage) GetInstances ¶
func (m *NewEpochMessage) GetInstances() map[Index]InstanceState
func (*NewEpochMessage) GetNewEpoch ¶
func (m *NewEpochMessage) GetNewEpoch() Epoch
func (*NewEpochMessage) GetNvProof ¶
func (m *NewEpochMessage) GetNvProof() []NewEpochProof
func (*NewEpochMessage) Marshal ¶
func (m *NewEpochMessage) Marshal() (dAtA []byte, err error)
func (*NewEpochMessage) MarshalToSizedBuffer ¶
func (m *NewEpochMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NewEpochMessage) ProtoMessage ¶
func (*NewEpochMessage) ProtoMessage()
func (*NewEpochMessage) Reset ¶
func (m *NewEpochMessage) Reset()
func (*NewEpochMessage) Size ¶
func (m *NewEpochMessage) Size() (n int)
func (*NewEpochMessage) String ¶
func (m *NewEpochMessage) String() string
func (*NewEpochMessage) Unmarshal ¶
func (m *NewEpochMessage) Unmarshal(dAtA []byte) error
func (*NewEpochMessage) XXX_DiscardUnknown ¶
func (m *NewEpochMessage) XXX_DiscardUnknown()
func (*NewEpochMessage) XXX_Marshal ¶
func (m *NewEpochMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewEpochMessage) XXX_Merge ¶
func (m *NewEpochMessage) XXX_Merge(src proto.Message)
func (*NewEpochMessage) XXX_Size ¶
func (m *NewEpochMessage) XXX_Size() int
func (*NewEpochMessage) XXX_Unmarshal ¶
func (m *NewEpochMessage) XXX_Unmarshal(b []byte) error
type NewEpochProof ¶
type NewEpochProof struct { AckFor github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-byte string literal not displayed */ Digest []byte `protobuf:"bytes,3,opt,name=digest,proto3" json:"digest,omitempty"` }
func (*NewEpochProof) Descriptor ¶
func (*NewEpochProof) Descriptor() ([]byte, []int)
func (*NewEpochProof) GetAckFor ¶
func (m *NewEpochProof) GetAckFor() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
func (*NewEpochProof) GetDigest ¶
func (m *NewEpochProof) GetDigest() []byte
func (*NewEpochProof) Marshal ¶
func (m *NewEpochProof) Marshal() (dAtA []byte, err error)
func (*NewEpochProof) MarshalToSizedBuffer ¶
func (m *NewEpochProof) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NewEpochProof) ProtoMessage ¶
func (*NewEpochProof) ProtoMessage()
func (*NewEpochProof) Reset ¶
func (m *NewEpochProof) Reset()
func (*NewEpochProof) Size ¶
func (m *NewEpochProof) Size() (n int)
func (*NewEpochProof) String ¶
func (m *NewEpochProof) String() string
func (*NewEpochProof) Unmarshal ¶
func (m *NewEpochProof) Unmarshal(dAtA []byte) error
func (*NewEpochProof) XXX_DiscardUnknown ¶
func (m *NewEpochProof) XXX_DiscardUnknown()
func (*NewEpochProof) XXX_Marshal ¶
func (m *NewEpochProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewEpochProof) XXX_Merge ¶
func (m *NewEpochProof) XXX_Merge(src proto.Message)
func (*NewEpochProof) XXX_Size ¶
func (m *NewEpochProof) XXX_Size() int
func (*NewEpochProof) XXX_Unmarshal ¶
func (m *NewEpochProof) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.