Documentation ¶
Index ¶
- Variables
- func InstancesEquals(a, b []InstanceID) bool
- func ReplicaIDEquals(a, b []peerpb.PeerID) bool
- func WrapMessageInner(msg proto.Message) isSBFTxMessage_Type
- 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) 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) 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 ResultMessage
- func (*ResultMessage) Descriptor() ([]byte, []int)
- func (m *ResultMessage) Equals(other *ResultMessage) bool
- func (m *ResultMessage) GetId() uint64
- func (m *ResultMessage) GetResult() []byte
- func (m *ResultMessage) Marshal() (dAtA []byte, err error)
- func (m *ResultMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *ResultMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResultMessage) ProtoMessage()
- func (m *ResultMessage) Reset()
- func (m *ResultMessage) Size() (n int)
- func (m *ResultMessage) String() string
- func (m *ResultMessage) Unmarshal(dAtA []byte) error
- func (m *ResultMessage) XXX_DiscardUnknown()
- func (m *ResultMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResultMessage) XXX_Merge(src proto.Message)
- func (m *ResultMessage) XXX_Size() int
- func (m *ResultMessage) XXX_Unmarshal(b []byte) error
- type SBFTxMessage
- func (*SBFTxMessage) Descriptor() ([]byte, []int)
- func (m *SBFTxMessage) GetNormal() *NormalMessage
- func (m *SBFTxMessage) GetONormal() *ONormalMessage
- func (m *SBFTxMessage) GetResult() *ResultMessage
- func (m *SBFTxMessage) GetType() isSBFTxMessage_Type
- func (m *SBFTxMessage) Marshal() (dAtA []byte, err error)
- func (m *SBFTxMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *SBFTxMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SBFTxMessage) ProtoMessage()
- func (m *SBFTxMessage) Reset()
- func (m *SBFTxMessage) Size() (n int)
- func (m *SBFTxMessage) String() string
- func (m *SBFTxMessage) Unmarshal(dAtA []byte) error
- func (m *SBFTxMessage) XXX_DiscardUnknown()
- func (m *SBFTxMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SBFTxMessage) XXX_Merge(src proto.Message)
- func (*SBFTxMessage) XXX_OneofWrappers() []interface{}
- func (m *SBFTxMessage) XXX_Size() int
- func (m *SBFTxMessage) XXX_Unmarshal(b []byte) error
- type SBFTxMessage_Normal
- type SBFTxMessage_ONormal
- type SBFTxMessage_Result
- type View
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthSbftx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSbftx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupSbftx = fmt.Errorf("proto: unexpected end of group") )
View Source
var InstanceState_Status_name = map[int32]string{
0: "None",
1: "Prepared",
2: "SignShared",
3: "Committed",
4: "StateShared",
5: "Executed",
}
View Source
var InstanceState_Status_value = map[string]int32{
"None": 0,
"Prepared": 1,
"SignShared": 2,
"Committed": 3,
"StateShared": 4,
"Executed": 5,
}
View Source
var NormalMessage_Type_name = map[int32]string{
0: "None",
1: "Prepare",
2: "SignShare",
3: "Commit",
4: "StateShare",
5: "ExecProof",
}
View Source
var NormalMessage_Type_value = map[string]int32{
"None": 0,
"Prepare": 1,
"SignShare": 2,
"Commit": 3,
"StateShare": 4,
"ExecProof": 5,
}
View Source
var OInstanceState_Status_name = map[int32]string{
0: "None",
1: "Prepared",
2: "SignShared",
3: "Committed",
4: "StateShared",
5: "Executed",
}
View Source
var OInstanceState_Status_value = map[string]int32{
"None": 0,
"Prepared": 1,
"SignShared": 2,
"Committed": 3,
"StateShared": 4,
"Executed": 5,
}
View Source
var ONormalMessage_Type_name = map[int32]string{
0: "None",
1: "OPrepare",
2: "OSignShare",
3: "OCommit",
4: "OStateShare",
5: "OExecProof",
}
View Source
var ONormalMessage_Type_value = map[string]int32{
"None": 0,
"OPrepare": 1,
"OSignShare": 2,
"OCommit": 3,
"OStateShare": 4,
"OExecProof": 5,
}
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 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=sbftxpb.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 = 3 InstanceState_Executed InstanceState_Status = 5 )
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=sbftxpb.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 NormalMessage_ExecProof NormalMessage_Type = 5 )
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=sbftxpb.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) 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 = 3 OInstanceState_Executed OInstanceState_Status = 5 )
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=sbftxpb.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 = 3 ONormalMessage_OExecProof ONormalMessage_Type = 5 )
func (ONormalMessage_Type) EnumDescriptor ¶
func (ONormalMessage_Type) EnumDescriptor() ([]byte, []int)
func (ONormalMessage_Type) String ¶
func (x ONormalMessage_Type) String() string
type ResultMessage ¶
type ResultMessage struct { Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` }
func (*ResultMessage) Descriptor ¶
func (*ResultMessage) Descriptor() ([]byte, []int)
func (*ResultMessage) Equals ¶
func (m *ResultMessage) Equals(other *ResultMessage) bool
func (*ResultMessage) GetId ¶
func (m *ResultMessage) GetId() uint64
func (*ResultMessage) GetResult ¶
func (m *ResultMessage) GetResult() []byte
func (*ResultMessage) Marshal ¶
func (m *ResultMessage) Marshal() (dAtA []byte, err error)
func (*ResultMessage) MarshalToSizedBuffer ¶
func (m *ResultMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResultMessage) ProtoMessage ¶
func (*ResultMessage) ProtoMessage()
func (*ResultMessage) Reset ¶
func (m *ResultMessage) Reset()
func (*ResultMessage) Size ¶
func (m *ResultMessage) Size() (n int)
func (*ResultMessage) String ¶
func (m *ResultMessage) String() string
func (*ResultMessage) Unmarshal ¶
func (m *ResultMessage) Unmarshal(dAtA []byte) error
func (*ResultMessage) XXX_DiscardUnknown ¶
func (m *ResultMessage) XXX_DiscardUnknown()
func (*ResultMessage) XXX_Marshal ¶
func (m *ResultMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResultMessage) XXX_Merge ¶
func (m *ResultMessage) XXX_Merge(src proto.Message)
func (*ResultMessage) XXX_Size ¶
func (m *ResultMessage) XXX_Size() int
func (*ResultMessage) XXX_Unmarshal ¶
func (m *ResultMessage) XXX_Unmarshal(b []byte) error
type SBFTxMessage ¶
type SBFTxMessage struct { // Types that are valid to be assigned to Type: // *SBFTxMessage_Normal // *SBFTxMessage_ONormal // *SBFTxMessage_Result Type isSBFTxMessage_Type `protobuf_oneof:"type"` }
func WrapSBFTxMessage ¶
func WrapSBFTxMessage(msg proto.Message) *SBFTxMessage
WrapSBFTxMessage wraps a union type of Message in a new PBFTMessage without a destination.
func (*SBFTxMessage) Descriptor ¶
func (*SBFTxMessage) Descriptor() ([]byte, []int)
func (*SBFTxMessage) GetNormal ¶
func (m *SBFTxMessage) GetNormal() *NormalMessage
func (*SBFTxMessage) GetONormal ¶
func (m *SBFTxMessage) GetONormal() *ONormalMessage
func (*SBFTxMessage) GetResult ¶
func (m *SBFTxMessage) GetResult() *ResultMessage
func (*SBFTxMessage) GetType ¶
func (m *SBFTxMessage) GetType() isSBFTxMessage_Type
func (*SBFTxMessage) Marshal ¶
func (m *SBFTxMessage) Marshal() (dAtA []byte, err error)
func (*SBFTxMessage) MarshalToSizedBuffer ¶
func (m *SBFTxMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SBFTxMessage) ProtoMessage ¶
func (*SBFTxMessage) ProtoMessage()
func (*SBFTxMessage) Reset ¶
func (m *SBFTxMessage) Reset()
func (*SBFTxMessage) Size ¶
func (m *SBFTxMessage) Size() (n int)
func (*SBFTxMessage) String ¶
func (m *SBFTxMessage) String() string
func (*SBFTxMessage) Unmarshal ¶
func (m *SBFTxMessage) Unmarshal(dAtA []byte) error
func (*SBFTxMessage) XXX_DiscardUnknown ¶
func (m *SBFTxMessage) XXX_DiscardUnknown()
func (*SBFTxMessage) XXX_Marshal ¶
func (m *SBFTxMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SBFTxMessage) XXX_Merge ¶
func (m *SBFTxMessage) XXX_Merge(src proto.Message)
func (*SBFTxMessage) XXX_OneofWrappers ¶
func (*SBFTxMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SBFTxMessage) XXX_Size ¶
func (m *SBFTxMessage) XXX_Size() int
func (*SBFTxMessage) XXX_Unmarshal ¶
func (m *SBFTxMessage) XXX_Unmarshal(b []byte) error
type SBFTxMessage_Normal ¶
type SBFTxMessage_Normal struct {
Normal *NormalMessage `protobuf:"bytes,1,opt,name=normal,proto3,oneof" json:"normal,omitempty"`
}
func (*SBFTxMessage_Normal) MarshalTo ¶
func (m *SBFTxMessage_Normal) MarshalTo(dAtA []byte) (int, error)
func (*SBFTxMessage_Normal) MarshalToSizedBuffer ¶
func (m *SBFTxMessage_Normal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SBFTxMessage_Normal) Size ¶
func (m *SBFTxMessage_Normal) Size() (n int)
type SBFTxMessage_ONormal ¶
type SBFTxMessage_ONormal struct {
ONormal *ONormalMessage `protobuf:"bytes,2,opt,name=oNormal,proto3,oneof" json:"oNormal,omitempty"`
}
func (*SBFTxMessage_ONormal) MarshalTo ¶
func (m *SBFTxMessage_ONormal) MarshalTo(dAtA []byte) (int, error)
func (*SBFTxMessage_ONormal) MarshalToSizedBuffer ¶
func (m *SBFTxMessage_ONormal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SBFTxMessage_ONormal) Size ¶
func (m *SBFTxMessage_ONormal) Size() (n int)
type SBFTxMessage_Result ¶
type SBFTxMessage_Result struct {
Result *ResultMessage `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
}
func (*SBFTxMessage_Result) MarshalTo ¶
func (m *SBFTxMessage_Result) MarshalTo(dAtA []byte) (int, error)
func (*SBFTxMessage_Result) MarshalToSizedBuffer ¶
func (m *SBFTxMessage_Result) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SBFTxMessage_Result) Size ¶
func (m *SBFTxMessage_Result) Size() (n int)
Click to show internal directories.
Click to hide internal directories.