Documentation ¶
Index ¶
- Variables
- func WrapMessageInner(msg proto.Message) isPrimeMessage_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) Equals(other InstanceState) bool
- 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) IsPOAcked() bool
- func (m *InstanceState) IsPOSummarized() bool
- func (m *InstanceState) IsPreOrdered() 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 OInstanceState
- func (*OInstanceState) Descriptor() ([]byte, []int)
- func (m *OInstanceState) GetIndex() Index
- func (m *OInstanceState) GetPOSummaryMatrix() *POSummaryMatrix
- func (m *OInstanceState) GetPOSummaryMatrixHash() []byte
- 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 OrderMessage
- func (*OrderMessage) Descriptor() ([]byte, []int)
- func (m *OrderMessage) Equals(other *OrderMessage) bool
- func (m *OrderMessage) GetIndex() Index
- func (m *OrderMessage) GetPOSummaryMatrix() *POSummaryMatrix
- func (m *OrderMessage) GetPOSummaryMatrixHash() []byte
- func (m *OrderMessage) GetType() OrderMessage_Type
- func (m *OrderMessage) GetView() View
- func (m *OrderMessage) Marshal() (dAtA []byte, err error)
- func (m *OrderMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *OrderMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OrderMessage) ProtoMessage()
- func (m *OrderMessage) Reset()
- func (m *OrderMessage) Size() (n int)
- func (m *OrderMessage) String() string
- func (m *OrderMessage) Unmarshal(dAtA []byte) error
- func (m *OrderMessage) XXX_DiscardUnknown()
- func (m *OrderMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrderMessage) XXX_Merge(src proto.Message)
- func (m *OrderMessage) XXX_Size() int
- func (m *OrderMessage) XXX_Unmarshal(b []byte) error
- type OrderMessage_Type
- type POSummary
- func (*POSummary) Descriptor() ([]byte, []int)
- func (m *POSummary) Equals(other POSummary) bool
- func (m *POSummary) GetPOSummary() []Index
- func (m *POSummary) Marshal() (dAtA []byte, err error)
- func (m *POSummary) MarshalTo(dAtA []byte) (int, error)
- func (m *POSummary) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*POSummary) ProtoMessage()
- func (m *POSummary) Reset()
- func (m *POSummary) Size() (n int)
- func (m *POSummary) String() string
- func (m *POSummary) Unmarshal(dAtA []byte) error
- func (m *POSummary) XXX_DiscardUnknown()
- func (m *POSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *POSummary) XXX_Merge(src proto.Message)
- func (m *POSummary) XXX_Size() int
- func (m *POSummary) XXX_Unmarshal(b []byte) error
- type POSummaryMatrix
- func (*POSummaryMatrix) Descriptor() ([]byte, []int)
- func (m *POSummaryMatrix) GetPOSummaryMatrix() []POSummary
- func (m *POSummaryMatrix) Marshal() (dAtA []byte, err error)
- func (m *POSummaryMatrix) MarshalTo(dAtA []byte) (int, error)
- func (m *POSummaryMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*POSummaryMatrix) ProtoMessage()
- func (m *POSummaryMatrix) Reset()
- func (m *POSummaryMatrix) Size() (n int)
- func (m *POSummaryMatrix) String() string
- func (m *POSummaryMatrix) Unmarshal(dAtA []byte) error
- func (m *POSummaryMatrix) XXX_DiscardUnknown()
- func (m *POSummaryMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *POSummaryMatrix) XXX_Merge(src proto.Message)
- func (m *POSummaryMatrix) XXX_Size() int
- func (m *POSummaryMatrix) XXX_Unmarshal(b []byte) error
- type PreOrderMessage
- func (*PreOrderMessage) Descriptor() ([]byte, []int)
- func (m *PreOrderMessage) Equals(other *PreOrderMessage) bool
- func (m *PreOrderMessage) GetCommand() *commandpb.Command
- func (m *PreOrderMessage) GetCommandHash() []byte
- func (m *PreOrderMessage) GetInstanceID() InstanceID
- func (m *PreOrderMessage) GetPOSummary() POSummary
- func (m *PreOrderMessage) GetType() PreOrderMessage_Type
- func (m *PreOrderMessage) Marshal() (dAtA []byte, err error)
- func (m *PreOrderMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *PreOrderMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PreOrderMessage) ProtoMessage()
- func (m *PreOrderMessage) Reset()
- func (m *PreOrderMessage) Size() (n int)
- func (m *PreOrderMessage) String() string
- func (m *PreOrderMessage) Unmarshal(dAtA []byte) error
- func (m *PreOrderMessage) XXX_DiscardUnknown()
- func (m *PreOrderMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PreOrderMessage) XXX_Merge(src proto.Message)
- func (m *PreOrderMessage) XXX_Size() int
- func (m *PreOrderMessage) XXX_Unmarshal(b []byte) error
- type PreOrderMessage_Type
- type PrimeMessage
- func (*PrimeMessage) Descriptor() ([]byte, []int)
- func (m *PrimeMessage) GetOrder() *OrderMessage
- func (m *PrimeMessage) GetPreorder() *PreOrderMessage
- func (m *PrimeMessage) GetResult() *ResultMessage
- func (m *PrimeMessage) GetType() isPrimeMessage_Type
- func (m *PrimeMessage) Marshal() (dAtA []byte, err error)
- func (m *PrimeMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *PrimeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrimeMessage) ProtoMessage()
- func (m *PrimeMessage) Reset()
- func (m *PrimeMessage) Size() (n int)
- func (m *PrimeMessage) String() string
- func (m *PrimeMessage) Unmarshal(dAtA []byte) error
- func (m *PrimeMessage) XXX_DiscardUnknown()
- func (m *PrimeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrimeMessage) XXX_Merge(src proto.Message)
- func (*PrimeMessage) XXX_OneofWrappers() []interface{}
- func (m *PrimeMessage) XXX_Size() int
- func (m *PrimeMessage) XXX_Unmarshal(b []byte) error
- type PrimeMessage_Order
- type PrimeMessage_Preorder
- type PrimeMessage_Result
- type ResultMessage
- func (*ResultMessage) Descriptor() ([]byte, []int)
- 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 View
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthPrime = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPrime = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPrime = fmt.Errorf("proto: unexpected end of group") )
View Source
var InstanceState_Status_name = map[int32]string{
0: "None",
1: "PreOrder",
2: "PreOrderAck",
3: "Summary",
4: "Committed",
5: "Executed",
}
View Source
var InstanceState_Status_value = map[string]int32{
"None": 0,
"PreOrder": 1,
"PreOrderAck": 2,
"Summary": 3,
"Committed": 4,
"Executed": 5,
}
View Source
var OInstanceState_Status_name = map[int32]string{
0: "None",
1: "PrePrepared",
2: "Prepared",
3: "Committed",
4: "Executed",
}
View Source
var OInstanceState_Status_value = map[string]int32{
"None": 0,
"PrePrepared": 1,
"Prepared": 2,
"Committed": 3,
"Executed": 4,
}
View Source
var OrderMessage_Type_name = map[int32]string{
0: "PrePrepare",
1: "Prepare",
2: "Commit",
}
View Source
var OrderMessage_Type_value = map[string]int32{
"PrePrepare": 0,
"Prepare": 1,
"Commit": 2,
}
View Source
var PreOrderMessage_Type_name = map[int32]string{
0: "PORequest",
1: "POAck",
2: "POSummary",
}
View Source
var PreOrderMessage_Type_value = map[string]int32{
"PORequest": 0,
"POAck": 1,
"POSummary": 2,
}
Functions ¶
func WrapMessageInner ¶
WrapMessageInner wraps a union type of Message in a new isMessage_Type.
Types ¶
type Index ¶
type Index uint64
Index is the number of an instance slot in a replica's command array.
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=primepb.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) Equals ¶
func (m *InstanceState) Equals(other InstanceState) bool
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) IsPOAcked ¶
func (m *InstanceState) IsPOAcked() bool
func (*InstanceState) IsPOSummarized ¶
func (m *InstanceState) IsPOSummarized() bool
func (*InstanceState) IsPreOrdered ¶
func (m *InstanceState) IsPreOrdered() 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_PreOrder InstanceState_Status = 1 InstanceState_PreOrderAck InstanceState_Status = 2 InstanceState_Summary InstanceState_Status = 3 InstanceState_Committed InstanceState_Status = 4 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 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=primepb.OInstanceState_Status" json:"status,omitempty"` POSummaryMatrix *POSummaryMatrix `protobuf:"bytes,5,opt,name=po_summary_matrix,json=poSummaryMatrix,proto3" json:"po_summary_matrix,omitempty"` POSummaryMatrixHash []byte `protobuf:"bytes,6,opt,name=po_summary_matrix_hash,json=poSummaryMatrixHash,proto3" json:"po_summary_matrix_hash,omitempty"` }
func (*OInstanceState) Descriptor ¶
func (*OInstanceState) Descriptor() ([]byte, []int)
func (*OInstanceState) GetIndex ¶
func (m *OInstanceState) GetIndex() Index
func (*OInstanceState) GetPOSummaryMatrix ¶
func (m *OInstanceState) GetPOSummaryMatrix() *POSummaryMatrix
func (*OInstanceState) GetPOSummaryMatrixHash ¶
func (m *OInstanceState) GetPOSummaryMatrixHash() []byte
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_PrePrepared OInstanceState_Status = 1 OInstanceState_Prepared OInstanceState_Status = 2 OInstanceState_Committed OInstanceState_Status = 3 OInstanceState_Executed OInstanceState_Status = 4 )
func (OInstanceState_Status) EnumDescriptor ¶
func (OInstanceState_Status) EnumDescriptor() ([]byte, []int)
func (OInstanceState_Status) String ¶
func (x OInstanceState_Status) String() string
type OrderMessage ¶
type OrderMessage 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 OrderMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=primepb.OrderMessage_Type" json:"type,omitempty"` POSummaryMatrix *POSummaryMatrix `protobuf:"bytes,5,opt,name=po_summary_matrix,json=poSummaryMatrix,proto3" json:"po_summary_matrix,omitempty"` POSummaryMatrixHash []byte `protobuf:"bytes,6,opt,name=po_summary_matrix_hash,json=poSummaryMatrixHash,proto3" json:"po_summary_matrix_hash,omitempty"` }
func (*OrderMessage) Descriptor ¶
func (*OrderMessage) Descriptor() ([]byte, []int)
func (*OrderMessage) Equals ¶
func (m *OrderMessage) Equals(other *OrderMessage) bool
func (*OrderMessage) GetIndex ¶
func (m *OrderMessage) GetIndex() Index
func (*OrderMessage) GetPOSummaryMatrix ¶
func (m *OrderMessage) GetPOSummaryMatrix() *POSummaryMatrix
func (*OrderMessage) GetPOSummaryMatrixHash ¶
func (m *OrderMessage) GetPOSummaryMatrixHash() []byte
func (*OrderMessage) GetType ¶
func (m *OrderMessage) GetType() OrderMessage_Type
func (*OrderMessage) GetView ¶
func (m *OrderMessage) GetView() View
func (*OrderMessage) Marshal ¶
func (m *OrderMessage) Marshal() (dAtA []byte, err error)
func (*OrderMessage) MarshalToSizedBuffer ¶
func (m *OrderMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OrderMessage) ProtoMessage ¶
func (*OrderMessage) ProtoMessage()
func (*OrderMessage) Reset ¶
func (m *OrderMessage) Reset()
func (*OrderMessage) Size ¶
func (m *OrderMessage) Size() (n int)
func (*OrderMessage) String ¶
func (m *OrderMessage) String() string
func (*OrderMessage) Unmarshal ¶
func (m *OrderMessage) Unmarshal(dAtA []byte) error
func (*OrderMessage) XXX_DiscardUnknown ¶
func (m *OrderMessage) XXX_DiscardUnknown()
func (*OrderMessage) XXX_Marshal ¶
func (m *OrderMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrderMessage) XXX_Merge ¶
func (m *OrderMessage) XXX_Merge(src proto.Message)
func (*OrderMessage) XXX_Size ¶
func (m *OrderMessage) XXX_Size() int
func (*OrderMessage) XXX_Unmarshal ¶
func (m *OrderMessage) XXX_Unmarshal(b []byte) error
type OrderMessage_Type ¶
type OrderMessage_Type int32
const ( OrderMessage_PrePrepare OrderMessage_Type = 0 OrderMessage_Prepare OrderMessage_Type = 1 OrderMessage_Commit OrderMessage_Type = 2 )
func (OrderMessage_Type) EnumDescriptor ¶
func (OrderMessage_Type) EnumDescriptor() ([]byte, []int)
func (OrderMessage_Type) String ¶
func (x OrderMessage_Type) String() string
type POSummary ¶
type POSummary struct {
POSummary []Index `protobuf:"varint,5,rep,packed,name=po_summary,json=poSummary,proto3,casttype=Index" json:"po_summary,omitempty"`
}
func (*POSummary) Descriptor ¶
func (*POSummary) GetPOSummary ¶
func (*POSummary) MarshalToSizedBuffer ¶
func (*POSummary) ProtoMessage ¶
func (*POSummary) ProtoMessage()
func (*POSummary) XXX_DiscardUnknown ¶
func (m *POSummary) XXX_DiscardUnknown()
func (*POSummary) XXX_Marshal ¶
func (*POSummary) XXX_Unmarshal ¶
type POSummaryMatrix ¶
type POSummaryMatrix struct {
POSummaryMatrix []POSummary `protobuf:"bytes,5,rep,name=po_summary_matrix,json=poSummaryMatrix,proto3" json:"po_summary_matrix"`
}
func (*POSummaryMatrix) Descriptor ¶
func (*POSummaryMatrix) Descriptor() ([]byte, []int)
func (*POSummaryMatrix) GetPOSummaryMatrix ¶
func (m *POSummaryMatrix) GetPOSummaryMatrix() []POSummary
func (*POSummaryMatrix) Marshal ¶
func (m *POSummaryMatrix) Marshal() (dAtA []byte, err error)
func (*POSummaryMatrix) MarshalToSizedBuffer ¶
func (m *POSummaryMatrix) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*POSummaryMatrix) ProtoMessage ¶
func (*POSummaryMatrix) ProtoMessage()
func (*POSummaryMatrix) Reset ¶
func (m *POSummaryMatrix) Reset()
func (*POSummaryMatrix) Size ¶
func (m *POSummaryMatrix) Size() (n int)
func (*POSummaryMatrix) String ¶
func (m *POSummaryMatrix) String() string
func (*POSummaryMatrix) Unmarshal ¶
func (m *POSummaryMatrix) Unmarshal(dAtA []byte) error
func (*POSummaryMatrix) XXX_DiscardUnknown ¶
func (m *POSummaryMatrix) XXX_DiscardUnknown()
func (*POSummaryMatrix) XXX_Marshal ¶
func (m *POSummaryMatrix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*POSummaryMatrix) XXX_Merge ¶
func (m *POSummaryMatrix) XXX_Merge(src proto.Message)
func (*POSummaryMatrix) XXX_Size ¶
func (m *POSummaryMatrix) XXX_Size() int
func (*POSummaryMatrix) XXX_Unmarshal ¶
func (m *POSummaryMatrix) XXX_Unmarshal(b []byte) error
type PreOrderMessage ¶
type PreOrderMessage struct { InstanceID InstanceID `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id"` Type PreOrderMessage_Type `protobuf:"varint,3,opt,name=type,proto3,enum=primepb.PreOrderMessage_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"` POSummary POSummary `protobuf:"bytes,6,opt,name=po_summary,json=poSummary,proto3" json:"po_summary"` }
func (*PreOrderMessage) Descriptor ¶
func (*PreOrderMessage) Descriptor() ([]byte, []int)
func (*PreOrderMessage) Equals ¶
func (m *PreOrderMessage) Equals(other *PreOrderMessage) bool
func (*PreOrderMessage) GetCommand ¶
func (m *PreOrderMessage) GetCommand() *commandpb.Command
func (*PreOrderMessage) GetCommandHash ¶
func (m *PreOrderMessage) GetCommandHash() []byte
func (*PreOrderMessage) GetInstanceID ¶
func (m *PreOrderMessage) GetInstanceID() InstanceID
func (*PreOrderMessage) GetPOSummary ¶
func (m *PreOrderMessage) GetPOSummary() POSummary
func (*PreOrderMessage) GetType ¶
func (m *PreOrderMessage) GetType() PreOrderMessage_Type
func (*PreOrderMessage) Marshal ¶
func (m *PreOrderMessage) Marshal() (dAtA []byte, err error)
func (*PreOrderMessage) MarshalToSizedBuffer ¶
func (m *PreOrderMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PreOrderMessage) ProtoMessage ¶
func (*PreOrderMessage) ProtoMessage()
func (*PreOrderMessage) Reset ¶
func (m *PreOrderMessage) Reset()
func (*PreOrderMessage) Size ¶
func (m *PreOrderMessage) Size() (n int)
func (*PreOrderMessage) String ¶
func (m *PreOrderMessage) String() string
func (*PreOrderMessage) Unmarshal ¶
func (m *PreOrderMessage) Unmarshal(dAtA []byte) error
func (*PreOrderMessage) XXX_DiscardUnknown ¶
func (m *PreOrderMessage) XXX_DiscardUnknown()
func (*PreOrderMessage) XXX_Marshal ¶
func (m *PreOrderMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PreOrderMessage) XXX_Merge ¶
func (m *PreOrderMessage) XXX_Merge(src proto.Message)
func (*PreOrderMessage) XXX_Size ¶
func (m *PreOrderMessage) XXX_Size() int
func (*PreOrderMessage) XXX_Unmarshal ¶
func (m *PreOrderMessage) XXX_Unmarshal(b []byte) error
type PreOrderMessage_Type ¶
type PreOrderMessage_Type int32
const ( PreOrderMessage_PORequest PreOrderMessage_Type = 0 PreOrderMessage_POAck PreOrderMessage_Type = 1 PreOrderMessage_POSummary PreOrderMessage_Type = 2 )
func (PreOrderMessage_Type) EnumDescriptor ¶
func (PreOrderMessage_Type) EnumDescriptor() ([]byte, []int)
func (PreOrderMessage_Type) String ¶
func (x PreOrderMessage_Type) String() string
type PrimeMessage ¶
type PrimeMessage struct { // Types that are valid to be assigned to Type: // *PrimeMessage_Preorder // *PrimeMessage_Order // *PrimeMessage_Result Type isPrimeMessage_Type `protobuf_oneof:"type"` }
func WrapPBFTMessage ¶
func WrapPBFTMessage(msg proto.Message) *PrimeMessage
WrapPBFTMessage wraps a union type of Message in a new PBFTMessage without a destination.
func (*PrimeMessage) Descriptor ¶
func (*PrimeMessage) Descriptor() ([]byte, []int)
func (*PrimeMessage) GetOrder ¶
func (m *PrimeMessage) GetOrder() *OrderMessage
func (*PrimeMessage) GetPreorder ¶
func (m *PrimeMessage) GetPreorder() *PreOrderMessage
func (*PrimeMessage) GetResult ¶
func (m *PrimeMessage) GetResult() *ResultMessage
func (*PrimeMessage) GetType ¶
func (m *PrimeMessage) GetType() isPrimeMessage_Type
func (*PrimeMessage) Marshal ¶
func (m *PrimeMessage) Marshal() (dAtA []byte, err error)
func (*PrimeMessage) MarshalToSizedBuffer ¶
func (m *PrimeMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimeMessage) ProtoMessage ¶
func (*PrimeMessage) ProtoMessage()
func (*PrimeMessage) Reset ¶
func (m *PrimeMessage) Reset()
func (*PrimeMessage) Size ¶
func (m *PrimeMessage) Size() (n int)
func (*PrimeMessage) String ¶
func (m *PrimeMessage) String() string
func (*PrimeMessage) Unmarshal ¶
func (m *PrimeMessage) Unmarshal(dAtA []byte) error
func (*PrimeMessage) XXX_DiscardUnknown ¶
func (m *PrimeMessage) XXX_DiscardUnknown()
func (*PrimeMessage) XXX_Marshal ¶
func (m *PrimeMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimeMessage) XXX_Merge ¶
func (m *PrimeMessage) XXX_Merge(src proto.Message)
func (*PrimeMessage) XXX_OneofWrappers ¶
func (*PrimeMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*PrimeMessage) XXX_Size ¶
func (m *PrimeMessage) XXX_Size() int
func (*PrimeMessage) XXX_Unmarshal ¶
func (m *PrimeMessage) XXX_Unmarshal(b []byte) error
type PrimeMessage_Order ¶
type PrimeMessage_Order struct {
Order *OrderMessage `protobuf:"bytes,2,opt,name=order,proto3,oneof" json:"order,omitempty"`
}
func (*PrimeMessage_Order) MarshalTo ¶
func (m *PrimeMessage_Order) MarshalTo(dAtA []byte) (int, error)
func (*PrimeMessage_Order) MarshalToSizedBuffer ¶
func (m *PrimeMessage_Order) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimeMessage_Order) Size ¶
func (m *PrimeMessage_Order) Size() (n int)
type PrimeMessage_Preorder ¶
type PrimeMessage_Preorder struct {
Preorder *PreOrderMessage `protobuf:"bytes,1,opt,name=preorder,proto3,oneof" json:"preorder,omitempty"`
}
func (*PrimeMessage_Preorder) MarshalTo ¶
func (m *PrimeMessage_Preorder) MarshalTo(dAtA []byte) (int, error)
func (*PrimeMessage_Preorder) MarshalToSizedBuffer ¶
func (m *PrimeMessage_Preorder) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimeMessage_Preorder) Size ¶
func (m *PrimeMessage_Preorder) Size() (n int)
type PrimeMessage_Result ¶
type PrimeMessage_Result struct {
Result *ResultMessage `protobuf:"bytes,3,opt,name=result,proto3,oneof" json:"result,omitempty"`
}
func (*PrimeMessage_Result) MarshalTo ¶
func (m *PrimeMessage_Result) MarshalTo(dAtA []byte) (int, error)
func (*PrimeMessage_Result) MarshalToSizedBuffer ¶
func (m *PrimeMessage_Result) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimeMessage_Result) Size ¶
func (m *PrimeMessage_Result) Size() (n int)
type ResultMessage ¶
type ResultMessage struct { Result [][]byte `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"` Id []uint64 `protobuf:"varint,2,rep,packed,name=id,proto3" json:"id,omitempty"` }
func (*ResultMessage) Descriptor ¶
func (*ResultMessage) Descriptor() ([]byte, []int)
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
Click to show internal directories.
Click to hide internal directories.