Documentation ¶
Index ¶
- Variables
- func MarshalOrPanic(m proto.Message) []byte
- func MessageFromAPI(m messages.Message) proto.Message
- type Commit
- func (*Commit) Descriptor() ([]byte, []int)deprecated
- func (x *Commit) GetProposal() *Message
- func (x *Commit) GetReplicaId() uint32
- func (x *Commit) GetUi() []byte
- func (*Commit) ProtoMessage()
- func (x *Commit) ProtoReflect() protoreflect.Message
- func (x *Commit) Reset()
- func (x *Commit) String() string
- type Hello
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetCommit() *Commit
- func (x *Message) GetHello() *Hello
- func (x *Message) GetNewView() *NewView
- func (x *Message) GetPrepare() *Prepare
- func (x *Message) GetReply() *Reply
- func (x *Message) GetReqViewChange() *ReqViewChange
- func (x *Message) GetRequest() *Request
- func (m *Message) GetTyped() isMessage_Typed
- func (x *Message) GetViewChange() *ViewChange
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type Message_Commit
- type Message_Hello
- type Message_NewView
- type Message_Prepare
- type Message_Reply
- type Message_ReqViewChange
- type Message_Request
- type Message_ViewChange
- type NewView
- func (*NewView) Descriptor() ([]byte, []int)deprecated
- func (x *NewView) GetNewView() uint64
- func (x *NewView) GetNvCert() []*ViewChange
- func (x *NewView) GetReplicaId() uint32
- func (x *NewView) GetUi() []byte
- func (*NewView) ProtoMessage()
- func (x *NewView) ProtoReflect() protoreflect.Message
- func (x *NewView) Reset()
- func (x *NewView) String() string
- type Prepare
- func (*Prepare) Descriptor() ([]byte, []int)deprecated
- func (x *Prepare) GetReplicaId() uint32
- func (x *Prepare) GetRequest() *Request
- func (x *Prepare) GetUi() []byte
- func (x *Prepare) GetView() uint64
- func (*Prepare) ProtoMessage()
- func (x *Prepare) ProtoReflect() protoreflect.Message
- func (x *Prepare) Reset()
- func (x *Prepare) String() string
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)deprecated
- func (x *Reply) GetClientId() uint32
- func (x *Reply) GetReplicaId() uint32
- func (x *Reply) GetResult() []byte
- func (x *Reply) GetSeq() uint64
- func (x *Reply) GetSignature() []byte
- func (*Reply) ProtoMessage()
- func (x *Reply) ProtoReflect() protoreflect.Message
- func (x *Reply) Reset()
- func (x *Reply) String() string
- type ReqViewChange
- func (*ReqViewChange) Descriptor() ([]byte, []int)deprecated
- func (x *ReqViewChange) GetNewView() uint64
- func (x *ReqViewChange) GetReplicaId() uint32
- func (x *ReqViewChange) GetSignature() []byte
- func (*ReqViewChange) ProtoMessage()
- func (x *ReqViewChange) ProtoReflect() protoreflect.Message
- func (x *ReqViewChange) Reset()
- func (x *ReqViewChange) String() string
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetClientId() uint32
- func (x *Request) GetOperation() []byte
- func (x *Request) GetSeq() uint64
- func (x *Request) GetSignature() []byte
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type ViewChange
- func (*ViewChange) Descriptor() ([]byte, []int)deprecated
- func (x *ViewChange) GetLog() []*Message
- func (x *ViewChange) GetNewView() uint64
- func (x *ViewChange) GetReplicaId() uint32
- func (x *ViewChange) GetUi() []byte
- func (x *ViewChange) GetVcCert() []*ReqViewChange
- func (*ViewChange) ProtoMessage()
- func (x *ViewChange) ProtoReflect() protoreflect.Message
- func (x *ViewChange) Reset()
- func (x *ViewChange) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_messages_proto protoreflect.FileDescriptor
Functions ¶
func MarshalOrPanic ¶
Types ¶
type Commit ¶
type Commit struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // Primary's proposal Proposal *Message `protobuf:"bytes,2,opt,name=proposal,proto3" json:"proposal,omitempty"` // Replica's UI Ui []byte `protobuf:"bytes,3,opt,name=ui,proto3" json:"ui,omitempty"` // contains filtered or unexported fields }
Commit represents COMMIT message.
func CommitFromAPI ¶
func (*Commit) Descriptor
deprecated
func (*Commit) GetProposal ¶
func (*Commit) GetReplicaId ¶
func (*Commit) ProtoMessage ¶
func (*Commit) ProtoMessage()
func (*Commit) ProtoReflect ¶
func (x *Commit) ProtoReflect() protoreflect.Message
type Hello ¶
type Hello struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // contains filtered or unexported fields }
Hello represents HELLO message.
func HelloFromAPI ¶
func (*Hello) Descriptor
deprecated
func (*Hello) GetReplicaId ¶
func (*Hello) ProtoMessage ¶
func (*Hello) ProtoMessage()
func (*Hello) ProtoReflect ¶
func (x *Hello) ProtoReflect() protoreflect.Message
type Message ¶
type Message struct { // Types that are assignable to Typed: // *Message_Hello // *Message_Request // *Message_Reply // *Message_Prepare // *Message_Commit // *Message_ReqViewChange // *Message_ViewChange // *Message_NewView Typed isMessage_Typed `protobuf_oneof:"typed"` // contains filtered or unexported fields }
Message represents arbitrary protocol message.
func WrapMessage ¶
func (*Message) Descriptor
deprecated
func (*Message) GetNewView ¶
func (*Message) GetPrepare ¶
func (*Message) GetReqViewChange ¶
func (x *Message) GetReqViewChange() *ReqViewChange
func (*Message) GetRequest ¶
func (*Message) GetViewChange ¶
func (x *Message) GetViewChange() *ViewChange
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type Message_Commit ¶
type Message_Commit struct {
Commit *Commit `protobuf:"bytes,5,opt,name=commit,proto3,oneof"`
}
type Message_Hello ¶
type Message_Hello struct {
Hello *Hello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}
type Message_NewView ¶
type Message_NewView struct {
NewView *NewView `protobuf:"bytes,8,opt,name=new_view,json=newView,proto3,oneof"`
}
type Message_Prepare ¶
type Message_Prepare struct {
Prepare *Prepare `protobuf:"bytes,4,opt,name=prepare,proto3,oneof"`
}
type Message_Reply ¶
type Message_Reply struct {
Reply *Reply `protobuf:"bytes,3,opt,name=reply,proto3,oneof"`
}
type Message_ReqViewChange ¶
type Message_ReqViewChange struct {
ReqViewChange *ReqViewChange `protobuf:"bytes,6,opt,name=req_view_change,json=reqViewChange,proto3,oneof"`
}
type Message_Request ¶
type Message_Request struct {
Request *Request `protobuf:"bytes,2,opt,name=request,proto3,oneof"`
}
type Message_ViewChange ¶
type Message_ViewChange struct {
ViewChange *ViewChange `protobuf:"bytes,7,opt,name=view_change,json=viewChange,proto3,oneof"`
}
type NewView ¶
type NewView struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // New view number NewView uint64 `protobuf:"varint,2,opt,name=new_view,json=newView,proto3" json:"new_view,omitempty"` // New view certificate NvCert []*ViewChange `protobuf:"bytes,3,rep,name=nv_cert,json=nvCert,proto3" json:"nv_cert,omitempty"` // Replicas's UI Ui []byte `protobuf:"bytes,4,opt,name=ui,proto3" json:"ui,omitempty"` // contains filtered or unexported fields }
NewView represents NEW-VIEW message.
func NewViewFromAPI ¶
func (*NewView) Descriptor
deprecated
func (*NewView) GetNewView ¶
func (*NewView) GetNvCert ¶
func (x *NewView) GetNvCert() []*ViewChange
func (*NewView) GetReplicaId ¶
func (*NewView) ProtoMessage ¶
func (*NewView) ProtoMessage()
func (*NewView) ProtoReflect ¶
func (x *NewView) ProtoReflect() protoreflect.Message
type Prepare ¶
type Prepare struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // View number View uint64 `protobuf:"varint,2,opt,name=view,proto3" json:"view,omitempty"` // Client's REQUEST Request *Request `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"` // Replica's UI Ui []byte `protobuf:"bytes,4,opt,name=ui,proto3" json:"ui,omitempty"` // contains filtered or unexported fields }
Prepare represents PREPARE message.
func PrepareFromAPI ¶
func (*Prepare) Descriptor
deprecated
func (*Prepare) GetReplicaId ¶
func (*Prepare) GetRequest ¶
func (*Prepare) ProtoMessage ¶
func (*Prepare) ProtoMessage()
func (*Prepare) ProtoReflect ¶
func (x *Prepare) ProtoReflect() protoreflect.Message
type Reply ¶
type Reply struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // Client identifier ClientId uint32 `protobuf:"varint,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` // Request identifier Seq uint64 `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"` // Result of requested operation execution Result []byte `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"` // Replica's signature Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Reply represents REPLY message.
func ReplyFromAPI ¶
func (*Reply) Descriptor
deprecated
func (*Reply) GetClientId ¶
func (*Reply) GetReplicaId ¶
func (*Reply) GetSignature ¶
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) ProtoReflect ¶
func (x *Reply) ProtoReflect() protoreflect.Message
type ReqViewChange ¶
type ReqViewChange struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // New view number NewView uint64 `protobuf:"varint,2,opt,name=new_view,json=newView,proto3" json:"new_view,omitempty"` // Replica's signature Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
ReqViewChange represents REQ-VIEW-CHANGE message.
func ReqViewChangeFromAPI ¶
func ReqViewChangeFromAPI(rvc messages.ReqViewChange) *ReqViewChange
func (*ReqViewChange) Descriptor
deprecated
func (*ReqViewChange) Descriptor() ([]byte, []int)
Deprecated: Use ReqViewChange.ProtoReflect.Descriptor instead.
func (*ReqViewChange) GetNewView ¶
func (x *ReqViewChange) GetNewView() uint64
func (*ReqViewChange) GetReplicaId ¶
func (x *ReqViewChange) GetReplicaId() uint32
func (*ReqViewChange) GetSignature ¶
func (x *ReqViewChange) GetSignature() []byte
func (*ReqViewChange) ProtoMessage ¶
func (*ReqViewChange) ProtoMessage()
func (*ReqViewChange) ProtoReflect ¶
func (x *ReqViewChange) ProtoReflect() protoreflect.Message
func (*ReqViewChange) Reset ¶
func (x *ReqViewChange) Reset()
func (*ReqViewChange) String ¶
func (x *ReqViewChange) String() string
type Request ¶
type Request struct { // Client identifier ClientId uint32 `protobuf:"varint,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` // Request identifier (timestamp / sequence number) Seq uint64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` // Operation to execute on replicated state machine Operation []byte `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"` // Client's signature Signature []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Request represents REQUEST message.
func RequestFromAPI ¶
func (*Request) Descriptor
deprecated
func (*Request) GetClientId ¶
func (*Request) GetOperation ¶
func (*Request) GetSignature ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type ViewChange ¶
type ViewChange struct { // Replica identifier ReplicaId uint32 `protobuf:"varint,1,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"` // New view number NewView uint64 `protobuf:"varint,2,opt,name=new_view,json=newView,proto3" json:"new_view,omitempty"` // Message log Log []*Message `protobuf:"bytes,4,rep,name=log,proto3" json:"log,omitempty"` // View change certificate VcCert []*ReqViewChange `protobuf:"bytes,5,rep,name=vc_cert,json=vcCert,proto3" json:"vc_cert,omitempty"` // Replicas's UI Ui []byte `protobuf:"bytes,6,opt,name=ui,proto3" json:"ui,omitempty"` // contains filtered or unexported fields }
ViewChange represents VIEW-CHANGE message.
func ViewChangeFromAPI ¶
func ViewChangeFromAPI(vc messages.ViewChange) *ViewChange
func (*ViewChange) Descriptor
deprecated
func (*ViewChange) Descriptor() ([]byte, []int)
Deprecated: Use ViewChange.ProtoReflect.Descriptor instead.
func (*ViewChange) GetLog ¶
func (x *ViewChange) GetLog() []*Message
func (*ViewChange) GetNewView ¶
func (x *ViewChange) GetNewView() uint64
func (*ViewChange) GetReplicaId ¶
func (x *ViewChange) GetReplicaId() uint32
func (*ViewChange) GetUi ¶
func (x *ViewChange) GetUi() []byte
func (*ViewChange) GetVcCert ¶
func (x *ViewChange) GetVcCert() []*ReqViewChange
func (*ViewChange) ProtoMessage ¶
func (*ViewChange) ProtoMessage()
func (*ViewChange) ProtoReflect ¶
func (x *ViewChange) ProtoReflect() protoreflect.Message
func (*ViewChange) Reset ¶
func (x *ViewChange) Reset()
func (*ViewChange) String ¶
func (x *ViewChange) String() string
Click to show internal directories.
Click to hide internal directories.