Documentation ¶
Index ¶
- Variables
- func InstancesEquals(a, b []InstanceID) bool
- func WrapMessageInner(msg proto.Message) isHybsterxMessage_Type
- type HybsterxMessage
- func (*HybsterxMessage) Descriptor() ([]byte, []int)
- func (m *HybsterxMessage) GetNormal() *NormalMessage
- func (m *HybsterxMessage) GetONormal() *ONormalMessage
- func (m *HybsterxMessage) GetType() isHybsterxMessage_Type
- func (m *HybsterxMessage) Marshal() (dAtA []byte, err error)
- func (m *HybsterxMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *HybsterxMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HybsterxMessage) ProtoMessage()
- func (m *HybsterxMessage) Reset()
- func (m *HybsterxMessage) Size() (n int)
- func (m *HybsterxMessage) String() string
- func (m *HybsterxMessage) Unmarshal(dAtA []byte) error
- func (m *HybsterxMessage) XXX_DiscardUnknown()
- func (m *HybsterxMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HybsterxMessage) XXX_Merge(src proto.Message)
- func (*HybsterxMessage) XXX_OneofWrappers() []interface{}
- func (m *HybsterxMessage) XXX_Size() int
- func (m *HybsterxMessage) XXX_Unmarshal(b []byte) error
- type HybsterxMessage_Normal
- type HybsterxMessage_ONormal
- type Index
- type InstanceID
- func (*InstanceID) Descriptor() ([]byte, []int)
- func (m InstanceID) Equals(other InstanceID) bool
- func (m *InstanceID) GetIndex() Index
- func (m *InstanceID) GetPeerID() 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) 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 NormalMessage
- func (*NormalMessage) Descriptor() ([]byte, []int)
- func (m *NormalMessage) Equals(other *NormalMessage) bool
- func (m *NormalMessage) GetCommand() *commandpb.Command
- func (m *NormalMessage) GetCommandHash() []byte
- func (m *NormalMessage) GetInstanceID() InstanceID
- func (m *NormalMessage) GetType() NormalMessage_Type
- func (m *NormalMessage) GetView() View
- func (m *NormalMessage) Marshal() (dAtA []byte, err error)
- func (m *NormalMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *NormalMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NormalMessage) ProtoMessage()
- func (m *NormalMessage) Reset()
- func (m *NormalMessage) Size() (n int)
- func (m *NormalMessage) String() string
- func (m *NormalMessage) Unmarshal(dAtA []byte) error
- func (m *NormalMessage) XXX_DiscardUnknown()
- func (m *NormalMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NormalMessage) XXX_Merge(src proto.Message)
- func (m *NormalMessage) XXX_Size() int
- func (m *NormalMessage) XXX_Unmarshal(b []byte) error
- type NormalMessage_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) 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 ONormalMessage
- func (*ONormalMessage) Descriptor() ([]byte, []int)
- func (m *ONormalMessage) Equals(other *ONormalMessage) bool
- func (m *ONormalMessage) GetCommandHash() []byte
- func (m *ONormalMessage) GetIndex() Index
- func (m *ONormalMessage) GetInstances() []InstanceID
- func (m *ONormalMessage) GetType() ONormalMessage_Type
- func (m *ONormalMessage) GetView() View
- func (m *ONormalMessage) Marshal() (dAtA []byte, err error)
- func (m *ONormalMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *ONormalMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ONormalMessage) ProtoMessage()
- func (m *ONormalMessage) Reset()
- func (m *ONormalMessage) Size() (n int)
- func (m *ONormalMessage) String() string
- func (m *ONormalMessage) Unmarshal(dAtA []byte) error
- func (m *ONormalMessage) XXX_DiscardUnknown()
- func (m *ONormalMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ONormalMessage) XXX_Merge(src proto.Message)
- func (m *ONormalMessage) XXX_Size() int
- func (m *ONormalMessage) XXX_Unmarshal(b []byte) error
- type ONormalMessage_Type
- type View
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthHybsterx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHybsterx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupHybsterx = fmt.Errorf("proto: unexpected end of group") )
View Source
var InstanceState_Status_name = map[int32]string{
0: "None",
1: "Prepared",
2: "Committed",
3: "Executed",
}
View Source
var InstanceState_Status_value = map[string]int32{
"None": 0,
"Prepared": 1,
"Committed": 2,
"Executed": 3,
}
View Source
var NormalMessage_Type_name = map[int32]string{
0: "None",
1: "Prepare",
3: "Commit",
}
View Source
var NormalMessage_Type_value = map[string]int32{
"None": 0,
"Prepare": 1,
"Commit": 3,
}
View Source
var OInstanceState_Status_name = map[int32]string{
0: "None",
1: "Prepared",
2: "Committed",
3: "Executed",
}
View Source
var OInstanceState_Status_value = map[string]int32{
"None": 0,
"Prepared": 1,
"Committed": 2,
"Executed": 3,
}
View Source
var ONormalMessage_Type_name = map[int32]string{
0: "None",
1: "OPrepare",
2: "OCommit",
}
View Source
var ONormalMessage_Type_value = map[string]int32{
"None": 0,
"OPrepare": 1,
"OCommit": 2,
}
Functions ¶
func InstancesEquals ¶
func InstancesEquals(a, b []InstanceID) bool
func WrapMessageInner ¶
WrapMessageInner wraps a union type of Message in a new isMessage_Type.
Types ¶
type HybsterxMessage ¶
type HybsterxMessage struct { // Types that are valid to be assigned to Type: // *HybsterxMessage_Normal // *HybsterxMessage_ONormal Type isHybsterxMessage_Type `protobuf_oneof:"type"` }
func WrapHybsterxMessage ¶
func WrapHybsterxMessage(msg proto.Message) *HybsterxMessage
WrapHybsterxMessage wraps a union type of Message in a new PBFTMessage without a destination.
func (*HybsterxMessage) Descriptor ¶
func (*HybsterxMessage) Descriptor() ([]byte, []int)
func (*HybsterxMessage) GetNormal ¶
func (m *HybsterxMessage) GetNormal() *NormalMessage
func (*HybsterxMessage) GetONormal ¶
func (m *HybsterxMessage) GetONormal() *ONormalMessage
func (*HybsterxMessage) GetType ¶
func (m *HybsterxMessage) GetType() isHybsterxMessage_Type
func (*HybsterxMessage) Marshal ¶
func (m *HybsterxMessage) Marshal() (dAtA []byte, err error)
func (*HybsterxMessage) MarshalToSizedBuffer ¶
func (m *HybsterxMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HybsterxMessage) ProtoMessage ¶
func (*HybsterxMessage) ProtoMessage()
func (*HybsterxMessage) Reset ¶
func (m *HybsterxMessage) Reset()
func (*HybsterxMessage) Size ¶
func (m *HybsterxMessage) Size() (n int)
func (*HybsterxMessage) String ¶
func (m *HybsterxMessage) String() string
func (*HybsterxMessage) Unmarshal ¶
func (m *HybsterxMessage) Unmarshal(dAtA []byte) error
func (*HybsterxMessage) XXX_DiscardUnknown ¶
func (m *HybsterxMessage) XXX_DiscardUnknown()
func (*HybsterxMessage) XXX_Marshal ¶
func (m *HybsterxMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HybsterxMessage) XXX_Merge ¶
func (m *HybsterxMessage) XXX_Merge(src proto.Message)
func (*HybsterxMessage) XXX_OneofWrappers ¶
func (*HybsterxMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*HybsterxMessage) XXX_Size ¶
func (m *HybsterxMessage) XXX_Size() int
func (*HybsterxMessage) XXX_Unmarshal ¶
func (m *HybsterxMessage) XXX_Unmarshal(b []byte) error
type HybsterxMessage_Normal ¶
type HybsterxMessage_Normal struct {
Normal *NormalMessage `protobuf:"bytes,1,opt,name=normal,proto3,oneof" json:"normal,omitempty"`
}
func (*HybsterxMessage_Normal) MarshalTo ¶
func (m *HybsterxMessage_Normal) MarshalTo(dAtA []byte) (int, error)
func (*HybsterxMessage_Normal) MarshalToSizedBuffer ¶
func (m *HybsterxMessage_Normal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HybsterxMessage_Normal) Size ¶
func (m *HybsterxMessage_Normal) Size() (n int)
type HybsterxMessage_ONormal ¶
type HybsterxMessage_ONormal struct {
ONormal *ONormalMessage `protobuf:"bytes,2,opt,name=oNormal,proto3,oneof" json:"oNormal,omitempty"`
}
func (*HybsterxMessage_ONormal) MarshalTo ¶
func (m *HybsterxMessage_ONormal) MarshalTo(dAtA []byte) (int, error)
func (*HybsterxMessage_ONormal) MarshalToSizedBuffer ¶
func (m *HybsterxMessage_ONormal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HybsterxMessage_ONormal) Size ¶
func (m *HybsterxMessage_ONormal) Size() (n int)
type Index ¶
type Index uint64
Index is the number of an instance slot in a replica's command array.
func (*Index) GetAndIncrement ¶
type InstanceID ¶
type InstanceID struct { PeerID github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-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) GetPeerID ¶
func (m *InstanceID) GetPeerID() 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=hybsterxpb.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) 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_Prepared InstanceState_Status = 1 InstanceState_Committed InstanceState_Status = 2 InstanceState_Executed InstanceState_Status = 3 )
func (InstanceState_Status) EnumDescriptor ¶
func (InstanceState_Status) EnumDescriptor() ([]byte, []int)
func (InstanceState_Status) String ¶
func (x InstanceState_Status) String() string
type NormalMessage ¶
type NormalMessage 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 NormalMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=hybsterxpb.NormalMessage_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 (*NormalMessage) Descriptor ¶
func (*NormalMessage) Descriptor() ([]byte, []int)
func (*NormalMessage) Equals ¶
func (m *NormalMessage) Equals(other *NormalMessage) bool
func (*NormalMessage) GetCommand ¶
func (m *NormalMessage) GetCommand() *commandpb.Command
func (*NormalMessage) GetCommandHash ¶
func (m *NormalMessage) GetCommandHash() []byte
func (*NormalMessage) GetInstanceID ¶
func (m *NormalMessage) GetInstanceID() InstanceID
func (*NormalMessage) GetType ¶
func (m *NormalMessage) GetType() NormalMessage_Type
func (*NormalMessage) GetView ¶
func (m *NormalMessage) GetView() View
func (*NormalMessage) Marshal ¶
func (m *NormalMessage) Marshal() (dAtA []byte, err error)
func (*NormalMessage) MarshalToSizedBuffer ¶
func (m *NormalMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NormalMessage) ProtoMessage ¶
func (*NormalMessage) ProtoMessage()
func (*NormalMessage) Reset ¶
func (m *NormalMessage) Reset()
func (*NormalMessage) Size ¶
func (m *NormalMessage) Size() (n int)
func (*NormalMessage) String ¶
func (m *NormalMessage) String() string
func (*NormalMessage) Unmarshal ¶
func (m *NormalMessage) Unmarshal(dAtA []byte) error
func (*NormalMessage) XXX_DiscardUnknown ¶
func (m *NormalMessage) XXX_DiscardUnknown()
func (*NormalMessage) XXX_Marshal ¶
func (m *NormalMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NormalMessage) XXX_Merge ¶
func (m *NormalMessage) XXX_Merge(src proto.Message)
func (*NormalMessage) XXX_Size ¶
func (m *NormalMessage) XXX_Size() int
func (*NormalMessage) XXX_Unmarshal ¶
func (m *NormalMessage) XXX_Unmarshal(b []byte) error
type NormalMessage_Type ¶
type NormalMessage_Type int32
const ( NormalMessage_None NormalMessage_Type = 0 NormalMessage_Prepare NormalMessage_Type = 1 NormalMessage_Commit NormalMessage_Type = 3 )
func (NormalMessage_Type) EnumDescriptor ¶
func (NormalMessage_Type) EnumDescriptor() ([]byte, []int)
func (NormalMessage_Type) String ¶
func (x NormalMessage_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=hybsterxpb.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) 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_Prepared OInstanceState_Status = 1 OInstanceState_Committed OInstanceState_Status = 2 OInstanceState_Executed OInstanceState_Status = 3 )
func (OInstanceState_Status) EnumDescriptor ¶
func (OInstanceState_Status) EnumDescriptor() ([]byte, []int)
func (OInstanceState_Status) String ¶
func (x OInstanceState_Status) String() string
type ONormalMessage ¶
type ONormalMessage 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 ONormalMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=hybsterxpb.ONormalMessage_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 (*ONormalMessage) Descriptor ¶
func (*ONormalMessage) Descriptor() ([]byte, []int)
func (*ONormalMessage) Equals ¶
func (m *ONormalMessage) Equals(other *ONormalMessage) bool
func (*ONormalMessage) GetCommandHash ¶
func (m *ONormalMessage) GetCommandHash() []byte
func (*ONormalMessage) GetIndex ¶
func (m *ONormalMessage) GetIndex() Index
func (*ONormalMessage) GetInstances ¶
func (m *ONormalMessage) GetInstances() []InstanceID
func (*ONormalMessage) GetType ¶
func (m *ONormalMessage) GetType() ONormalMessage_Type
func (*ONormalMessage) GetView ¶
func (m *ONormalMessage) GetView() View
func (*ONormalMessage) Marshal ¶
func (m *ONormalMessage) Marshal() (dAtA []byte, err error)
func (*ONormalMessage) MarshalToSizedBuffer ¶
func (m *ONormalMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ONormalMessage) ProtoMessage ¶
func (*ONormalMessage) ProtoMessage()
func (*ONormalMessage) Reset ¶
func (m *ONormalMessage) Reset()
func (*ONormalMessage) Size ¶
func (m *ONormalMessage) Size() (n int)
func (*ONormalMessage) String ¶
func (m *ONormalMessage) String() string
func (*ONormalMessage) Unmarshal ¶
func (m *ONormalMessage) Unmarshal(dAtA []byte) error
func (*ONormalMessage) XXX_DiscardUnknown ¶
func (m *ONormalMessage) XXX_DiscardUnknown()
func (*ONormalMessage) XXX_Marshal ¶
func (m *ONormalMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ONormalMessage) XXX_Merge ¶
func (m *ONormalMessage) XXX_Merge(src proto.Message)
func (*ONormalMessage) XXX_Size ¶
func (m *ONormalMessage) XXX_Size() int
func (*ONormalMessage) XXX_Unmarshal ¶
func (m *ONormalMessage) XXX_Unmarshal(b []byte) error
type ONormalMessage_Type ¶
type ONormalMessage_Type int32
const ( ONormalMessage_None ONormalMessage_Type = 0 ONormalMessage_OPrepare ONormalMessage_Type = 1 ONormalMessage_OCommit ONormalMessage_Type = 2 )
func (ONormalMessage_Type) EnumDescriptor ¶
func (ONormalMessage_Type) EnumDescriptor() ([]byte, []int)
func (ONormalMessage_Type) String ¶
func (x ONormalMessage_Type) String() string
Click to show internal directories.
Click to hide internal directories.