Documentation ¶
Index ¶
- Variables
- func InstancesEquals(a, b []InstanceID) bool
- func ReplicaIDEquals(a, b []peerpb.PeerID) bool
- func WrapMessageInner(msg proto.Message) isDQPBFTMessage_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) GetInstanceID() InstanceID
- func (m *AgreementMessage) GetType() AgreementMessage_Type
- func (m *AgreementMessage) GetView() View
- 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 DQPBFTMessage
- func (*DQPBFTMessage) Descriptor() ([]byte, []int)
- func (m *DQPBFTMessage) GetAgreement() *AgreementMessage
- func (m *DQPBFTMessage) GetOAgreement() *OAgreementMessage
- func (m *DQPBFTMessage) GetType() isDQPBFTMessage_Type
- func (m *DQPBFTMessage) Marshal() (dAtA []byte, err error)
- func (m *DQPBFTMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *DQPBFTMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DQPBFTMessage) ProtoMessage()
- func (m *DQPBFTMessage) Reset()
- func (m *DQPBFTMessage) Size() (n int)
- func (m *DQPBFTMessage) String() string
- func (m *DQPBFTMessage) Unmarshal(dAtA []byte) error
- func (m *DQPBFTMessage) XXX_DiscardUnknown()
- func (m *DQPBFTMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DQPBFTMessage) XXX_Merge(src proto.Message)
- func (*DQPBFTMessage) XXX_OneofWrappers() []interface{}
- func (m *DQPBFTMessage) XXX_Size() int
- func (m *DQPBFTMessage) XXX_Unmarshal(b []byte) error
- type DQPBFTMessage_Agreement
- type DQPBFTMessage_OAgreement
- type Index
- type InstanceID
- func (*InstanceID) Descriptor() ([]byte, []int)
- func (m InstanceID) Equals(other InstanceID) bool
- func (m *InstanceID) GetIndex() Index
- func (m *InstanceID) GetReplicaID() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
- func (m *InstanceID) Marshal() (dAtA []byte, err error)
- func (m *InstanceID) MarshalTo(dAtA []byte) (int, error)
- func (m *InstanceID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InstanceID) ProtoMessage()
- func (m *InstanceID) Reset()
- func (m *InstanceID) Size() (n int)
- func (m *InstanceID) String() string
- func (m *InstanceID) Unmarshal(dAtA []byte) error
- func (m *InstanceID) XXX_DiscardUnknown()
- func (m *InstanceID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InstanceID) XXX_Merge(src proto.Message)
- func (m *InstanceID) XXX_Size() int
- func (m *InstanceID) XXX_Unmarshal(b []byte) error
- type InstanceState
- func (*InstanceState) Descriptor() ([]byte, []int)
- func (m *InstanceState) GetCommand() *commandpb.Command
- func (m *InstanceState) GetCommandHash() []byte
- func (m *InstanceState) GetInstanceID() InstanceID
- func (m *InstanceState) GetStatus() InstanceState_Status
- func (m *InstanceState) GetView() View
- 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 OAgreementMessage
- func (*OAgreementMessage) Descriptor() ([]byte, []int)
- func (m *OAgreementMessage) Equals(other *OAgreementMessage) bool
- func (m *OAgreementMessage) GetCommandHash() []byte
- func (m *OAgreementMessage) GetIndex() Index
- func (m *OAgreementMessage) GetInstances() []InstanceID
- func (m *OAgreementMessage) GetType() OAgreementMessage_Type
- func (m *OAgreementMessage) GetView() View
- func (m *OAgreementMessage) Marshal() (dAtA []byte, err error)
- func (m *OAgreementMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *OAgreementMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OAgreementMessage) ProtoMessage()
- func (m *OAgreementMessage) Reset()
- func (m *OAgreementMessage) Size() (n int)
- func (m *OAgreementMessage) String() string
- func (m *OAgreementMessage) Unmarshal(dAtA []byte) error
- func (m *OAgreementMessage) XXX_DiscardUnknown()
- func (m *OAgreementMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OAgreementMessage) XXX_Merge(src proto.Message)
- func (m *OAgreementMessage) XXX_Size() int
- func (m *OAgreementMessage) XXX_Unmarshal(b []byte) error
- type OAgreementMessage_Type
- type OInstanceState
- func (*OInstanceState) Descriptor() ([]byte, []int)
- func (m *OInstanceState) GetCommandHash() []byte
- func (m *OInstanceState) GetIndex() Index
- func (m *OInstanceState) GetInstances() []InstanceID
- func (m *OInstanceState) GetStatus() OInstanceState_Status
- func (m *OInstanceState) GetView() View
- func (m *OInstanceState) IsCommitted() bool
- func (m *OInstanceState) IsPrePrepared() bool
- func (m *OInstanceState) IsPrepared() bool
- func (m *OInstanceState) Marshal() (dAtA []byte, err error)
- func (m *OInstanceState) MarshalTo(dAtA []byte) (int, error)
- func (m *OInstanceState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OInstanceState) ProtoMessage()
- func (m *OInstanceState) Reset()
- func (m *OInstanceState) Size() (n int)
- func (m *OInstanceState) String() string
- func (m *OInstanceState) Unmarshal(dAtA []byte) error
- func (m *OInstanceState) XXX_DiscardUnknown()
- func (m *OInstanceState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OInstanceState) XXX_Merge(src proto.Message)
- func (m *OInstanceState) XXX_Size() int
- func (m *OInstanceState) XXX_Unmarshal(b []byte) error
- type OInstanceState_Status
- type View
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthDqpbft = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowDqpbft = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupDqpbft = 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,
}
View Source
var OAgreementMessage_Type_name = map[int32]string{
0: "OPrePrepare",
1: "OPrepare",
2: "OCommit",
}
View Source
var OAgreementMessage_Type_value = map[string]int32{
"OPrePrepare": 0,
"OPrepare": 1,
"OCommit": 2,
}
View Source
var OInstanceState_Status_name = map[int32]string{
0: "None",
1: "OPrePrepared",
2: "OPrepared",
3: "OCommitted",
4: "OExecuted",
}
View Source
var OInstanceState_Status_value = map[string]int32{
"None": 0,
"OPrePrepared": 1,
"OPrepared": 2,
"OCommitted": 3,
"OExecuted": 4,
}
Functions ¶
func InstancesEquals ¶
func InstancesEquals(a, b []InstanceID) bool
func ReplicaIDEquals ¶
func WrapMessageInner ¶
WrapMessageInner wraps a union type of Message in a new isMessage_Type.
Types ¶
type AgreementMessage ¶
type AgreementMessage struct { View View `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"` InstanceID InstanceID `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id"` Type AgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=dqpbftpb.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) GetInstanceID ¶
func (m *AgreementMessage) GetInstanceID() InstanceID
func (*AgreementMessage) GetType ¶
func (m *AgreementMessage) GetType() AgreementMessage_Type
func (*AgreementMessage) GetView ¶
func (m *AgreementMessage) GetView() View
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 DQPBFTMessage ¶
type DQPBFTMessage struct { // Types that are valid to be assigned to Type: // *DQPBFTMessage_Agreement // *DQPBFTMessage_OAgreement Type isDQPBFTMessage_Type `protobuf_oneof:"type"` }
func WrapDQPBFTMessage ¶
func WrapDQPBFTMessage(msg proto.Message) *DQPBFTMessage
WrapDQPBFTMessage wraps a union type of Message in a new PBFTMessage without a destination.
func (*DQPBFTMessage) Descriptor ¶
func (*DQPBFTMessage) Descriptor() ([]byte, []int)
func (*DQPBFTMessage) GetAgreement ¶
func (m *DQPBFTMessage) GetAgreement() *AgreementMessage
func (*DQPBFTMessage) GetOAgreement ¶
func (m *DQPBFTMessage) GetOAgreement() *OAgreementMessage
func (*DQPBFTMessage) GetType ¶
func (m *DQPBFTMessage) GetType() isDQPBFTMessage_Type
func (*DQPBFTMessage) Marshal ¶
func (m *DQPBFTMessage) Marshal() (dAtA []byte, err error)
func (*DQPBFTMessage) MarshalToSizedBuffer ¶
func (m *DQPBFTMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DQPBFTMessage) ProtoMessage ¶
func (*DQPBFTMessage) ProtoMessage()
func (*DQPBFTMessage) Reset ¶
func (m *DQPBFTMessage) Reset()
func (*DQPBFTMessage) Size ¶
func (m *DQPBFTMessage) Size() (n int)
func (*DQPBFTMessage) String ¶
func (m *DQPBFTMessage) String() string
func (*DQPBFTMessage) Unmarshal ¶
func (m *DQPBFTMessage) Unmarshal(dAtA []byte) error
func (*DQPBFTMessage) XXX_DiscardUnknown ¶
func (m *DQPBFTMessage) XXX_DiscardUnknown()
func (*DQPBFTMessage) XXX_Marshal ¶
func (m *DQPBFTMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DQPBFTMessage) XXX_Merge ¶
func (m *DQPBFTMessage) XXX_Merge(src proto.Message)
func (*DQPBFTMessage) XXX_OneofWrappers ¶
func (*DQPBFTMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DQPBFTMessage) XXX_Size ¶
func (m *DQPBFTMessage) XXX_Size() int
func (*DQPBFTMessage) XXX_Unmarshal ¶
func (m *DQPBFTMessage) XXX_Unmarshal(b []byte) error
type DQPBFTMessage_Agreement ¶
type DQPBFTMessage_Agreement struct {
Agreement *AgreementMessage `protobuf:"bytes,1,opt,name=agreement,proto3,oneof" json:"agreement,omitempty"`
}
func (*DQPBFTMessage_Agreement) MarshalTo ¶
func (m *DQPBFTMessage_Agreement) MarshalTo(dAtA []byte) (int, error)
func (*DQPBFTMessage_Agreement) MarshalToSizedBuffer ¶
func (m *DQPBFTMessage_Agreement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DQPBFTMessage_Agreement) Size ¶
func (m *DQPBFTMessage_Agreement) Size() (n int)
type DQPBFTMessage_OAgreement ¶
type DQPBFTMessage_OAgreement struct {
OAgreement *OAgreementMessage `protobuf:"bytes,2,opt,name=o_agreement,json=oAgreement,proto3,oneof" json:"o_agreement,omitempty"`
}
func (*DQPBFTMessage_OAgreement) MarshalTo ¶
func (m *DQPBFTMessage_OAgreement) MarshalTo(dAtA []byte) (int, error)
func (*DQPBFTMessage_OAgreement) MarshalToSizedBuffer ¶
func (m *DQPBFTMessage_OAgreement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DQPBFTMessage_OAgreement) Size ¶
func (m *DQPBFTMessage_OAgreement) Size() (n int)
type InstanceID ¶
type InstanceID struct { ReplicaID github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 153-byte string literal not displayed */ Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` }
func (*InstanceID) Descriptor ¶
func (*InstanceID) Descriptor() ([]byte, []int)
func (InstanceID) Equals ¶
func (m InstanceID) Equals(other InstanceID) bool
func (*InstanceID) GetIndex ¶
func (m *InstanceID) GetIndex() Index
func (*InstanceID) GetReplicaID ¶
func (m *InstanceID) GetReplicaID() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID
func (*InstanceID) Marshal ¶
func (m *InstanceID) Marshal() (dAtA []byte, err error)
func (*InstanceID) MarshalToSizedBuffer ¶
func (m *InstanceID) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InstanceID) ProtoMessage ¶
func (*InstanceID) ProtoMessage()
func (*InstanceID) Reset ¶
func (m *InstanceID) Reset()
func (*InstanceID) Size ¶
func (m *InstanceID) Size() (n int)
func (*InstanceID) String ¶
func (m *InstanceID) String() string
func (*InstanceID) Unmarshal ¶
func (m *InstanceID) Unmarshal(dAtA []byte) error
func (*InstanceID) XXX_DiscardUnknown ¶
func (m *InstanceID) XXX_DiscardUnknown()
func (*InstanceID) XXX_Marshal ¶
func (m *InstanceID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InstanceID) XXX_Merge ¶
func (m *InstanceID) XXX_Merge(src proto.Message)
func (*InstanceID) XXX_Size ¶
func (m *InstanceID) XXX_Size() int
func (*InstanceID) XXX_Unmarshal ¶
func (m *InstanceID) XXX_Unmarshal(b []byte) error
type InstanceState ¶
type InstanceState struct { View View `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"` InstanceID InstanceID `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id"` Status InstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=dqpbftpb.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) GetInstanceID ¶
func (m *InstanceState) GetInstanceID() InstanceID
func (*InstanceState) GetStatus ¶
func (m *InstanceState) GetStatus() InstanceState_Status
func (*InstanceState) GetView ¶
func (m *InstanceState) GetView() View
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 OAgreementMessage ¶
type OAgreementMessage struct { View View `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"` Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Type OAgreementMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=dqpbftpb.OAgreementMessage_Type" json:"type,omitempty"` Instances []InstanceID `protobuf:"bytes,4,rep,name=instances,proto3" json:"instances"` CommandHash []byte `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"` }
func (*OAgreementMessage) Descriptor ¶
func (*OAgreementMessage) Descriptor() ([]byte, []int)
func (*OAgreementMessage) Equals ¶
func (m *OAgreementMessage) Equals(other *OAgreementMessage) bool
func (*OAgreementMessage) GetCommandHash ¶
func (m *OAgreementMessage) GetCommandHash() []byte
func (*OAgreementMessage) GetIndex ¶
func (m *OAgreementMessage) GetIndex() Index
func (*OAgreementMessage) GetInstances ¶
func (m *OAgreementMessage) GetInstances() []InstanceID
func (*OAgreementMessage) GetType ¶
func (m *OAgreementMessage) GetType() OAgreementMessage_Type
func (*OAgreementMessage) GetView ¶
func (m *OAgreementMessage) GetView() View
func (*OAgreementMessage) Marshal ¶
func (m *OAgreementMessage) Marshal() (dAtA []byte, err error)
func (*OAgreementMessage) MarshalTo ¶
func (m *OAgreementMessage) MarshalTo(dAtA []byte) (int, error)
func (*OAgreementMessage) MarshalToSizedBuffer ¶
func (m *OAgreementMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OAgreementMessage) ProtoMessage ¶
func (*OAgreementMessage) ProtoMessage()
func (*OAgreementMessage) Reset ¶
func (m *OAgreementMessage) Reset()
func (*OAgreementMessage) Size ¶
func (m *OAgreementMessage) Size() (n int)
func (*OAgreementMessage) String ¶
func (m *OAgreementMessage) String() string
func (*OAgreementMessage) Unmarshal ¶
func (m *OAgreementMessage) Unmarshal(dAtA []byte) error
func (*OAgreementMessage) XXX_DiscardUnknown ¶
func (m *OAgreementMessage) XXX_DiscardUnknown()
func (*OAgreementMessage) XXX_Marshal ¶
func (m *OAgreementMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OAgreementMessage) XXX_Merge ¶
func (m *OAgreementMessage) XXX_Merge(src proto.Message)
func (*OAgreementMessage) XXX_Size ¶
func (m *OAgreementMessage) XXX_Size() int
func (*OAgreementMessage) XXX_Unmarshal ¶
func (m *OAgreementMessage) XXX_Unmarshal(b []byte) error
type OAgreementMessage_Type ¶
type OAgreementMessage_Type int32
const ( OAgreementMessage_OPrePrepare OAgreementMessage_Type = 0 OAgreementMessage_OPrepare OAgreementMessage_Type = 1 OAgreementMessage_OCommit OAgreementMessage_Type = 2 )
func (OAgreementMessage_Type) EnumDescriptor ¶
func (OAgreementMessage_Type) EnumDescriptor() ([]byte, []int)
func (OAgreementMessage_Type) String ¶
func (x OAgreementMessage_Type) String() string
type OInstanceState ¶
type OInstanceState struct { View View `protobuf:"varint,1,opt,name=view,proto3,casttype=View" json:"view,omitempty"` Index Index `protobuf:"varint,2,opt,name=index,proto3,casttype=Index" json:"index,omitempty"` Status OInstanceState_Status `protobuf:"varint,3,opt,name=status,proto3,enum=dqpbftpb.OInstanceState_Status" json:"status,omitempty"` Instances []InstanceID `protobuf:"bytes,4,rep,name=instances,proto3" json:"instances"` CommandHash []byte `protobuf:"bytes,5,opt,name=command_hash,json=commandHash,proto3" json:"command_hash,omitempty"` }
func (*OInstanceState) Descriptor ¶
func (*OInstanceState) Descriptor() ([]byte, []int)
func (*OInstanceState) GetCommandHash ¶
func (m *OInstanceState) GetCommandHash() []byte
func (*OInstanceState) GetIndex ¶
func (m *OInstanceState) GetIndex() Index
func (*OInstanceState) GetInstances ¶
func (m *OInstanceState) GetInstances() []InstanceID
func (*OInstanceState) GetStatus ¶
func (m *OInstanceState) GetStatus() OInstanceState_Status
func (*OInstanceState) GetView ¶
func (m *OInstanceState) GetView() View
func (*OInstanceState) IsCommitted ¶
func (m *OInstanceState) IsCommitted() bool
func (*OInstanceState) IsPrePrepared ¶
func (m *OInstanceState) IsPrePrepared() bool
func (*OInstanceState) IsPrepared ¶
func (m *OInstanceState) IsPrepared() bool
func (*OInstanceState) Marshal ¶
func (m *OInstanceState) Marshal() (dAtA []byte, err error)
func (*OInstanceState) MarshalToSizedBuffer ¶
func (m *OInstanceState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OInstanceState) ProtoMessage ¶
func (*OInstanceState) ProtoMessage()
func (*OInstanceState) Reset ¶
func (m *OInstanceState) Reset()
func (*OInstanceState) Size ¶
func (m *OInstanceState) Size() (n int)
func (*OInstanceState) String ¶
func (m *OInstanceState) String() string
func (*OInstanceState) Unmarshal ¶
func (m *OInstanceState) Unmarshal(dAtA []byte) error
func (*OInstanceState) XXX_DiscardUnknown ¶
func (m *OInstanceState) XXX_DiscardUnknown()
func (*OInstanceState) XXX_Marshal ¶
func (m *OInstanceState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OInstanceState) XXX_Merge ¶
func (m *OInstanceState) XXX_Merge(src proto.Message)
func (*OInstanceState) XXX_Size ¶
func (m *OInstanceState) XXX_Size() int
func (*OInstanceState) XXX_Unmarshal ¶
func (m *OInstanceState) XXX_Unmarshal(b []byte) error
type OInstanceState_Status ¶
type OInstanceState_Status int32
const ( OInstanceState_None OInstanceState_Status = 0 OInstanceState_OPrePrepared OInstanceState_Status = 1 OInstanceState_OPrepared OInstanceState_Status = 2 OInstanceState_OCommitted OInstanceState_Status = 3 OInstanceState_OExecuted OInstanceState_Status = 4 )
func (OInstanceState_Status) EnumDescriptor ¶
func (OInstanceState_Status) EnumDescriptor() ([]byte, []int)
func (OInstanceState_Status) String ¶
func (x OInstanceState_Status) String() string
Click to show internal directories.
Click to hide internal directories.