Documentation ¶
Index ¶
- Variables
- func RegisterClientServiceServer(s *grpc.Server, srv ClientServiceServer)
- func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)
- type Checkpoint
- type ClientMessage
- func (*ClientMessage) Descriptor() ([]byte, []int)
- func (this *ClientMessage) Equal(that interface{}) bool
- func (m *ClientMessage) GetCommand() *CommandRequest
- func (m *ClientMessage) GetCommandClose() *CommandClose
- func (m *ClientMessage) GetCommandReply() *CommandReply
- func (m *ClientMessage) GetMessage() isClientMessage_Message
- func (m *ClientMessage) GetQuery() *QueryRequest
- func (m *ClientMessage) GetQueryClose() *QueryClose
- func (m *ClientMessage) GetQueryReply() *QueryReply
- func (m *ClientMessage) Marshal() (dAtA []byte, err error)
- func (m *ClientMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *ClientMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClientMessage) ProtoMessage()
- func (m *ClientMessage) Reset()
- func (m *ClientMessage) Size() (n int)
- func (m *ClientMessage) String() string
- func (m *ClientMessage) Unmarshal(dAtA []byte) error
- func (m *ClientMessage) XXX_DiscardUnknown()
- func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientMessage) XXX_Merge(src proto.Message)
- func (*ClientMessage) XXX_OneofWrappers() []interface{}
- func (m *ClientMessage) XXX_Size() int
- func (m *ClientMessage) XXX_Unmarshal(b []byte) error
- type ClientMessage_Command
- type ClientMessage_CommandClose
- type ClientMessage_CommandReply
- type ClientMessage_Query
- type ClientMessage_QueryClose
- type ClientMessage_QueryReply
- type ClientServiceClient
- type ClientServiceServer
- type ClientService_ClientStreamClient
- type ClientService_ClientStreamServer
- type Cluster
- type CommandClose
- func (*CommandClose) Descriptor() ([]byte, []int)
- func (this *CommandClose) Equal(that interface{}) bool
- func (m *CommandClose) GetMessageNum() MessageID
- func (m *CommandClose) GetSender() MemberID
- func (m *CommandClose) GetViewID() *ViewId
- func (m *CommandClose) Marshal() (dAtA []byte, err error)
- func (m *CommandClose) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandClose) ProtoMessage()
- func (m *CommandClose) Reset()
- func (m *CommandClose) Size() (n int)
- func (m *CommandClose) String() string
- func (m *CommandClose) Unmarshal(dAtA []byte) error
- func (m *CommandClose) XXX_DiscardUnknown()
- func (m *CommandClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandClose) XXX_Merge(src proto.Message)
- func (m *CommandClose) XXX_Size() int
- func (m *CommandClose) XXX_Unmarshal(b []byte) error
- type CommandReply
- func (*CommandReply) Descriptor() ([]byte, []int)
- func (this *CommandReply) Equal(that interface{}) bool
- func (m *CommandReply) GetMessageNum() MessageID
- func (m *CommandReply) GetSender() MemberID
- func (m *CommandReply) GetSlotNum() LogSlotID
- func (m *CommandReply) GetValue() []byte
- func (m *CommandReply) GetViewID() *ViewId
- func (m *CommandReply) Marshal() (dAtA []byte, err error)
- func (m *CommandReply) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandReply) ProtoMessage()
- func (m *CommandReply) Reset()
- func (m *CommandReply) Size() (n int)
- func (m *CommandReply) String() string
- func (m *CommandReply) Unmarshal(dAtA []byte) error
- func (m *CommandReply) XXX_DiscardUnknown()
- func (m *CommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandReply) XXX_Merge(src proto.Message)
- func (m *CommandReply) XXX_Size() int
- func (m *CommandReply) XXX_Unmarshal(b []byte) error
- type CommandRequest
- func (*CommandRequest) Descriptor() ([]byte, []int)
- func (this *CommandRequest) Equal(that interface{}) bool
- func (m *CommandRequest) GetMessageNum() MessageID
- func (m *CommandRequest) GetSessionNum() SessionID
- func (m *CommandRequest) GetTimestamp() time.Time
- func (m *CommandRequest) GetValue() []byte
- func (m *CommandRequest) Marshal() (dAtA []byte, err error)
- func (m *CommandRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommandRequest) ProtoMessage()
- func (m *CommandRequest) Reset()
- func (m *CommandRequest) Size() (n int)
- func (m *CommandRequest) String() string
- func (m *CommandRequest) Unmarshal(dAtA []byte) error
- func (m *CommandRequest) XXX_DiscardUnknown()
- func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommandRequest) XXX_Merge(src proto.Message)
- func (m *CommandRequest) XXX_Size() int
- func (m *CommandRequest) XXX_Unmarshal(b []byte) error
- type GapCommitReply
- func (*GapCommitReply) Descriptor() ([]byte, []int)
- func (this *GapCommitReply) Equal(that interface{}) bool
- func (m *GapCommitReply) GetSender() MemberID
- func (m *GapCommitReply) GetSlotNum() LogSlotID
- func (m *GapCommitReply) GetViewID() *ViewId
- func (m *GapCommitReply) Marshal() (dAtA []byte, err error)
- func (m *GapCommitReply) MarshalTo(dAtA []byte) (int, error)
- func (m *GapCommitReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GapCommitReply) ProtoMessage()
- func (m *GapCommitReply) Reset()
- func (m *GapCommitReply) Size() (n int)
- func (m *GapCommitReply) String() string
- func (m *GapCommitReply) Unmarshal(dAtA []byte) error
- func (m *GapCommitReply) XXX_DiscardUnknown()
- func (m *GapCommitReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GapCommitReply) XXX_Merge(src proto.Message)
- func (m *GapCommitReply) XXX_Size() int
- func (m *GapCommitReply) XXX_Unmarshal(b []byte) error
- type GapCommitRequest
- func (*GapCommitRequest) Descriptor() ([]byte, []int)
- func (this *GapCommitRequest) Equal(that interface{}) bool
- func (m *GapCommitRequest) GetSender() MemberID
- func (m *GapCommitRequest) GetSlotNum() LogSlotID
- func (m *GapCommitRequest) GetViewID() *ViewId
- func (m *GapCommitRequest) Marshal() (dAtA []byte, err error)
- func (m *GapCommitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GapCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GapCommitRequest) ProtoMessage()
- func (m *GapCommitRequest) Reset()
- func (m *GapCommitRequest) Size() (n int)
- func (m *GapCommitRequest) String() string
- func (m *GapCommitRequest) Unmarshal(dAtA []byte) error
- func (m *GapCommitRequest) XXX_DiscardUnknown()
- func (m *GapCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GapCommitRequest) XXX_Merge(src proto.Message)
- func (m *GapCommitRequest) XXX_Size() int
- func (m *GapCommitRequest) XXX_Unmarshal(b []byte) error
- type Indexed
- func (*Indexed) Descriptor() ([]byte, []int)
- func (this *Indexed) Equal(that interface{}) bool
- func (m *Indexed) GetIndex() uint64
- func (m *Indexed) GetValue() []byte
- func (m *Indexed) Marshal() (dAtA []byte, err error)
- func (m *Indexed) MarshalTo(dAtA []byte) (int, error)
- func (m *Indexed) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Indexed) ProtoMessage()
- func (m *Indexed) Reset()
- func (m *Indexed) Size() (n int)
- func (m *Indexed) String() string
- func (m *Indexed) Unmarshal(dAtA []byte) error
- func (m *Indexed) XXX_DiscardUnknown()
- func (m *Indexed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Indexed) XXX_Merge(src proto.Message)
- func (m *Indexed) XXX_Size() int
- func (m *Indexed) XXX_Unmarshal(b []byte) error
- type LeaderID
- type Log
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)
- func (this *LogEntry) Equal(that interface{}) bool
- func (m *LogEntry) GetMessageNum() MessageID
- func (m *LogEntry) GetSlotNum() LogSlotID
- func (m *LogEntry) GetTimestamp() time.Time
- func (m *LogEntry) GetValue() []byte
- func (m *LogEntry) Marshal() (dAtA []byte, err error)
- func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) Size() (n int)
- func (m *LogEntry) String() string
- func (m *LogEntry) Unmarshal(dAtA []byte) error
- func (m *LogEntry) XXX_DiscardUnknown()
- func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogEntry) XXX_Merge(src proto.Message)
- func (m *LogEntry) XXX_Size() int
- func (m *LogEntry) XXX_Unmarshal(b []byte) error
- type LogSlotID
- type MemberID
- type MessageID
- type NOPaxos
- type Ping
- func (*Ping) Descriptor() ([]byte, []int)
- func (this *Ping) Equal(that interface{}) bool
- func (m *Ping) GetSender() MemberID
- func (m *Ping) GetViewID() *ViewId
- func (m *Ping) Marshal() (dAtA []byte, err error)
- func (m *Ping) MarshalTo(dAtA []byte) (int, error)
- func (m *Ping) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Ping) ProtoMessage()
- func (m *Ping) Reset()
- func (m *Ping) Size() (n int)
- func (m *Ping) String() string
- func (m *Ping) Unmarshal(dAtA []byte) error
- func (m *Ping) XXX_DiscardUnknown()
- func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Ping) XXX_Merge(src proto.Message)
- func (m *Ping) XXX_Size() int
- func (m *Ping) XXX_Unmarshal(b []byte) error
- type QueryClose
- func (*QueryClose) Descriptor() ([]byte, []int)
- func (this *QueryClose) Equal(that interface{}) bool
- func (m *QueryClose) GetMessageNum() MessageID
- func (m *QueryClose) GetSender() MemberID
- func (m *QueryClose) GetViewID() *ViewId
- func (m *QueryClose) Marshal() (dAtA []byte, err error)
- func (m *QueryClose) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryClose) ProtoMessage()
- func (m *QueryClose) Reset()
- func (m *QueryClose) Size() (n int)
- func (m *QueryClose) String() string
- func (m *QueryClose) Unmarshal(dAtA []byte) error
- func (m *QueryClose) XXX_DiscardUnknown()
- func (m *QueryClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryClose) XXX_Merge(src proto.Message)
- func (m *QueryClose) XXX_Size() int
- func (m *QueryClose) XXX_Unmarshal(b []byte) error
- type QueryReply
- func (*QueryReply) Descriptor() ([]byte, []int)
- func (this *QueryReply) Equal(that interface{}) bool
- func (m *QueryReply) GetMessageNum() MessageID
- func (m *QueryReply) GetSender() MemberID
- func (m *QueryReply) GetValue() []byte
- func (m *QueryReply) GetViewID() *ViewId
- func (m *QueryReply) Marshal() (dAtA []byte, err error)
- func (m *QueryReply) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryReply) ProtoMessage()
- func (m *QueryReply) Reset()
- func (m *QueryReply) Size() (n int)
- func (m *QueryReply) String() string
- func (m *QueryReply) Unmarshal(dAtA []byte) error
- func (m *QueryReply) XXX_DiscardUnknown()
- func (m *QueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryReply) XXX_Merge(src proto.Message)
- func (m *QueryReply) XXX_Size() int
- func (m *QueryReply) XXX_Unmarshal(b []byte) error
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)
- func (this *QueryRequest) Equal(that interface{}) bool
- func (m *QueryRequest) GetMessageNum() MessageID
- func (m *QueryRequest) GetSessionNum() SessionID
- func (m *QueryRequest) GetTimestamp() time.Time
- func (m *QueryRequest) GetValue() []byte
- func (m *QueryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryRequest) ProtoMessage()
- func (m *QueryRequest) Reset()
- func (m *QueryRequest) Size() (n int)
- func (m *QueryRequest) String() string
- func (m *QueryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryRequest) XXX_DiscardUnknown()
- func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryRequest) XXX_Merge(src proto.Message)
- func (m *QueryRequest) XXX_Size() int
- func (m *QueryRequest) XXX_Unmarshal(b []byte) error
- type Recover
- func (*Recover) Descriptor() ([]byte, []int)
- func (this *Recover) Equal(that interface{}) bool
- func (m *Recover) GetRecoveryID() string
- func (m *Recover) GetSender() MemberID
- func (m *Recover) Marshal() (dAtA []byte, err error)
- func (m *Recover) MarshalTo(dAtA []byte) (int, error)
- func (m *Recover) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Recover) ProtoMessage()
- func (m *Recover) Reset()
- func (m *Recover) Size() (n int)
- func (m *Recover) String() string
- func (m *Recover) Unmarshal(dAtA []byte) error
- func (m *Recover) XXX_DiscardUnknown()
- func (m *Recover) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Recover) XXX_Merge(src proto.Message)
- func (m *Recover) XXX_Size() int
- func (m *Recover) XXX_Unmarshal(b []byte) error
- type RecoverReply
- func (*RecoverReply) Descriptor() ([]byte, []int)
- func (this *RecoverReply) Equal(that interface{}) bool
- func (m *RecoverReply) GetCheckpoint() []byte
- func (m *RecoverReply) GetCheckpointSlotNum() LogSlotID
- func (m *RecoverReply) GetLog() []*LogEntry
- func (m *RecoverReply) GetMessageNum() MessageID
- func (m *RecoverReply) GetRecoveryID() string
- func (m *RecoverReply) GetSender() MemberID
- func (m *RecoverReply) GetViewID() *ViewId
- func (m *RecoverReply) Marshal() (dAtA []byte, err error)
- func (m *RecoverReply) MarshalTo(dAtA []byte) (int, error)
- func (m *RecoverReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecoverReply) ProtoMessage()
- func (m *RecoverReply) Reset()
- func (m *RecoverReply) Size() (n int)
- func (m *RecoverReply) String() string
- func (m *RecoverReply) Unmarshal(dAtA []byte) error
- func (m *RecoverReply) XXX_DiscardUnknown()
- func (m *RecoverReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoverReply) XXX_Merge(src proto.Message)
- func (m *RecoverReply) XXX_Size() int
- func (m *RecoverReply) XXX_Unmarshal(b []byte) error
- type ReplicaMessage
- func (*ReplicaMessage) Descriptor() ([]byte, []int)
- func (this *ReplicaMessage) Equal(that interface{}) bool
- func (m *ReplicaMessage) GetCommand() *CommandRequest
- func (m *ReplicaMessage) GetCommandReply() *CommandReply
- func (m *ReplicaMessage) GetGapCommit() *GapCommitRequest
- func (m *ReplicaMessage) GetGapCommitReply() *GapCommitReply
- func (m *ReplicaMessage) GetMessage() isReplicaMessage_Message
- func (m *ReplicaMessage) GetPing() *Ping
- func (m *ReplicaMessage) GetQuery() *QueryRequest
- func (m *ReplicaMessage) GetQueryReply() *QueryReply
- func (m *ReplicaMessage) GetRecover() *Recover
- func (m *ReplicaMessage) GetRecoverReply() *RecoverReply
- func (m *ReplicaMessage) GetSlotLookup() *SlotLookup
- func (m *ReplicaMessage) GetStartView() *StartView
- func (m *ReplicaMessage) GetSyncCommit() *SyncCommit
- func (m *ReplicaMessage) GetSyncPrepare() *SyncPrepare
- func (m *ReplicaMessage) GetSyncRepair() *SyncRepair
- func (m *ReplicaMessage) GetSyncRepairReply() *SyncRepairReply
- func (m *ReplicaMessage) GetSyncReply() *SyncReply
- func (m *ReplicaMessage) GetViewChange() *ViewChange
- func (m *ReplicaMessage) GetViewChangeRepair() *ViewChangeRepair
- func (m *ReplicaMessage) GetViewChangeRepairReply() *ViewChangeRepairReply
- func (m *ReplicaMessage) GetViewChangeRequest() *ViewChangeRequest
- func (m *ReplicaMessage) GetViewRepair() *ViewRepair
- func (m *ReplicaMessage) GetViewRepairReply() *ViewRepairReply
- func (m *ReplicaMessage) Marshal() (dAtA []byte, err error)
- func (m *ReplicaMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicaMessage) ProtoMessage()
- func (m *ReplicaMessage) Reset()
- func (m *ReplicaMessage) Size() (n int)
- func (m *ReplicaMessage) String() string
- func (m *ReplicaMessage) Unmarshal(dAtA []byte) error
- func (m *ReplicaMessage) XXX_DiscardUnknown()
- func (m *ReplicaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicaMessage) XXX_Merge(src proto.Message)
- func (*ReplicaMessage) XXX_OneofWrappers() []interface{}
- func (m *ReplicaMessage) XXX_Size() int
- func (m *ReplicaMessage) XXX_Unmarshal(b []byte) error
- type ReplicaMessage_Command
- type ReplicaMessage_CommandReply
- type ReplicaMessage_GapCommit
- type ReplicaMessage_GapCommitReply
- type ReplicaMessage_Ping
- type ReplicaMessage_Query
- type ReplicaMessage_QueryReply
- type ReplicaMessage_Recover
- type ReplicaMessage_RecoverReply
- type ReplicaMessage_SlotLookup
- type ReplicaMessage_StartView
- type ReplicaMessage_SyncCommit
- type ReplicaMessage_SyncPrepare
- type ReplicaMessage_SyncRepair
- type ReplicaMessage_SyncRepairReply
- type ReplicaMessage_SyncReply
- type ReplicaMessage_ViewChange
- type ReplicaMessage_ViewChangeRepair
- type ReplicaMessage_ViewChangeRepairReply
- func (this *ReplicaMessage_ViewChangeRepairReply) Equal(that interface{}) bool
- func (m *ReplicaMessage_ViewChangeRepairReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaMessage_ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *ReplicaMessage_ViewChangeRepairReply) Size() (n int)
- type ReplicaMessage_ViewChangeRequest
- func (this *ReplicaMessage_ViewChangeRequest) Equal(that interface{}) bool
- func (m *ReplicaMessage_ViewChangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaMessage_ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *ReplicaMessage_ViewChangeRequest) Size() (n int)
- type ReplicaMessage_ViewRepair
- type ReplicaMessage_ViewRepairReply
- type ReplicaServiceClient
- type ReplicaServiceServer
- type ReplicaService_ReplicaStreamClient
- type ReplicaService_ReplicaStreamServer
- type SessionID
- type SlotLookup
- func (*SlotLookup) Descriptor() ([]byte, []int)
- func (this *SlotLookup) Equal(that interface{}) bool
- func (m *SlotLookup) GetMessageNum() MessageID
- func (m *SlotLookup) GetSender() MemberID
- func (m *SlotLookup) GetViewID() *ViewId
- func (m *SlotLookup) Marshal() (dAtA []byte, err error)
- func (m *SlotLookup) MarshalTo(dAtA []byte) (int, error)
- func (m *SlotLookup) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SlotLookup) ProtoMessage()
- func (m *SlotLookup) Reset()
- func (m *SlotLookup) Size() (n int)
- func (m *SlotLookup) String() string
- func (m *SlotLookup) Unmarshal(dAtA []byte) error
- func (m *SlotLookup) XXX_DiscardUnknown()
- func (m *SlotLookup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SlotLookup) XXX_Merge(src proto.Message)
- func (m *SlotLookup) XXX_Size() int
- func (m *SlotLookup) XXX_Unmarshal(b []byte) error
- type StartView
- func (*StartView) Descriptor() ([]byte, []int)
- func (this *StartView) Equal(that interface{}) bool
- func (m *StartView) GetFirstLogSlotNum() LogSlotID
- func (m *StartView) GetLastLogSlotNum() LogSlotID
- func (m *StartView) GetMessageNum() MessageID
- func (m *StartView) GetNoOpFilter() []byte
- func (m *StartView) GetSender() MemberID
- func (m *StartView) GetViewID() *ViewId
- func (m *StartView) Marshal() (dAtA []byte, err error)
- func (m *StartView) MarshalTo(dAtA []byte) (int, error)
- func (m *StartView) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartView) ProtoMessage()
- func (m *StartView) Reset()
- func (m *StartView) Size() (n int)
- func (m *StartView) String() string
- func (m *StartView) Unmarshal(dAtA []byte) error
- func (m *StartView) XXX_DiscardUnknown()
- func (m *StartView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartView) XXX_Merge(src proto.Message)
- func (m *StartView) XXX_Size() int
- func (m *StartView) XXX_Unmarshal(b []byte) error
- type Status
- type SyncCommit
- func (*SyncCommit) Descriptor() ([]byte, []int)
- func (this *SyncCommit) Equal(that interface{}) bool
- func (m *SyncCommit) GetMessageNum() MessageID
- func (m *SyncCommit) GetSender() MemberID
- func (m *SyncCommit) GetSyncPoint() LogSlotID
- func (m *SyncCommit) GetViewID() *ViewId
- func (m *SyncCommit) Marshal() (dAtA []byte, err error)
- func (m *SyncCommit) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncCommit) ProtoMessage()
- func (m *SyncCommit) Reset()
- func (m *SyncCommit) Size() (n int)
- func (m *SyncCommit) String() string
- func (m *SyncCommit) Unmarshal(dAtA []byte) error
- func (m *SyncCommit) XXX_DiscardUnknown()
- func (m *SyncCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncCommit) XXX_Merge(src proto.Message)
- func (m *SyncCommit) XXX_Size() int
- func (m *SyncCommit) XXX_Unmarshal(b []byte) error
- type SyncPrepare
- func (*SyncPrepare) Descriptor() ([]byte, []int)
- func (this *SyncPrepare) Equal(that interface{}) bool
- func (m *SyncPrepare) GetFirstLogSlotNum() LogSlotID
- func (m *SyncPrepare) GetLastLogSlotNum() LogSlotID
- func (m *SyncPrepare) GetMessageNum() MessageID
- func (m *SyncPrepare) GetNoOpFilter() []byte
- func (m *SyncPrepare) GetSender() MemberID
- func (m *SyncPrepare) GetViewID() *ViewId
- func (m *SyncPrepare) Marshal() (dAtA []byte, err error)
- func (m *SyncPrepare) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncPrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncPrepare) ProtoMessage()
- func (m *SyncPrepare) Reset()
- func (m *SyncPrepare) Size() (n int)
- func (m *SyncPrepare) String() string
- func (m *SyncPrepare) Unmarshal(dAtA []byte) error
- func (m *SyncPrepare) XXX_DiscardUnknown()
- func (m *SyncPrepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncPrepare) XXX_Merge(src proto.Message)
- func (m *SyncPrepare) XXX_Size() int
- func (m *SyncPrepare) XXX_Unmarshal(b []byte) error
- type SyncRepair
- func (*SyncRepair) Descriptor() ([]byte, []int)
- func (this *SyncRepair) Equal(that interface{}) bool
- func (m *SyncRepair) GetCheckpoint() LogSlotID
- func (m *SyncRepair) GetSender() MemberID
- func (m *SyncRepair) GetSlotNums() []LogSlotID
- func (m *SyncRepair) GetViewID() *ViewId
- func (m *SyncRepair) Marshal() (dAtA []byte, err error)
- func (m *SyncRepair) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncRepair) ProtoMessage()
- func (m *SyncRepair) Reset()
- func (m *SyncRepair) Size() (n int)
- func (m *SyncRepair) String() string
- func (m *SyncRepair) Unmarshal(dAtA []byte) error
- func (m *SyncRepair) XXX_DiscardUnknown()
- func (m *SyncRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRepair) XXX_Merge(src proto.Message)
- func (m *SyncRepair) XXX_Size() int
- func (m *SyncRepair) XXX_Unmarshal(b []byte) error
- type SyncRepairReply
- func (*SyncRepairReply) Descriptor() ([]byte, []int)
- func (this *SyncRepairReply) Equal(that interface{}) bool
- func (m *SyncRepairReply) GetCheckpoint() []byte
- func (m *SyncRepairReply) GetCheckpointSlotNum() LogSlotID
- func (m *SyncRepairReply) GetEntries() []*LogEntry
- func (m *SyncRepairReply) GetSender() MemberID
- func (m *SyncRepairReply) GetViewID() *ViewId
- func (m *SyncRepairReply) Marshal() (dAtA []byte, err error)
- func (m *SyncRepairReply) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncRepairReply) ProtoMessage()
- func (m *SyncRepairReply) Reset()
- func (m *SyncRepairReply) Size() (n int)
- func (m *SyncRepairReply) String() string
- func (m *SyncRepairReply) Unmarshal(dAtA []byte) error
- func (m *SyncRepairReply) XXX_DiscardUnknown()
- func (m *SyncRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRepairReply) XXX_Merge(src proto.Message)
- func (m *SyncRepairReply) XXX_Size() int
- func (m *SyncRepairReply) XXX_Unmarshal(b []byte) error
- type SyncReply
- func (*SyncReply) Descriptor() ([]byte, []int)
- func (this *SyncReply) Equal(that interface{}) bool
- func (m *SyncReply) GetSender() MemberID
- func (m *SyncReply) GetSlotNum() LogSlotID
- func (m *SyncReply) GetViewID() *ViewId
- func (m *SyncReply) Marshal() (dAtA []byte, err error)
- func (m *SyncReply) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncReply) ProtoMessage()
- func (m *SyncReply) Reset()
- func (m *SyncReply) Size() (n int)
- func (m *SyncReply) String() string
- func (m *SyncReply) Unmarshal(dAtA []byte) error
- func (m *SyncReply) XXX_DiscardUnknown()
- func (m *SyncReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncReply) XXX_Merge(src proto.Message)
- func (m *SyncReply) XXX_Size() int
- func (m *SyncReply) XXX_Unmarshal(b []byte) error
- type UnimplementedClientServiceServer
- type UnimplementedReplicaServiceServer
- type ViewChange
- func (*ViewChange) Descriptor() ([]byte, []int)
- func (this *ViewChange) Equal(that interface{}) bool
- func (m *ViewChange) GetFirstLogSlotNum() LogSlotID
- func (m *ViewChange) GetLastLogSlotNum() LogSlotID
- func (m *ViewChange) GetLastNormal() *ViewId
- func (m *ViewChange) GetMessageNum() MessageID
- func (m *ViewChange) GetNoOpFilter() []byte
- func (m *ViewChange) GetSender() MemberID
- func (m *ViewChange) GetViewID() *ViewId
- func (m *ViewChange) Marshal() (dAtA []byte, err error)
- func (m *ViewChange) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewChange) ProtoMessage()
- func (m *ViewChange) Reset()
- func (m *ViewChange) Size() (n int)
- func (m *ViewChange) String() string
- func (m *ViewChange) Unmarshal(dAtA []byte) error
- func (m *ViewChange) XXX_DiscardUnknown()
- func (m *ViewChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewChange) XXX_Merge(src proto.Message)
- func (m *ViewChange) XXX_Size() int
- func (m *ViewChange) XXX_Unmarshal(b []byte) error
- type ViewChangeRepair
- func (*ViewChangeRepair) Descriptor() ([]byte, []int)
- func (this *ViewChangeRepair) Equal(that interface{}) bool
- func (m *ViewChangeRepair) GetCheckpoint() LogSlotID
- func (m *ViewChangeRepair) GetMessageNum() MessageID
- func (m *ViewChangeRepair) GetSender() MemberID
- func (m *ViewChangeRepair) GetSlotNums() []LogSlotID
- func (m *ViewChangeRepair) GetViewID() *ViewId
- func (m *ViewChangeRepair) Marshal() (dAtA []byte, err error)
- func (m *ViewChangeRepair) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewChangeRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewChangeRepair) ProtoMessage()
- func (m *ViewChangeRepair) Reset()
- func (m *ViewChangeRepair) Size() (n int)
- func (m *ViewChangeRepair) String() string
- func (m *ViewChangeRepair) Unmarshal(dAtA []byte) error
- func (m *ViewChangeRepair) XXX_DiscardUnknown()
- func (m *ViewChangeRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewChangeRepair) XXX_Merge(src proto.Message)
- func (m *ViewChangeRepair) XXX_Size() int
- func (m *ViewChangeRepair) XXX_Unmarshal(b []byte) error
- type ViewChangeRepairReply
- func (*ViewChangeRepairReply) Descriptor() ([]byte, []int)
- func (this *ViewChangeRepairReply) Equal(that interface{}) bool
- func (m *ViewChangeRepairReply) GetCheckpoint() []byte
- func (m *ViewChangeRepairReply) GetCheckpointSlotNum() LogSlotID
- func (m *ViewChangeRepairReply) GetMessageNum() MessageID
- func (m *ViewChangeRepairReply) GetSender() MemberID
- func (m *ViewChangeRepairReply) GetSlotNums() []LogSlotID
- func (m *ViewChangeRepairReply) GetViewID() *ViewId
- func (m *ViewChangeRepairReply) Marshal() (dAtA []byte, err error)
- func (m *ViewChangeRepairReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewChangeRepairReply) ProtoMessage()
- func (m *ViewChangeRepairReply) Reset()
- func (m *ViewChangeRepairReply) Size() (n int)
- func (m *ViewChangeRepairReply) String() string
- func (m *ViewChangeRepairReply) Unmarshal(dAtA []byte) error
- func (m *ViewChangeRepairReply) XXX_DiscardUnknown()
- func (m *ViewChangeRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewChangeRepairReply) XXX_Merge(src proto.Message)
- func (m *ViewChangeRepairReply) XXX_Size() int
- func (m *ViewChangeRepairReply) XXX_Unmarshal(b []byte) error
- type ViewChangeRequest
- func (*ViewChangeRequest) Descriptor() ([]byte, []int)
- func (this *ViewChangeRequest) Equal(that interface{}) bool
- func (m *ViewChangeRequest) GetSender() MemberID
- func (m *ViewChangeRequest) GetViewID() *ViewId
- func (m *ViewChangeRequest) Marshal() (dAtA []byte, err error)
- func (m *ViewChangeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewChangeRequest) ProtoMessage()
- func (m *ViewChangeRequest) Reset()
- func (m *ViewChangeRequest) Size() (n int)
- func (m *ViewChangeRequest) String() string
- func (m *ViewChangeRequest) Unmarshal(dAtA []byte) error
- func (m *ViewChangeRequest) XXX_DiscardUnknown()
- func (m *ViewChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewChangeRequest) XXX_Merge(src proto.Message)
- func (m *ViewChangeRequest) XXX_Size() int
- func (m *ViewChangeRequest) XXX_Unmarshal(b []byte) error
- type ViewId
- func (*ViewId) Descriptor() ([]byte, []int)
- func (this *ViewId) Equal(that interface{}) bool
- func (m *ViewId) GetLeaderNum() LeaderID
- func (m *ViewId) GetSessionNum() SessionID
- func (m *ViewId) Marshal() (dAtA []byte, err error)
- func (m *ViewId) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewId) ProtoMessage()
- func (m *ViewId) Reset()
- func (m *ViewId) Size() (n int)
- func (m *ViewId) String() string
- func (m *ViewId) Unmarshal(dAtA []byte) error
- func (m *ViewId) XXX_DiscardUnknown()
- func (m *ViewId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewId) XXX_Merge(src proto.Message)
- func (m *ViewId) XXX_Size() int
- func (m *ViewId) XXX_Unmarshal(b []byte) error
- type ViewRepair
- func (*ViewRepair) Descriptor() ([]byte, []int)
- func (this *ViewRepair) Equal(that interface{}) bool
- func (m *ViewRepair) GetCheckpoint() LogSlotID
- func (m *ViewRepair) GetMessageNum() MessageID
- func (m *ViewRepair) GetSender() MemberID
- func (m *ViewRepair) GetSlotNums() []LogSlotID
- func (m *ViewRepair) GetViewID() *ViewId
- func (m *ViewRepair) Marshal() (dAtA []byte, err error)
- func (m *ViewRepair) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewRepair) ProtoMessage()
- func (m *ViewRepair) Reset()
- func (m *ViewRepair) Size() (n int)
- func (m *ViewRepair) String() string
- func (m *ViewRepair) Unmarshal(dAtA []byte) error
- func (m *ViewRepair) XXX_DiscardUnknown()
- func (m *ViewRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewRepair) XXX_Merge(src proto.Message)
- func (m *ViewRepair) XXX_Size() int
- func (m *ViewRepair) XXX_Unmarshal(b []byte) error
- type ViewRepairReply
- func (*ViewRepairReply) Descriptor() ([]byte, []int)
- func (this *ViewRepairReply) Equal(that interface{}) bool
- func (m *ViewRepairReply) GetCheckpoint() []byte
- func (m *ViewRepairReply) GetCheckpointSlotNum() LogSlotID
- func (m *ViewRepairReply) GetEntries() []*LogEntry
- func (m *ViewRepairReply) GetSender() MemberID
- func (m *ViewRepairReply) GetViewID() *ViewId
- func (m *ViewRepairReply) Marshal() (dAtA []byte, err error)
- func (m *ViewRepairReply) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewRepairReply) ProtoMessage()
- func (m *ViewRepairReply) Reset()
- func (m *ViewRepairReply) Size() (n int)
- func (m *ViewRepairReply) String() string
- func (m *ViewRepairReply) Unmarshal(dAtA []byte) error
- func (m *ViewRepairReply) XXX_DiscardUnknown()
- func (m *ViewRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewRepairReply) XXX_Merge(src proto.Message)
- func (m *ViewRepairReply) XXX_Size() int
- func (m *ViewRepairReply) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterClientServiceServer ¶
func RegisterClientServiceServer(s *grpc.Server, srv ClientServiceServer)
func RegisterReplicaServiceServer ¶
func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)
Types ¶
type Checkpoint ¶
Checkpoint is a checkpoint of the state machine
func (*Checkpoint) Reader ¶
func (s *Checkpoint) Reader() io.ReadCloser
func (*Checkpoint) Writer ¶
func (s *Checkpoint) Writer() io.WriteCloser
type ClientMessage ¶
type ClientMessage struct { // Types that are valid to be assigned to Message: // *ClientMessage_Command // *ClientMessage_CommandReply // *ClientMessage_CommandClose // *ClientMessage_Query // *ClientMessage_QueryReply // *ClientMessage_QueryClose Message isClientMessage_Message `protobuf_oneof:"message"` }
func NewPopulatedClientMessage ¶
func NewPopulatedClientMessage(r randyProtocol, easy bool) *ClientMessage
func (*ClientMessage) Descriptor ¶
func (*ClientMessage) Descriptor() ([]byte, []int)
func (*ClientMessage) Equal ¶
func (this *ClientMessage) Equal(that interface{}) bool
func (*ClientMessage) GetCommand ¶
func (m *ClientMessage) GetCommand() *CommandRequest
func (*ClientMessage) GetCommandClose ¶
func (m *ClientMessage) GetCommandClose() *CommandClose
func (*ClientMessage) GetCommandReply ¶
func (m *ClientMessage) GetCommandReply() *CommandReply
func (*ClientMessage) GetMessage ¶
func (m *ClientMessage) GetMessage() isClientMessage_Message
func (*ClientMessage) GetQuery ¶
func (m *ClientMessage) GetQuery() *QueryRequest
func (*ClientMessage) GetQueryClose ¶
func (m *ClientMessage) GetQueryClose() *QueryClose
func (*ClientMessage) GetQueryReply ¶
func (m *ClientMessage) GetQueryReply() *QueryReply
func (*ClientMessage) Marshal ¶
func (m *ClientMessage) Marshal() (dAtA []byte, err error)
func (*ClientMessage) MarshalToSizedBuffer ¶
func (m *ClientMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage) ProtoMessage ¶
func (*ClientMessage) ProtoMessage()
func (*ClientMessage) Reset ¶
func (m *ClientMessage) Reset()
func (*ClientMessage) Size ¶
func (m *ClientMessage) Size() (n int)
func (*ClientMessage) String ¶
func (m *ClientMessage) String() string
func (*ClientMessage) Unmarshal ¶
func (m *ClientMessage) Unmarshal(dAtA []byte) error
func (*ClientMessage) XXX_DiscardUnknown ¶
func (m *ClientMessage) XXX_DiscardUnknown()
func (*ClientMessage) XXX_Marshal ¶
func (m *ClientMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientMessage) XXX_Merge ¶
func (m *ClientMessage) XXX_Merge(src proto.Message)
func (*ClientMessage) XXX_OneofWrappers ¶
func (*ClientMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ClientMessage) XXX_Size ¶
func (m *ClientMessage) XXX_Size() int
func (*ClientMessage) XXX_Unmarshal ¶
func (m *ClientMessage) XXX_Unmarshal(b []byte) error
type ClientMessage_Command ¶
type ClientMessage_Command struct {
Command *CommandRequest `protobuf:"bytes,1,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func NewPopulatedClientMessage_Command ¶
func NewPopulatedClientMessage_Command(r randyProtocol, easy bool) *ClientMessage_Command
func (*ClientMessage_Command) Equal ¶
func (this *ClientMessage_Command) Equal(that interface{}) bool
func (*ClientMessage_Command) MarshalTo ¶
func (m *ClientMessage_Command) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_Command) MarshalToSizedBuffer ¶
func (m *ClientMessage_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_Command) Size ¶
func (m *ClientMessage_Command) Size() (n int)
type ClientMessage_CommandClose ¶
type ClientMessage_CommandClose struct {
CommandClose *CommandClose `protobuf:"bytes,3,opt,name=command_close,json=commandClose,proto3,oneof" json:"command_close,omitempty"`
}
func NewPopulatedClientMessage_CommandClose ¶
func NewPopulatedClientMessage_CommandClose(r randyProtocol, easy bool) *ClientMessage_CommandClose
func (*ClientMessage_CommandClose) Equal ¶
func (this *ClientMessage_CommandClose) Equal(that interface{}) bool
func (*ClientMessage_CommandClose) MarshalTo ¶
func (m *ClientMessage_CommandClose) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_CommandClose) MarshalToSizedBuffer ¶
func (m *ClientMessage_CommandClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_CommandClose) Size ¶
func (m *ClientMessage_CommandClose) Size() (n int)
type ClientMessage_CommandReply ¶
type ClientMessage_CommandReply struct {
CommandReply *CommandReply `protobuf:"bytes,2,opt,name=command_reply,json=commandReply,proto3,oneof" json:"command_reply,omitempty"`
}
func NewPopulatedClientMessage_CommandReply ¶
func NewPopulatedClientMessage_CommandReply(r randyProtocol, easy bool) *ClientMessage_CommandReply
func (*ClientMessage_CommandReply) Equal ¶
func (this *ClientMessage_CommandReply) Equal(that interface{}) bool
func (*ClientMessage_CommandReply) MarshalTo ¶
func (m *ClientMessage_CommandReply) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_CommandReply) MarshalToSizedBuffer ¶
func (m *ClientMessage_CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_CommandReply) Size ¶
func (m *ClientMessage_CommandReply) Size() (n int)
type ClientMessage_Query ¶
type ClientMessage_Query struct {
Query *QueryRequest `protobuf:"bytes,4,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func NewPopulatedClientMessage_Query ¶
func NewPopulatedClientMessage_Query(r randyProtocol, easy bool) *ClientMessage_Query
func (*ClientMessage_Query) Equal ¶
func (this *ClientMessage_Query) Equal(that interface{}) bool
func (*ClientMessage_Query) MarshalTo ¶
func (m *ClientMessage_Query) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_Query) MarshalToSizedBuffer ¶
func (m *ClientMessage_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_Query) Size ¶
func (m *ClientMessage_Query) Size() (n int)
type ClientMessage_QueryClose ¶
type ClientMessage_QueryClose struct {
QueryClose *QueryClose `protobuf:"bytes,6,opt,name=query_close,json=queryClose,proto3,oneof" json:"query_close,omitempty"`
}
func NewPopulatedClientMessage_QueryClose ¶
func NewPopulatedClientMessage_QueryClose(r randyProtocol, easy bool) *ClientMessage_QueryClose
func (*ClientMessage_QueryClose) Equal ¶
func (this *ClientMessage_QueryClose) Equal(that interface{}) bool
func (*ClientMessage_QueryClose) MarshalTo ¶
func (m *ClientMessage_QueryClose) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_QueryClose) MarshalToSizedBuffer ¶
func (m *ClientMessage_QueryClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_QueryClose) Size ¶
func (m *ClientMessage_QueryClose) Size() (n int)
type ClientMessage_QueryReply ¶
type ClientMessage_QueryReply struct {
QueryReply *QueryReply `protobuf:"bytes,5,opt,name=query_reply,json=queryReply,proto3,oneof" json:"query_reply,omitempty"`
}
func NewPopulatedClientMessage_QueryReply ¶
func NewPopulatedClientMessage_QueryReply(r randyProtocol, easy bool) *ClientMessage_QueryReply
func (*ClientMessage_QueryReply) Equal ¶
func (this *ClientMessage_QueryReply) Equal(that interface{}) bool
func (*ClientMessage_QueryReply) MarshalTo ¶
func (m *ClientMessage_QueryReply) MarshalTo(dAtA []byte) (int, error)
func (*ClientMessage_QueryReply) MarshalToSizedBuffer ¶
func (m *ClientMessage_QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClientMessage_QueryReply) Size ¶
func (m *ClientMessage_QueryReply) Size() (n int)
type ClientServiceClient ¶
type ClientServiceClient interface {
ClientStream(ctx context.Context, opts ...grpc.CallOption) (ClientService_ClientStreamClient, error)
}
ClientServiceClient is the client API for ClientService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClientServiceClient ¶
func NewClientServiceClient(cc *grpc.ClientConn) ClientServiceClient
type ClientServiceServer ¶
type ClientServiceServer interface {
ClientStream(ClientService_ClientStreamServer) error
}
ClientServiceServer is the server API for ClientService service.
type ClientService_ClientStreamClient ¶
type ClientService_ClientStreamClient interface { Send(*ClientMessage) error Recv() (*ClientMessage, error) grpc.ClientStream }
type ClientService_ClientStreamServer ¶
type ClientService_ClientStreamServer interface { Send(*ClientMessage) error Recv() (*ClientMessage, error) grpc.ServerStream }
type Cluster ¶
type Cluster interface { // Member returns the local member ID Member() MemberID // Members returns a list of all members in the NOPaxos cluster Members() []MemberID // QuorumSize returns the cluster quorum size QuorumSize() int // GetStream gets a NOPaxosService_StreamClient connection for the given member GetStream(memberID MemberID) (ReplicaService_ReplicaStreamClient, error) }
Cluster provides cluster information for the NOPaxos protocol
func NewCluster ¶
NewCluster returns a new Cluster with the given configuration
type CommandClose ¶
type CommandClose struct { MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Sender MemberID `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` }
func NewPopulatedCommandClose ¶
func NewPopulatedCommandClose(r randyProtocol, easy bool) *CommandClose
func (*CommandClose) Descriptor ¶
func (*CommandClose) Descriptor() ([]byte, []int)
func (*CommandClose) Equal ¶
func (this *CommandClose) Equal(that interface{}) bool
func (*CommandClose) GetMessageNum ¶
func (m *CommandClose) GetMessageNum() MessageID
func (*CommandClose) GetSender ¶
func (m *CommandClose) GetSender() MemberID
func (*CommandClose) GetViewID ¶
func (m *CommandClose) GetViewID() *ViewId
func (*CommandClose) Marshal ¶
func (m *CommandClose) Marshal() (dAtA []byte, err error)
func (*CommandClose) MarshalToSizedBuffer ¶
func (m *CommandClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandClose) ProtoMessage ¶
func (*CommandClose) ProtoMessage()
func (*CommandClose) Reset ¶
func (m *CommandClose) Reset()
func (*CommandClose) Size ¶
func (m *CommandClose) Size() (n int)
func (*CommandClose) String ¶
func (m *CommandClose) String() string
func (*CommandClose) Unmarshal ¶
func (m *CommandClose) Unmarshal(dAtA []byte) error
func (*CommandClose) XXX_DiscardUnknown ¶
func (m *CommandClose) XXX_DiscardUnknown()
func (*CommandClose) XXX_Marshal ¶
func (m *CommandClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandClose) XXX_Merge ¶
func (m *CommandClose) XXX_Merge(src proto.Message)
func (*CommandClose) XXX_Size ¶
func (m *CommandClose) XXX_Size() int
func (*CommandClose) XXX_Unmarshal ¶
func (m *CommandClose) XXX_Unmarshal(b []byte) error
type CommandReply ¶
type CommandReply struct { MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Sender MemberID `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` SlotNum LogSlotID `protobuf:"varint,4,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"` Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedCommandReply ¶
func NewPopulatedCommandReply(r randyProtocol, easy bool) *CommandReply
func (*CommandReply) Descriptor ¶
func (*CommandReply) Descriptor() ([]byte, []int)
func (*CommandReply) Equal ¶
func (this *CommandReply) Equal(that interface{}) bool
func (*CommandReply) GetMessageNum ¶
func (m *CommandReply) GetMessageNum() MessageID
func (*CommandReply) GetSender ¶
func (m *CommandReply) GetSender() MemberID
func (*CommandReply) GetSlotNum ¶
func (m *CommandReply) GetSlotNum() LogSlotID
func (*CommandReply) GetValue ¶
func (m *CommandReply) GetValue() []byte
func (*CommandReply) GetViewID ¶
func (m *CommandReply) GetViewID() *ViewId
func (*CommandReply) Marshal ¶
func (m *CommandReply) Marshal() (dAtA []byte, err error)
func (*CommandReply) MarshalToSizedBuffer ¶
func (m *CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandReply) ProtoMessage ¶
func (*CommandReply) ProtoMessage()
func (*CommandReply) Reset ¶
func (m *CommandReply) Reset()
func (*CommandReply) Size ¶
func (m *CommandReply) Size() (n int)
func (*CommandReply) String ¶
func (m *CommandReply) String() string
func (*CommandReply) Unmarshal ¶
func (m *CommandReply) Unmarshal(dAtA []byte) error
func (*CommandReply) XXX_DiscardUnknown ¶
func (m *CommandReply) XXX_DiscardUnknown()
func (*CommandReply) XXX_Marshal ¶
func (m *CommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandReply) XXX_Merge ¶
func (m *CommandReply) XXX_Merge(src proto.Message)
func (*CommandReply) XXX_Size ¶
func (m *CommandReply) XXX_Size() int
func (*CommandReply) XXX_Unmarshal ¶
func (m *CommandReply) XXX_Unmarshal(b []byte) error
type CommandRequest ¶
type CommandRequest struct { SessionNum SessionID `protobuf:"varint,1,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"` MessageNum MessageID `protobuf:"varint,2,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedCommandRequest ¶
func NewPopulatedCommandRequest(r randyProtocol, easy bool) *CommandRequest
func (*CommandRequest) Descriptor ¶
func (*CommandRequest) Descriptor() ([]byte, []int)
func (*CommandRequest) Equal ¶
func (this *CommandRequest) Equal(that interface{}) bool
func (*CommandRequest) GetMessageNum ¶
func (m *CommandRequest) GetMessageNum() MessageID
func (*CommandRequest) GetSessionNum ¶
func (m *CommandRequest) GetSessionNum() SessionID
func (*CommandRequest) GetTimestamp ¶
func (m *CommandRequest) GetTimestamp() time.Time
func (*CommandRequest) GetValue ¶
func (m *CommandRequest) GetValue() []byte
func (*CommandRequest) Marshal ¶
func (m *CommandRequest) Marshal() (dAtA []byte, err error)
func (*CommandRequest) MarshalToSizedBuffer ¶
func (m *CommandRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommandRequest) ProtoMessage ¶
func (*CommandRequest) ProtoMessage()
func (*CommandRequest) Reset ¶
func (m *CommandRequest) Reset()
func (*CommandRequest) Size ¶
func (m *CommandRequest) Size() (n int)
func (*CommandRequest) String ¶
func (m *CommandRequest) String() string
func (*CommandRequest) Unmarshal ¶
func (m *CommandRequest) Unmarshal(dAtA []byte) error
func (*CommandRequest) XXX_DiscardUnknown ¶
func (m *CommandRequest) XXX_DiscardUnknown()
func (*CommandRequest) XXX_Marshal ¶
func (m *CommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommandRequest) XXX_Merge ¶
func (m *CommandRequest) XXX_Merge(src proto.Message)
func (*CommandRequest) XXX_Size ¶
func (m *CommandRequest) XXX_Size() int
func (*CommandRequest) XXX_Unmarshal ¶
func (m *CommandRequest) XXX_Unmarshal(b []byte) error
type GapCommitReply ¶
type GapCommitReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"` }
func NewPopulatedGapCommitReply ¶
func NewPopulatedGapCommitReply(r randyProtocol, easy bool) *GapCommitReply
func (*GapCommitReply) Descriptor ¶
func (*GapCommitReply) Descriptor() ([]byte, []int)
func (*GapCommitReply) Equal ¶
func (this *GapCommitReply) Equal(that interface{}) bool
func (*GapCommitReply) GetSender ¶
func (m *GapCommitReply) GetSender() MemberID
func (*GapCommitReply) GetSlotNum ¶
func (m *GapCommitReply) GetSlotNum() LogSlotID
func (*GapCommitReply) GetViewID ¶
func (m *GapCommitReply) GetViewID() *ViewId
func (*GapCommitReply) Marshal ¶
func (m *GapCommitReply) Marshal() (dAtA []byte, err error)
func (*GapCommitReply) MarshalToSizedBuffer ¶
func (m *GapCommitReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GapCommitReply) ProtoMessage ¶
func (*GapCommitReply) ProtoMessage()
func (*GapCommitReply) Reset ¶
func (m *GapCommitReply) Reset()
func (*GapCommitReply) Size ¶
func (m *GapCommitReply) Size() (n int)
func (*GapCommitReply) String ¶
func (m *GapCommitReply) String() string
func (*GapCommitReply) Unmarshal ¶
func (m *GapCommitReply) Unmarshal(dAtA []byte) error
func (*GapCommitReply) XXX_DiscardUnknown ¶
func (m *GapCommitReply) XXX_DiscardUnknown()
func (*GapCommitReply) XXX_Marshal ¶
func (m *GapCommitReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GapCommitReply) XXX_Merge ¶
func (m *GapCommitReply) XXX_Merge(src proto.Message)
func (*GapCommitReply) XXX_Size ¶
func (m *GapCommitReply) XXX_Size() int
func (*GapCommitReply) XXX_Unmarshal ¶
func (m *GapCommitReply) XXX_Unmarshal(b []byte) error
type GapCommitRequest ¶
type GapCommitRequest struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"` }
func NewPopulatedGapCommitRequest ¶
func NewPopulatedGapCommitRequest(r randyProtocol, easy bool) *GapCommitRequest
func (*GapCommitRequest) Descriptor ¶
func (*GapCommitRequest) Descriptor() ([]byte, []int)
func (*GapCommitRequest) Equal ¶
func (this *GapCommitRequest) Equal(that interface{}) bool
func (*GapCommitRequest) GetSender ¶
func (m *GapCommitRequest) GetSender() MemberID
func (*GapCommitRequest) GetSlotNum ¶
func (m *GapCommitRequest) GetSlotNum() LogSlotID
func (*GapCommitRequest) GetViewID ¶
func (m *GapCommitRequest) GetViewID() *ViewId
func (*GapCommitRequest) Marshal ¶
func (m *GapCommitRequest) Marshal() (dAtA []byte, err error)
func (*GapCommitRequest) MarshalToSizedBuffer ¶
func (m *GapCommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GapCommitRequest) ProtoMessage ¶
func (*GapCommitRequest) ProtoMessage()
func (*GapCommitRequest) Reset ¶
func (m *GapCommitRequest) Reset()
func (*GapCommitRequest) Size ¶
func (m *GapCommitRequest) Size() (n int)
func (*GapCommitRequest) String ¶
func (m *GapCommitRequest) String() string
func (*GapCommitRequest) Unmarshal ¶
func (m *GapCommitRequest) Unmarshal(dAtA []byte) error
func (*GapCommitRequest) XXX_DiscardUnknown ¶
func (m *GapCommitRequest) XXX_DiscardUnknown()
func (*GapCommitRequest) XXX_Marshal ¶
func (m *GapCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GapCommitRequest) XXX_Merge ¶
func (m *GapCommitRequest) XXX_Merge(src proto.Message)
func (*GapCommitRequest) XXX_Size ¶
func (m *GapCommitRequest) XXX_Size() int
func (*GapCommitRequest) XXX_Unmarshal ¶
func (m *GapCommitRequest) XXX_Unmarshal(b []byte) error
type Indexed ¶
type Indexed struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedIndexed ¶
func (*Indexed) Descriptor ¶
func (*Indexed) MarshalToSizedBuffer ¶
func (*Indexed) ProtoMessage ¶
func (*Indexed) ProtoMessage()
func (*Indexed) XXX_DiscardUnknown ¶
func (m *Indexed) XXX_DiscardUnknown()
func (*Indexed) XXX_Marshal ¶
func (*Indexed) XXX_Unmarshal ¶
type Log ¶
type Log struct {
// contains filtered or unexported fields
}
Log is a NOPaxos log
type LogEntry ¶
type LogEntry struct { SlotNum LogSlotID `protobuf:"varint,1,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"` Timestamp time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedLogEntry ¶
func (*LogEntry) Descriptor ¶
func (*LogEntry) GetMessageNum ¶
func (*LogEntry) GetSlotNum ¶
func (*LogEntry) GetTimestamp ¶
func (*LogEntry) MarshalToSizedBuffer ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) XXX_DiscardUnknown ¶
func (m *LogEntry) XXX_DiscardUnknown()
func (*LogEntry) XXX_Marshal ¶
func (*LogEntry) XXX_Unmarshal ¶
type NOPaxos ¶
type NOPaxos struct {
// contains filtered or unexported fields
}
NOPaxos is an interface for managing the state of the NOPaxos consensus protocol
func NewNOPaxos ¶
NewNOPaxos returns a new NOPaxos protocol state struct
func (*NOPaxos) ClientStream ¶
func (s *NOPaxos) ClientStream(stream ClientService_ClientStreamServer) error
func (*NOPaxos) ReplicaStream ¶
func (s *NOPaxos) ReplicaStream(stream ReplicaService_ReplicaStreamServer) error
type Ping ¶
type Ping struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` }
func NewPopulatedPing ¶
func (*Ping) Descriptor ¶
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) XXX_DiscardUnknown ¶
func (m *Ping) XXX_DiscardUnknown()
func (*Ping) XXX_Unmarshal ¶
type QueryClose ¶
type QueryClose struct { MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Sender MemberID `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` }
func NewPopulatedQueryClose ¶
func NewPopulatedQueryClose(r randyProtocol, easy bool) *QueryClose
func (*QueryClose) Descriptor ¶
func (*QueryClose) Descriptor() ([]byte, []int)
func (*QueryClose) Equal ¶
func (this *QueryClose) Equal(that interface{}) bool
func (*QueryClose) GetMessageNum ¶
func (m *QueryClose) GetMessageNum() MessageID
func (*QueryClose) GetSender ¶
func (m *QueryClose) GetSender() MemberID
func (*QueryClose) GetViewID ¶
func (m *QueryClose) GetViewID() *ViewId
func (*QueryClose) Marshal ¶
func (m *QueryClose) Marshal() (dAtA []byte, err error)
func (*QueryClose) MarshalToSizedBuffer ¶
func (m *QueryClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryClose) ProtoMessage ¶
func (*QueryClose) ProtoMessage()
func (*QueryClose) Reset ¶
func (m *QueryClose) Reset()
func (*QueryClose) Size ¶
func (m *QueryClose) Size() (n int)
func (*QueryClose) String ¶
func (m *QueryClose) String() string
func (*QueryClose) Unmarshal ¶
func (m *QueryClose) Unmarshal(dAtA []byte) error
func (*QueryClose) XXX_DiscardUnknown ¶
func (m *QueryClose) XXX_DiscardUnknown()
func (*QueryClose) XXX_Marshal ¶
func (m *QueryClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryClose) XXX_Merge ¶
func (m *QueryClose) XXX_Merge(src proto.Message)
func (*QueryClose) XXX_Size ¶
func (m *QueryClose) XXX_Size() int
func (*QueryClose) XXX_Unmarshal ¶
func (m *QueryClose) XXX_Unmarshal(b []byte) error
type QueryReply ¶
type QueryReply struct { MessageNum MessageID `protobuf:"varint,1,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Sender MemberID `protobuf:"bytes,2,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedQueryReply ¶
func NewPopulatedQueryReply(r randyProtocol, easy bool) *QueryReply
func (*QueryReply) Descriptor ¶
func (*QueryReply) Descriptor() ([]byte, []int)
func (*QueryReply) Equal ¶
func (this *QueryReply) Equal(that interface{}) bool
func (*QueryReply) GetMessageNum ¶
func (m *QueryReply) GetMessageNum() MessageID
func (*QueryReply) GetSender ¶
func (m *QueryReply) GetSender() MemberID
func (*QueryReply) GetValue ¶
func (m *QueryReply) GetValue() []byte
func (*QueryReply) GetViewID ¶
func (m *QueryReply) GetViewID() *ViewId
func (*QueryReply) Marshal ¶
func (m *QueryReply) Marshal() (dAtA []byte, err error)
func (*QueryReply) MarshalToSizedBuffer ¶
func (m *QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryReply) ProtoMessage ¶
func (*QueryReply) ProtoMessage()
func (*QueryReply) Reset ¶
func (m *QueryReply) Reset()
func (*QueryReply) Size ¶
func (m *QueryReply) Size() (n int)
func (*QueryReply) String ¶
func (m *QueryReply) String() string
func (*QueryReply) Unmarshal ¶
func (m *QueryReply) Unmarshal(dAtA []byte) error
func (*QueryReply) XXX_DiscardUnknown ¶
func (m *QueryReply) XXX_DiscardUnknown()
func (*QueryReply) XXX_Marshal ¶
func (m *QueryReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryReply) XXX_Merge ¶
func (m *QueryReply) XXX_Merge(src proto.Message)
func (*QueryReply) XXX_Size ¶
func (m *QueryReply) XXX_Size() int
func (*QueryReply) XXX_Unmarshal ¶
func (m *QueryReply) XXX_Unmarshal(b []byte) error
type QueryRequest ¶
type QueryRequest struct { SessionNum SessionID `protobuf:"varint,1,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"` MessageNum MessageID `protobuf:"varint,2,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Timestamp time.Time `protobuf:"bytes,3,opt,name=timestamp,proto3,stdtime" json:"timestamp"` Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"` }
func NewPopulatedQueryRequest ¶
func NewPopulatedQueryRequest(r randyProtocol, easy bool) *QueryRequest
func (*QueryRequest) Descriptor ¶
func (*QueryRequest) Descriptor() ([]byte, []int)
func (*QueryRequest) Equal ¶
func (this *QueryRequest) Equal(that interface{}) bool
func (*QueryRequest) GetMessageNum ¶
func (m *QueryRequest) GetMessageNum() MessageID
func (*QueryRequest) GetSessionNum ¶
func (m *QueryRequest) GetSessionNum() SessionID
func (*QueryRequest) GetTimestamp ¶
func (m *QueryRequest) GetTimestamp() time.Time
func (*QueryRequest) GetValue ¶
func (m *QueryRequest) GetValue() []byte
func (*QueryRequest) Marshal ¶
func (m *QueryRequest) Marshal() (dAtA []byte, err error)
func (*QueryRequest) MarshalToSizedBuffer ¶
func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) Reset ¶
func (m *QueryRequest) Reset()
func (*QueryRequest) Size ¶
func (m *QueryRequest) Size() (n int)
func (*QueryRequest) String ¶
func (m *QueryRequest) String() string
func (*QueryRequest) Unmarshal ¶
func (m *QueryRequest) Unmarshal(dAtA []byte) error
func (*QueryRequest) XXX_DiscardUnknown ¶
func (m *QueryRequest) XXX_DiscardUnknown()
func (*QueryRequest) XXX_Marshal ¶
func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryRequest) XXX_Merge ¶
func (m *QueryRequest) XXX_Merge(src proto.Message)
func (*QueryRequest) XXX_Size ¶
func (m *QueryRequest) XXX_Size() int
func (*QueryRequest) XXX_Unmarshal ¶
func (m *QueryRequest) XXX_Unmarshal(b []byte) error
type Recover ¶
type Recover struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` RecoveryID string `protobuf:"bytes,2,opt,name=recovery_id,json=recoveryId,proto3" json:"recovery_id,omitempty"` }
func NewPopulatedRecover ¶
func (*Recover) Descriptor ¶
func (*Recover) GetRecoveryID ¶
func (*Recover) MarshalToSizedBuffer ¶
func (*Recover) ProtoMessage ¶
func (*Recover) ProtoMessage()
func (*Recover) XXX_DiscardUnknown ¶
func (m *Recover) XXX_DiscardUnknown()
func (*Recover) XXX_Marshal ¶
func (*Recover) XXX_Unmarshal ¶
type RecoverReply ¶
type RecoverReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` RecoveryID string `protobuf:"bytes,2,opt,name=recovery_id,json=recoveryId,proto3" json:"recovery_id,omitempty"` ViewID *ViewId `protobuf:"bytes,3,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,4,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` CheckpointSlotNum LogSlotID `` /* 134-byte string literal not displayed */ Checkpoint []byte `protobuf:"bytes,6,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` Log []*LogEntry `protobuf:"bytes,7,rep,name=log,proto3" json:"log,omitempty"` }
func NewPopulatedRecoverReply ¶
func NewPopulatedRecoverReply(r randyProtocol, easy bool) *RecoverReply
func (*RecoverReply) Descriptor ¶
func (*RecoverReply) Descriptor() ([]byte, []int)
func (*RecoverReply) Equal ¶
func (this *RecoverReply) Equal(that interface{}) bool
func (*RecoverReply) GetCheckpoint ¶
func (m *RecoverReply) GetCheckpoint() []byte
func (*RecoverReply) GetCheckpointSlotNum ¶
func (m *RecoverReply) GetCheckpointSlotNum() LogSlotID
func (*RecoverReply) GetLog ¶
func (m *RecoverReply) GetLog() []*LogEntry
func (*RecoverReply) GetMessageNum ¶
func (m *RecoverReply) GetMessageNum() MessageID
func (*RecoverReply) GetRecoveryID ¶
func (m *RecoverReply) GetRecoveryID() string
func (*RecoverReply) GetSender ¶
func (m *RecoverReply) GetSender() MemberID
func (*RecoverReply) GetViewID ¶
func (m *RecoverReply) GetViewID() *ViewId
func (*RecoverReply) Marshal ¶
func (m *RecoverReply) Marshal() (dAtA []byte, err error)
func (*RecoverReply) MarshalToSizedBuffer ¶
func (m *RecoverReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecoverReply) ProtoMessage ¶
func (*RecoverReply) ProtoMessage()
func (*RecoverReply) Reset ¶
func (m *RecoverReply) Reset()
func (*RecoverReply) Size ¶
func (m *RecoverReply) Size() (n int)
func (*RecoverReply) String ¶
func (m *RecoverReply) String() string
func (*RecoverReply) Unmarshal ¶
func (m *RecoverReply) Unmarshal(dAtA []byte) error
func (*RecoverReply) XXX_DiscardUnknown ¶
func (m *RecoverReply) XXX_DiscardUnknown()
func (*RecoverReply) XXX_Marshal ¶
func (m *RecoverReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecoverReply) XXX_Merge ¶
func (m *RecoverReply) XXX_Merge(src proto.Message)
func (*RecoverReply) XXX_Size ¶
func (m *RecoverReply) XXX_Size() int
func (*RecoverReply) XXX_Unmarshal ¶
func (m *RecoverReply) XXX_Unmarshal(b []byte) error
type ReplicaMessage ¶
type ReplicaMessage struct { // Types that are valid to be assigned to Message: // *ReplicaMessage_Command // *ReplicaMessage_CommandReply // *ReplicaMessage_Query // *ReplicaMessage_QueryReply // *ReplicaMessage_SlotLookup // *ReplicaMessage_GapCommit // *ReplicaMessage_GapCommitReply // *ReplicaMessage_ViewChangeRequest // *ReplicaMessage_ViewChange // *ReplicaMessage_ViewChangeRepair // *ReplicaMessage_ViewChangeRepairReply // *ReplicaMessage_StartView // *ReplicaMessage_ViewRepair // *ReplicaMessage_ViewRepairReply // *ReplicaMessage_SyncPrepare // *ReplicaMessage_SyncRepair // *ReplicaMessage_SyncRepairReply // *ReplicaMessage_SyncReply // *ReplicaMessage_SyncCommit // *ReplicaMessage_Recover // *ReplicaMessage_RecoverReply // *ReplicaMessage_Ping Message isReplicaMessage_Message `protobuf_oneof:"message"` }
func NewPopulatedReplicaMessage ¶
func NewPopulatedReplicaMessage(r randyProtocol, easy bool) *ReplicaMessage
func (*ReplicaMessage) Descriptor ¶
func (*ReplicaMessage) Descriptor() ([]byte, []int)
func (*ReplicaMessage) Equal ¶
func (this *ReplicaMessage) Equal(that interface{}) bool
func (*ReplicaMessage) GetCommand ¶
func (m *ReplicaMessage) GetCommand() *CommandRequest
func (*ReplicaMessage) GetCommandReply ¶
func (m *ReplicaMessage) GetCommandReply() *CommandReply
func (*ReplicaMessage) GetGapCommit ¶
func (m *ReplicaMessage) GetGapCommit() *GapCommitRequest
func (*ReplicaMessage) GetGapCommitReply ¶
func (m *ReplicaMessage) GetGapCommitReply() *GapCommitReply
func (*ReplicaMessage) GetMessage ¶
func (m *ReplicaMessage) GetMessage() isReplicaMessage_Message
func (*ReplicaMessage) GetPing ¶
func (m *ReplicaMessage) GetPing() *Ping
func (*ReplicaMessage) GetQuery ¶
func (m *ReplicaMessage) GetQuery() *QueryRequest
func (*ReplicaMessage) GetQueryReply ¶
func (m *ReplicaMessage) GetQueryReply() *QueryReply
func (*ReplicaMessage) GetRecover ¶
func (m *ReplicaMessage) GetRecover() *Recover
func (*ReplicaMessage) GetRecoverReply ¶
func (m *ReplicaMessage) GetRecoverReply() *RecoverReply
func (*ReplicaMessage) GetSlotLookup ¶
func (m *ReplicaMessage) GetSlotLookup() *SlotLookup
func (*ReplicaMessage) GetStartView ¶
func (m *ReplicaMessage) GetStartView() *StartView
func (*ReplicaMessage) GetSyncCommit ¶
func (m *ReplicaMessage) GetSyncCommit() *SyncCommit
func (*ReplicaMessage) GetSyncPrepare ¶
func (m *ReplicaMessage) GetSyncPrepare() *SyncPrepare
func (*ReplicaMessage) GetSyncRepair ¶
func (m *ReplicaMessage) GetSyncRepair() *SyncRepair
func (*ReplicaMessage) GetSyncRepairReply ¶
func (m *ReplicaMessage) GetSyncRepairReply() *SyncRepairReply
func (*ReplicaMessage) GetSyncReply ¶
func (m *ReplicaMessage) GetSyncReply() *SyncReply
func (*ReplicaMessage) GetViewChange ¶
func (m *ReplicaMessage) GetViewChange() *ViewChange
func (*ReplicaMessage) GetViewChangeRepair ¶
func (m *ReplicaMessage) GetViewChangeRepair() *ViewChangeRepair
func (*ReplicaMessage) GetViewChangeRepairReply ¶
func (m *ReplicaMessage) GetViewChangeRepairReply() *ViewChangeRepairReply
func (*ReplicaMessage) GetViewChangeRequest ¶
func (m *ReplicaMessage) GetViewChangeRequest() *ViewChangeRequest
func (*ReplicaMessage) GetViewRepair ¶
func (m *ReplicaMessage) GetViewRepair() *ViewRepair
func (*ReplicaMessage) GetViewRepairReply ¶
func (m *ReplicaMessage) GetViewRepairReply() *ViewRepairReply
func (*ReplicaMessage) Marshal ¶
func (m *ReplicaMessage) Marshal() (dAtA []byte, err error)
func (*ReplicaMessage) MarshalToSizedBuffer ¶
func (m *ReplicaMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage) ProtoMessage ¶
func (*ReplicaMessage) ProtoMessage()
func (*ReplicaMessage) Reset ¶
func (m *ReplicaMessage) Reset()
func (*ReplicaMessage) Size ¶
func (m *ReplicaMessage) Size() (n int)
func (*ReplicaMessage) String ¶
func (m *ReplicaMessage) String() string
func (*ReplicaMessage) Unmarshal ¶
func (m *ReplicaMessage) Unmarshal(dAtA []byte) error
func (*ReplicaMessage) XXX_DiscardUnknown ¶
func (m *ReplicaMessage) XXX_DiscardUnknown()
func (*ReplicaMessage) XXX_Marshal ¶
func (m *ReplicaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicaMessage) XXX_Merge ¶
func (m *ReplicaMessage) XXX_Merge(src proto.Message)
func (*ReplicaMessage) XXX_OneofWrappers ¶
func (*ReplicaMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ReplicaMessage) XXX_Size ¶
func (m *ReplicaMessage) XXX_Size() int
func (*ReplicaMessage) XXX_Unmarshal ¶
func (m *ReplicaMessage) XXX_Unmarshal(b []byte) error
type ReplicaMessage_Command ¶
type ReplicaMessage_Command struct {
Command *CommandRequest `protobuf:"bytes,1,opt,name=command,proto3,oneof" json:"command,omitempty"`
}
func NewPopulatedReplicaMessage_Command ¶
func NewPopulatedReplicaMessage_Command(r randyProtocol, easy bool) *ReplicaMessage_Command
func (*ReplicaMessage_Command) Equal ¶
func (this *ReplicaMessage_Command) Equal(that interface{}) bool
func (*ReplicaMessage_Command) MarshalTo ¶
func (m *ReplicaMessage_Command) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_Command) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_Command) Size ¶
func (m *ReplicaMessage_Command) Size() (n int)
type ReplicaMessage_CommandReply ¶
type ReplicaMessage_CommandReply struct {
CommandReply *CommandReply `protobuf:"bytes,2,opt,name=command_reply,json=commandReply,proto3,oneof" json:"command_reply,omitempty"`
}
func NewPopulatedReplicaMessage_CommandReply ¶
func NewPopulatedReplicaMessage_CommandReply(r randyProtocol, easy bool) *ReplicaMessage_CommandReply
func (*ReplicaMessage_CommandReply) Equal ¶
func (this *ReplicaMessage_CommandReply) Equal(that interface{}) bool
func (*ReplicaMessage_CommandReply) MarshalTo ¶
func (m *ReplicaMessage_CommandReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_CommandReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_CommandReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_CommandReply) Size ¶
func (m *ReplicaMessage_CommandReply) Size() (n int)
type ReplicaMessage_GapCommit ¶
type ReplicaMessage_GapCommit struct {
GapCommit *GapCommitRequest `protobuf:"bytes,6,opt,name=gap_commit,json=gapCommit,proto3,oneof" json:"gap_commit,omitempty"`
}
func NewPopulatedReplicaMessage_GapCommit ¶
func NewPopulatedReplicaMessage_GapCommit(r randyProtocol, easy bool) *ReplicaMessage_GapCommit
func (*ReplicaMessage_GapCommit) Equal ¶
func (this *ReplicaMessage_GapCommit) Equal(that interface{}) bool
func (*ReplicaMessage_GapCommit) MarshalTo ¶
func (m *ReplicaMessage_GapCommit) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_GapCommit) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_GapCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_GapCommit) Size ¶
func (m *ReplicaMessage_GapCommit) Size() (n int)
type ReplicaMessage_GapCommitReply ¶
type ReplicaMessage_GapCommitReply struct {
GapCommitReply *GapCommitReply `protobuf:"bytes,7,opt,name=gap_commit_reply,json=gapCommitReply,proto3,oneof" json:"gap_commit_reply,omitempty"`
}
func NewPopulatedReplicaMessage_GapCommitReply ¶
func NewPopulatedReplicaMessage_GapCommitReply(r randyProtocol, easy bool) *ReplicaMessage_GapCommitReply
func (*ReplicaMessage_GapCommitReply) Equal ¶
func (this *ReplicaMessage_GapCommitReply) Equal(that interface{}) bool
func (*ReplicaMessage_GapCommitReply) MarshalTo ¶
func (m *ReplicaMessage_GapCommitReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_GapCommitReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_GapCommitReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_GapCommitReply) Size ¶
func (m *ReplicaMessage_GapCommitReply) Size() (n int)
type ReplicaMessage_Ping ¶
type ReplicaMessage_Ping struct {
Ping *Ping `protobuf:"bytes,22,opt,name=ping,proto3,oneof" json:"ping,omitempty"`
}
func NewPopulatedReplicaMessage_Ping ¶
func NewPopulatedReplicaMessage_Ping(r randyProtocol, easy bool) *ReplicaMessage_Ping
func (*ReplicaMessage_Ping) Equal ¶
func (this *ReplicaMessage_Ping) Equal(that interface{}) bool
func (*ReplicaMessage_Ping) MarshalTo ¶
func (m *ReplicaMessage_Ping) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_Ping) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_Ping) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_Ping) Size ¶
func (m *ReplicaMessage_Ping) Size() (n int)
type ReplicaMessage_Query ¶
type ReplicaMessage_Query struct {
Query *QueryRequest `protobuf:"bytes,3,opt,name=query,proto3,oneof" json:"query,omitempty"`
}
func NewPopulatedReplicaMessage_Query ¶
func NewPopulatedReplicaMessage_Query(r randyProtocol, easy bool) *ReplicaMessage_Query
func (*ReplicaMessage_Query) Equal ¶
func (this *ReplicaMessage_Query) Equal(that interface{}) bool
func (*ReplicaMessage_Query) MarshalTo ¶
func (m *ReplicaMessage_Query) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_Query) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_Query) Size ¶
func (m *ReplicaMessage_Query) Size() (n int)
type ReplicaMessage_QueryReply ¶
type ReplicaMessage_QueryReply struct {
QueryReply *QueryReply `protobuf:"bytes,4,opt,name=query_reply,json=queryReply,proto3,oneof" json:"query_reply,omitempty"`
}
func NewPopulatedReplicaMessage_QueryReply ¶
func NewPopulatedReplicaMessage_QueryReply(r randyProtocol, easy bool) *ReplicaMessage_QueryReply
func (*ReplicaMessage_QueryReply) Equal ¶
func (this *ReplicaMessage_QueryReply) Equal(that interface{}) bool
func (*ReplicaMessage_QueryReply) MarshalTo ¶
func (m *ReplicaMessage_QueryReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_QueryReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_QueryReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_QueryReply) Size ¶
func (m *ReplicaMessage_QueryReply) Size() (n int)
type ReplicaMessage_Recover ¶
type ReplicaMessage_Recover struct {
Recover *Recover `protobuf:"bytes,20,opt,name=recover,proto3,oneof" json:"recover,omitempty"`
}
func NewPopulatedReplicaMessage_Recover ¶
func NewPopulatedReplicaMessage_Recover(r randyProtocol, easy bool) *ReplicaMessage_Recover
func (*ReplicaMessage_Recover) Equal ¶
func (this *ReplicaMessage_Recover) Equal(that interface{}) bool
func (*ReplicaMessage_Recover) MarshalTo ¶
func (m *ReplicaMessage_Recover) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_Recover) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_Recover) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_Recover) Size ¶
func (m *ReplicaMessage_Recover) Size() (n int)
type ReplicaMessage_RecoverReply ¶
type ReplicaMessage_RecoverReply struct {
RecoverReply *RecoverReply `protobuf:"bytes,21,opt,name=recover_reply,json=recoverReply,proto3,oneof" json:"recover_reply,omitempty"`
}
func NewPopulatedReplicaMessage_RecoverReply ¶
func NewPopulatedReplicaMessage_RecoverReply(r randyProtocol, easy bool) *ReplicaMessage_RecoverReply
func (*ReplicaMessage_RecoverReply) Equal ¶
func (this *ReplicaMessage_RecoverReply) Equal(that interface{}) bool
func (*ReplicaMessage_RecoverReply) MarshalTo ¶
func (m *ReplicaMessage_RecoverReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_RecoverReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_RecoverReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_RecoverReply) Size ¶
func (m *ReplicaMessage_RecoverReply) Size() (n int)
type ReplicaMessage_SlotLookup ¶
type ReplicaMessage_SlotLookup struct {
SlotLookup *SlotLookup `protobuf:"bytes,5,opt,name=slot_lookup,json=slotLookup,proto3,oneof" json:"slot_lookup,omitempty"`
}
func NewPopulatedReplicaMessage_SlotLookup ¶
func NewPopulatedReplicaMessage_SlotLookup(r randyProtocol, easy bool) *ReplicaMessage_SlotLookup
func (*ReplicaMessage_SlotLookup) Equal ¶
func (this *ReplicaMessage_SlotLookup) Equal(that interface{}) bool
func (*ReplicaMessage_SlotLookup) MarshalTo ¶
func (m *ReplicaMessage_SlotLookup) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SlotLookup) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SlotLookup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SlotLookup) Size ¶
func (m *ReplicaMessage_SlotLookup) Size() (n int)
type ReplicaMessage_StartView ¶
type ReplicaMessage_StartView struct {
StartView *StartView `protobuf:"bytes,12,opt,name=start_view,json=startView,proto3,oneof" json:"start_view,omitempty"`
}
func NewPopulatedReplicaMessage_StartView ¶
func NewPopulatedReplicaMessage_StartView(r randyProtocol, easy bool) *ReplicaMessage_StartView
func (*ReplicaMessage_StartView) Equal ¶
func (this *ReplicaMessage_StartView) Equal(that interface{}) bool
func (*ReplicaMessage_StartView) MarshalTo ¶
func (m *ReplicaMessage_StartView) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_StartView) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_StartView) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_StartView) Size ¶
func (m *ReplicaMessage_StartView) Size() (n int)
type ReplicaMessage_SyncCommit ¶
type ReplicaMessage_SyncCommit struct {
SyncCommit *SyncCommit `protobuf:"bytes,19,opt,name=sync_commit,json=syncCommit,proto3,oneof" json:"sync_commit,omitempty"`
}
func NewPopulatedReplicaMessage_SyncCommit ¶
func NewPopulatedReplicaMessage_SyncCommit(r randyProtocol, easy bool) *ReplicaMessage_SyncCommit
func (*ReplicaMessage_SyncCommit) Equal ¶
func (this *ReplicaMessage_SyncCommit) Equal(that interface{}) bool
func (*ReplicaMessage_SyncCommit) MarshalTo ¶
func (m *ReplicaMessage_SyncCommit) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncCommit) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SyncCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncCommit) Size ¶
func (m *ReplicaMessage_SyncCommit) Size() (n int)
type ReplicaMessage_SyncPrepare ¶
type ReplicaMessage_SyncPrepare struct {
SyncPrepare *SyncPrepare `protobuf:"bytes,15,opt,name=sync_prepare,json=syncPrepare,proto3,oneof" json:"sync_prepare,omitempty"`
}
func NewPopulatedReplicaMessage_SyncPrepare ¶
func NewPopulatedReplicaMessage_SyncPrepare(r randyProtocol, easy bool) *ReplicaMessage_SyncPrepare
func (*ReplicaMessage_SyncPrepare) Equal ¶
func (this *ReplicaMessage_SyncPrepare) Equal(that interface{}) bool
func (*ReplicaMessage_SyncPrepare) MarshalTo ¶
func (m *ReplicaMessage_SyncPrepare) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncPrepare) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SyncPrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncPrepare) Size ¶
func (m *ReplicaMessage_SyncPrepare) Size() (n int)
type ReplicaMessage_SyncRepair ¶
type ReplicaMessage_SyncRepair struct {
SyncRepair *SyncRepair `protobuf:"bytes,16,opt,name=sync_repair,json=syncRepair,proto3,oneof" json:"sync_repair,omitempty"`
}
func NewPopulatedReplicaMessage_SyncRepair ¶
func NewPopulatedReplicaMessage_SyncRepair(r randyProtocol, easy bool) *ReplicaMessage_SyncRepair
func (*ReplicaMessage_SyncRepair) Equal ¶
func (this *ReplicaMessage_SyncRepair) Equal(that interface{}) bool
func (*ReplicaMessage_SyncRepair) MarshalTo ¶
func (m *ReplicaMessage_SyncRepair) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncRepair) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SyncRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncRepair) Size ¶
func (m *ReplicaMessage_SyncRepair) Size() (n int)
type ReplicaMessage_SyncRepairReply ¶
type ReplicaMessage_SyncRepairReply struct {
SyncRepairReply *SyncRepairReply `protobuf:"bytes,17,opt,name=sync_repair_reply,json=syncRepairReply,proto3,oneof" json:"sync_repair_reply,omitempty"`
}
func NewPopulatedReplicaMessage_SyncRepairReply ¶
func NewPopulatedReplicaMessage_SyncRepairReply(r randyProtocol, easy bool) *ReplicaMessage_SyncRepairReply
func (*ReplicaMessage_SyncRepairReply) Equal ¶
func (this *ReplicaMessage_SyncRepairReply) Equal(that interface{}) bool
func (*ReplicaMessage_SyncRepairReply) MarshalTo ¶
func (m *ReplicaMessage_SyncRepairReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncRepairReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SyncRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncRepairReply) Size ¶
func (m *ReplicaMessage_SyncRepairReply) Size() (n int)
type ReplicaMessage_SyncReply ¶
type ReplicaMessage_SyncReply struct {
SyncReply *SyncReply `protobuf:"bytes,18,opt,name=sync_reply,json=syncReply,proto3,oneof" json:"sync_reply,omitempty"`
}
func NewPopulatedReplicaMessage_SyncReply ¶
func NewPopulatedReplicaMessage_SyncReply(r randyProtocol, easy bool) *ReplicaMessage_SyncReply
func (*ReplicaMessage_SyncReply) Equal ¶
func (this *ReplicaMessage_SyncReply) Equal(that interface{}) bool
func (*ReplicaMessage_SyncReply) MarshalTo ¶
func (m *ReplicaMessage_SyncReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_SyncReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_SyncReply) Size ¶
func (m *ReplicaMessage_SyncReply) Size() (n int)
type ReplicaMessage_ViewChange ¶
type ReplicaMessage_ViewChange struct {
ViewChange *ViewChange `protobuf:"bytes,9,opt,name=view_change,json=viewChange,proto3,oneof" json:"view_change,omitempty"`
}
func NewPopulatedReplicaMessage_ViewChange ¶
func NewPopulatedReplicaMessage_ViewChange(r randyProtocol, easy bool) *ReplicaMessage_ViewChange
func (*ReplicaMessage_ViewChange) Equal ¶
func (this *ReplicaMessage_ViewChange) Equal(that interface{}) bool
func (*ReplicaMessage_ViewChange) MarshalTo ¶
func (m *ReplicaMessage_ViewChange) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChange) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChange) Size ¶
func (m *ReplicaMessage_ViewChange) Size() (n int)
type ReplicaMessage_ViewChangeRepair ¶
type ReplicaMessage_ViewChangeRepair struct {
ViewChangeRepair *ViewChangeRepair `protobuf:"bytes,10,opt,name=view_change_repair,json=viewChangeRepair,proto3,oneof" json:"view_change_repair,omitempty"`
}
func NewPopulatedReplicaMessage_ViewChangeRepair ¶
func NewPopulatedReplicaMessage_ViewChangeRepair(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRepair
func (*ReplicaMessage_ViewChangeRepair) Equal ¶
func (this *ReplicaMessage_ViewChangeRepair) Equal(that interface{}) bool
func (*ReplicaMessage_ViewChangeRepair) MarshalTo ¶
func (m *ReplicaMessage_ViewChangeRepair) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRepair) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewChangeRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRepair) Size ¶
func (m *ReplicaMessage_ViewChangeRepair) Size() (n int)
type ReplicaMessage_ViewChangeRepairReply ¶
type ReplicaMessage_ViewChangeRepairReply struct {
ViewChangeRepairReply *ViewChangeRepairReply `` /* 135-byte string literal not displayed */
}
func NewPopulatedReplicaMessage_ViewChangeRepairReply ¶
func NewPopulatedReplicaMessage_ViewChangeRepairReply(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRepairReply
func (*ReplicaMessage_ViewChangeRepairReply) Equal ¶
func (this *ReplicaMessage_ViewChangeRepairReply) Equal(that interface{}) bool
func (*ReplicaMessage_ViewChangeRepairReply) MarshalTo ¶
func (m *ReplicaMessage_ViewChangeRepairReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRepairReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRepairReply) Size ¶
func (m *ReplicaMessage_ViewChangeRepairReply) Size() (n int)
type ReplicaMessage_ViewChangeRequest ¶
type ReplicaMessage_ViewChangeRequest struct {
ViewChangeRequest *ViewChangeRequest `protobuf:"bytes,8,opt,name=view_change_request,json=viewChangeRequest,proto3,oneof" json:"view_change_request,omitempty"`
}
func NewPopulatedReplicaMessage_ViewChangeRequest ¶
func NewPopulatedReplicaMessage_ViewChangeRequest(r randyProtocol, easy bool) *ReplicaMessage_ViewChangeRequest
func (*ReplicaMessage_ViewChangeRequest) Equal ¶
func (this *ReplicaMessage_ViewChangeRequest) Equal(that interface{}) bool
func (*ReplicaMessage_ViewChangeRequest) MarshalTo ¶
func (m *ReplicaMessage_ViewChangeRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRequest) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewChangeRequest) Size ¶
func (m *ReplicaMessage_ViewChangeRequest) Size() (n int)
type ReplicaMessage_ViewRepair ¶
type ReplicaMessage_ViewRepair struct {
ViewRepair *ViewRepair `protobuf:"bytes,13,opt,name=view_repair,json=viewRepair,proto3,oneof" json:"view_repair,omitempty"`
}
func NewPopulatedReplicaMessage_ViewRepair ¶
func NewPopulatedReplicaMessage_ViewRepair(r randyProtocol, easy bool) *ReplicaMessage_ViewRepair
func (*ReplicaMessage_ViewRepair) Equal ¶
func (this *ReplicaMessage_ViewRepair) Equal(that interface{}) bool
func (*ReplicaMessage_ViewRepair) MarshalTo ¶
func (m *ReplicaMessage_ViewRepair) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewRepair) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewRepair) Size ¶
func (m *ReplicaMessage_ViewRepair) Size() (n int)
type ReplicaMessage_ViewRepairReply ¶
type ReplicaMessage_ViewRepairReply struct {
ViewRepairReply *ViewRepairReply `protobuf:"bytes,14,opt,name=view_repair_reply,json=viewRepairReply,proto3,oneof" json:"view_repair_reply,omitempty"`
}
func NewPopulatedReplicaMessage_ViewRepairReply ¶
func NewPopulatedReplicaMessage_ViewRepairReply(r randyProtocol, easy bool) *ReplicaMessage_ViewRepairReply
func (*ReplicaMessage_ViewRepairReply) Equal ¶
func (this *ReplicaMessage_ViewRepairReply) Equal(that interface{}) bool
func (*ReplicaMessage_ViewRepairReply) MarshalTo ¶
func (m *ReplicaMessage_ViewRepairReply) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewRepairReply) MarshalToSizedBuffer ¶
func (m *ReplicaMessage_ViewRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaMessage_ViewRepairReply) Size ¶
func (m *ReplicaMessage_ViewRepairReply) Size() (n int)
type ReplicaServiceClient ¶
type ReplicaServiceClient interface {
ReplicaStream(ctx context.Context, opts ...grpc.CallOption) (ReplicaService_ReplicaStreamClient, error)
}
ReplicaServiceClient is the client API for ReplicaService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewReplicaServiceClient ¶
func NewReplicaServiceClient(cc *grpc.ClientConn) ReplicaServiceClient
type ReplicaServiceServer ¶
type ReplicaServiceServer interface {
ReplicaStream(ReplicaService_ReplicaStreamServer) error
}
ReplicaServiceServer is the server API for ReplicaService service.
type ReplicaService_ReplicaStreamClient ¶
type ReplicaService_ReplicaStreamClient interface { Send(*ReplicaMessage) error Recv() (*ReplicaMessage, error) grpc.ClientStream }
type ReplicaService_ReplicaStreamServer ¶
type ReplicaService_ReplicaStreamServer interface { Send(*ReplicaMessage) error Recv() (*ReplicaMessage, error) grpc.ServerStream }
type SlotLookup ¶
type SlotLookup struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` }
func NewPopulatedSlotLookup ¶
func NewPopulatedSlotLookup(r randyProtocol, easy bool) *SlotLookup
func (*SlotLookup) Descriptor ¶
func (*SlotLookup) Descriptor() ([]byte, []int)
func (*SlotLookup) Equal ¶
func (this *SlotLookup) Equal(that interface{}) bool
func (*SlotLookup) GetMessageNum ¶
func (m *SlotLookup) GetMessageNum() MessageID
func (*SlotLookup) GetSender ¶
func (m *SlotLookup) GetSender() MemberID
func (*SlotLookup) GetViewID ¶
func (m *SlotLookup) GetViewID() *ViewId
func (*SlotLookup) Marshal ¶
func (m *SlotLookup) Marshal() (dAtA []byte, err error)
func (*SlotLookup) MarshalToSizedBuffer ¶
func (m *SlotLookup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SlotLookup) ProtoMessage ¶
func (*SlotLookup) ProtoMessage()
func (*SlotLookup) Reset ¶
func (m *SlotLookup) Reset()
func (*SlotLookup) Size ¶
func (m *SlotLookup) Size() (n int)
func (*SlotLookup) String ¶
func (m *SlotLookup) String() string
func (*SlotLookup) Unmarshal ¶
func (m *SlotLookup) Unmarshal(dAtA []byte) error
func (*SlotLookup) XXX_DiscardUnknown ¶
func (m *SlotLookup) XXX_DiscardUnknown()
func (*SlotLookup) XXX_Marshal ¶
func (m *SlotLookup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlotLookup) XXX_Merge ¶
func (m *SlotLookup) XXX_Merge(src proto.Message)
func (*SlotLookup) XXX_Size ¶
func (m *SlotLookup) XXX_Size() int
func (*SlotLookup) XXX_Unmarshal ¶
func (m *SlotLookup) XXX_Unmarshal(b []byte) error
type StartView ¶
type StartView struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` NoOpFilter []byte `protobuf:"bytes,4,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"` FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */ LastLogSlotNum LogSlotID `` /* 127-byte string literal not displayed */ }
func NewPopulatedStartView ¶
func (*StartView) Descriptor ¶
func (*StartView) GetFirstLogSlotNum ¶
func (*StartView) GetLastLogSlotNum ¶
func (*StartView) GetMessageNum ¶
func (*StartView) GetNoOpFilter ¶
func (*StartView) MarshalToSizedBuffer ¶
func (*StartView) ProtoMessage ¶
func (*StartView) ProtoMessage()
func (*StartView) XXX_DiscardUnknown ¶
func (m *StartView) XXX_DiscardUnknown()
func (*StartView) XXX_Marshal ¶
func (*StartView) XXX_Unmarshal ¶
type Status ¶
type Status string
Status is the protocol status
const ( // StatusRecovering is used by a recovering replica to avoid operating on old state StatusRecovering Status = "Recovering" // StatusNormal is the normal status StatusNormal Status = "Normal" // StatusViewChange is used to ignore certain messages during view changes StatusViewChange Status = "ViewChange" // StatusGapCommit indicates the replica is undergoing a gap commit StatusGapCommit Status = "GapCommit" )
type SyncCommit ¶
type SyncCommit struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` SyncPoint LogSlotID `protobuf:"varint,4,opt,name=sync_point,json=syncPoint,proto3,casttype=LogSlotID" json:"sync_point,omitempty"` }
func NewPopulatedSyncCommit ¶
func NewPopulatedSyncCommit(r randyProtocol, easy bool) *SyncCommit
func (*SyncCommit) Descriptor ¶
func (*SyncCommit) Descriptor() ([]byte, []int)
func (*SyncCommit) Equal ¶
func (this *SyncCommit) Equal(that interface{}) bool
func (*SyncCommit) GetMessageNum ¶
func (m *SyncCommit) GetMessageNum() MessageID
func (*SyncCommit) GetSender ¶
func (m *SyncCommit) GetSender() MemberID
func (*SyncCommit) GetSyncPoint ¶
func (m *SyncCommit) GetSyncPoint() LogSlotID
func (*SyncCommit) GetViewID ¶
func (m *SyncCommit) GetViewID() *ViewId
func (*SyncCommit) Marshal ¶
func (m *SyncCommit) Marshal() (dAtA []byte, err error)
func (*SyncCommit) MarshalToSizedBuffer ¶
func (m *SyncCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncCommit) ProtoMessage ¶
func (*SyncCommit) ProtoMessage()
func (*SyncCommit) Reset ¶
func (m *SyncCommit) Reset()
func (*SyncCommit) Size ¶
func (m *SyncCommit) Size() (n int)
func (*SyncCommit) String ¶
func (m *SyncCommit) String() string
func (*SyncCommit) Unmarshal ¶
func (m *SyncCommit) Unmarshal(dAtA []byte) error
func (*SyncCommit) XXX_DiscardUnknown ¶
func (m *SyncCommit) XXX_DiscardUnknown()
func (*SyncCommit) XXX_Marshal ¶
func (m *SyncCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncCommit) XXX_Merge ¶
func (m *SyncCommit) XXX_Merge(src proto.Message)
func (*SyncCommit) XXX_Size ¶
func (m *SyncCommit) XXX_Size() int
func (*SyncCommit) XXX_Unmarshal ¶
func (m *SyncCommit) XXX_Unmarshal(b []byte) error
type SyncPrepare ¶
type SyncPrepare struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` NoOpFilter []byte `protobuf:"bytes,4,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"` FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */ LastLogSlotNum LogSlotID `` /* 127-byte string literal not displayed */ }
func NewPopulatedSyncPrepare ¶
func NewPopulatedSyncPrepare(r randyProtocol, easy bool) *SyncPrepare
func (*SyncPrepare) Descriptor ¶
func (*SyncPrepare) Descriptor() ([]byte, []int)
func (*SyncPrepare) Equal ¶
func (this *SyncPrepare) Equal(that interface{}) bool
func (*SyncPrepare) GetFirstLogSlotNum ¶
func (m *SyncPrepare) GetFirstLogSlotNum() LogSlotID
func (*SyncPrepare) GetLastLogSlotNum ¶
func (m *SyncPrepare) GetLastLogSlotNum() LogSlotID
func (*SyncPrepare) GetMessageNum ¶
func (m *SyncPrepare) GetMessageNum() MessageID
func (*SyncPrepare) GetNoOpFilter ¶
func (m *SyncPrepare) GetNoOpFilter() []byte
func (*SyncPrepare) GetSender ¶
func (m *SyncPrepare) GetSender() MemberID
func (*SyncPrepare) GetViewID ¶
func (m *SyncPrepare) GetViewID() *ViewId
func (*SyncPrepare) Marshal ¶
func (m *SyncPrepare) Marshal() (dAtA []byte, err error)
func (*SyncPrepare) MarshalToSizedBuffer ¶
func (m *SyncPrepare) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncPrepare) ProtoMessage ¶
func (*SyncPrepare) ProtoMessage()
func (*SyncPrepare) Reset ¶
func (m *SyncPrepare) Reset()
func (*SyncPrepare) Size ¶
func (m *SyncPrepare) Size() (n int)
func (*SyncPrepare) String ¶
func (m *SyncPrepare) String() string
func (*SyncPrepare) Unmarshal ¶
func (m *SyncPrepare) Unmarshal(dAtA []byte) error
func (*SyncPrepare) XXX_DiscardUnknown ¶
func (m *SyncPrepare) XXX_DiscardUnknown()
func (*SyncPrepare) XXX_Marshal ¶
func (m *SyncPrepare) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncPrepare) XXX_Merge ¶
func (m *SyncPrepare) XXX_Merge(src proto.Message)
func (*SyncPrepare) XXX_Size ¶
func (m *SyncPrepare) XXX_Size() int
func (*SyncPrepare) XXX_Unmarshal ¶
func (m *SyncPrepare) XXX_Unmarshal(b []byte) error
type SyncRepair ¶
type SyncRepair struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` Checkpoint LogSlotID `protobuf:"varint,3,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"` SlotNums []LogSlotID `protobuf:"varint,4,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"` }
func NewPopulatedSyncRepair ¶
func NewPopulatedSyncRepair(r randyProtocol, easy bool) *SyncRepair
func (*SyncRepair) Descriptor ¶
func (*SyncRepair) Descriptor() ([]byte, []int)
func (*SyncRepair) Equal ¶
func (this *SyncRepair) Equal(that interface{}) bool
func (*SyncRepair) GetCheckpoint ¶
func (m *SyncRepair) GetCheckpoint() LogSlotID
func (*SyncRepair) GetSender ¶
func (m *SyncRepair) GetSender() MemberID
func (*SyncRepair) GetSlotNums ¶
func (m *SyncRepair) GetSlotNums() []LogSlotID
func (*SyncRepair) GetViewID ¶
func (m *SyncRepair) GetViewID() *ViewId
func (*SyncRepair) Marshal ¶
func (m *SyncRepair) Marshal() (dAtA []byte, err error)
func (*SyncRepair) MarshalToSizedBuffer ¶
func (m *SyncRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncRepair) ProtoMessage ¶
func (*SyncRepair) ProtoMessage()
func (*SyncRepair) Reset ¶
func (m *SyncRepair) Reset()
func (*SyncRepair) Size ¶
func (m *SyncRepair) Size() (n int)
func (*SyncRepair) String ¶
func (m *SyncRepair) String() string
func (*SyncRepair) Unmarshal ¶
func (m *SyncRepair) Unmarshal(dAtA []byte) error
func (*SyncRepair) XXX_DiscardUnknown ¶
func (m *SyncRepair) XXX_DiscardUnknown()
func (*SyncRepair) XXX_Marshal ¶
func (m *SyncRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRepair) XXX_Merge ¶
func (m *SyncRepair) XXX_Merge(src proto.Message)
func (*SyncRepair) XXX_Size ¶
func (m *SyncRepair) XXX_Size() int
func (*SyncRepair) XXX_Unmarshal ¶
func (m *SyncRepair) XXX_Unmarshal(b []byte) error
type SyncRepairReply ¶
type SyncRepairReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` CheckpointSlotNum LogSlotID `` /* 134-byte string literal not displayed */ Checkpoint []byte `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` Entries []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"` }
func NewPopulatedSyncRepairReply ¶
func NewPopulatedSyncRepairReply(r randyProtocol, easy bool) *SyncRepairReply
func (*SyncRepairReply) Descriptor ¶
func (*SyncRepairReply) Descriptor() ([]byte, []int)
func (*SyncRepairReply) Equal ¶
func (this *SyncRepairReply) Equal(that interface{}) bool
func (*SyncRepairReply) GetCheckpoint ¶
func (m *SyncRepairReply) GetCheckpoint() []byte
func (*SyncRepairReply) GetCheckpointSlotNum ¶
func (m *SyncRepairReply) GetCheckpointSlotNum() LogSlotID
func (*SyncRepairReply) GetEntries ¶
func (m *SyncRepairReply) GetEntries() []*LogEntry
func (*SyncRepairReply) GetSender ¶
func (m *SyncRepairReply) GetSender() MemberID
func (*SyncRepairReply) GetViewID ¶
func (m *SyncRepairReply) GetViewID() *ViewId
func (*SyncRepairReply) Marshal ¶
func (m *SyncRepairReply) Marshal() (dAtA []byte, err error)
func (*SyncRepairReply) MarshalToSizedBuffer ¶
func (m *SyncRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SyncRepairReply) ProtoMessage ¶
func (*SyncRepairReply) ProtoMessage()
func (*SyncRepairReply) Reset ¶
func (m *SyncRepairReply) Reset()
func (*SyncRepairReply) Size ¶
func (m *SyncRepairReply) Size() (n int)
func (*SyncRepairReply) String ¶
func (m *SyncRepairReply) String() string
func (*SyncRepairReply) Unmarshal ¶
func (m *SyncRepairReply) Unmarshal(dAtA []byte) error
func (*SyncRepairReply) XXX_DiscardUnknown ¶
func (m *SyncRepairReply) XXX_DiscardUnknown()
func (*SyncRepairReply) XXX_Marshal ¶
func (m *SyncRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncRepairReply) XXX_Merge ¶
func (m *SyncRepairReply) XXX_Merge(src proto.Message)
func (*SyncRepairReply) XXX_Size ¶
func (m *SyncRepairReply) XXX_Size() int
func (*SyncRepairReply) XXX_Unmarshal ¶
func (m *SyncRepairReply) XXX_Unmarshal(b []byte) error
type SyncReply ¶
type SyncReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` SlotNum LogSlotID `protobuf:"varint,3,opt,name=slot_num,json=slotNum,proto3,casttype=LogSlotID" json:"slot_num,omitempty"` }
func NewPopulatedSyncReply ¶
func (*SyncReply) Descriptor ¶
func (*SyncReply) GetSlotNum ¶
func (*SyncReply) MarshalToSizedBuffer ¶
func (*SyncReply) ProtoMessage ¶
func (*SyncReply) ProtoMessage()
func (*SyncReply) XXX_DiscardUnknown ¶
func (m *SyncReply) XXX_DiscardUnknown()
func (*SyncReply) XXX_Marshal ¶
func (*SyncReply) XXX_Unmarshal ¶
type UnimplementedClientServiceServer ¶
type UnimplementedClientServiceServer struct { }
UnimplementedClientServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedClientServiceServer) ClientStream ¶
func (*UnimplementedClientServiceServer) ClientStream(srv ClientService_ClientStreamServer) error
type UnimplementedReplicaServiceServer ¶
type UnimplementedReplicaServiceServer struct { }
UnimplementedReplicaServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedReplicaServiceServer) ReplicaStream ¶
func (*UnimplementedReplicaServiceServer) ReplicaStream(srv ReplicaService_ReplicaStreamServer) error
type ViewChange ¶
type ViewChange struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` LastNormal *ViewId `protobuf:"bytes,3,opt,name=last_normal,json=lastNormal,proto3" json:"last_normal,omitempty"` MessageNum MessageID `protobuf:"varint,4,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` NoOpFilter []byte `protobuf:"bytes,5,opt,name=no_op_filter,json=noOpFilter,proto3" json:"no_op_filter,omitempty"` FirstLogSlotNum LogSlotID `` /* 130-byte string literal not displayed */ LastLogSlotNum LogSlotID `` /* 127-byte string literal not displayed */ }
func NewPopulatedViewChange ¶
func NewPopulatedViewChange(r randyProtocol, easy bool) *ViewChange
func (*ViewChange) Descriptor ¶
func (*ViewChange) Descriptor() ([]byte, []int)
func (*ViewChange) Equal ¶
func (this *ViewChange) Equal(that interface{}) bool
func (*ViewChange) GetFirstLogSlotNum ¶
func (m *ViewChange) GetFirstLogSlotNum() LogSlotID
func (*ViewChange) GetLastLogSlotNum ¶
func (m *ViewChange) GetLastLogSlotNum() LogSlotID
func (*ViewChange) GetLastNormal ¶
func (m *ViewChange) GetLastNormal() *ViewId
func (*ViewChange) GetMessageNum ¶
func (m *ViewChange) GetMessageNum() MessageID
func (*ViewChange) GetNoOpFilter ¶
func (m *ViewChange) GetNoOpFilter() []byte
func (*ViewChange) GetSender ¶
func (m *ViewChange) GetSender() MemberID
func (*ViewChange) GetViewID ¶
func (m *ViewChange) GetViewID() *ViewId
func (*ViewChange) Marshal ¶
func (m *ViewChange) Marshal() (dAtA []byte, err error)
func (*ViewChange) MarshalToSizedBuffer ¶
func (m *ViewChange) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewChange) ProtoMessage ¶
func (*ViewChange) ProtoMessage()
func (*ViewChange) Reset ¶
func (m *ViewChange) Reset()
func (*ViewChange) Size ¶
func (m *ViewChange) Size() (n int)
func (*ViewChange) String ¶
func (m *ViewChange) String() string
func (*ViewChange) Unmarshal ¶
func (m *ViewChange) Unmarshal(dAtA []byte) error
func (*ViewChange) XXX_DiscardUnknown ¶
func (m *ViewChange) XXX_DiscardUnknown()
func (*ViewChange) XXX_Marshal ¶
func (m *ViewChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewChange) XXX_Merge ¶
func (m *ViewChange) XXX_Merge(src proto.Message)
func (*ViewChange) XXX_Size ¶
func (m *ViewChange) XXX_Size() int
func (*ViewChange) XXX_Unmarshal ¶
func (m *ViewChange) XXX_Unmarshal(b []byte) error
type ViewChangeRepair ¶
type ViewChangeRepair struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Checkpoint LogSlotID `protobuf:"varint,4,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"` SlotNums []LogSlotID `protobuf:"varint,5,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"` }
func NewPopulatedViewChangeRepair ¶
func NewPopulatedViewChangeRepair(r randyProtocol, easy bool) *ViewChangeRepair
func (*ViewChangeRepair) Descriptor ¶
func (*ViewChangeRepair) Descriptor() ([]byte, []int)
func (*ViewChangeRepair) Equal ¶
func (this *ViewChangeRepair) Equal(that interface{}) bool
func (*ViewChangeRepair) GetCheckpoint ¶
func (m *ViewChangeRepair) GetCheckpoint() LogSlotID
func (*ViewChangeRepair) GetMessageNum ¶
func (m *ViewChangeRepair) GetMessageNum() MessageID
func (*ViewChangeRepair) GetSender ¶
func (m *ViewChangeRepair) GetSender() MemberID
func (*ViewChangeRepair) GetSlotNums ¶
func (m *ViewChangeRepair) GetSlotNums() []LogSlotID
func (*ViewChangeRepair) GetViewID ¶
func (m *ViewChangeRepair) GetViewID() *ViewId
func (*ViewChangeRepair) Marshal ¶
func (m *ViewChangeRepair) Marshal() (dAtA []byte, err error)
func (*ViewChangeRepair) MarshalToSizedBuffer ¶
func (m *ViewChangeRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewChangeRepair) ProtoMessage ¶
func (*ViewChangeRepair) ProtoMessage()
func (*ViewChangeRepair) Reset ¶
func (m *ViewChangeRepair) Reset()
func (*ViewChangeRepair) Size ¶
func (m *ViewChangeRepair) Size() (n int)
func (*ViewChangeRepair) String ¶
func (m *ViewChangeRepair) String() string
func (*ViewChangeRepair) Unmarshal ¶
func (m *ViewChangeRepair) Unmarshal(dAtA []byte) error
func (*ViewChangeRepair) XXX_DiscardUnknown ¶
func (m *ViewChangeRepair) XXX_DiscardUnknown()
func (*ViewChangeRepair) XXX_Marshal ¶
func (m *ViewChangeRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewChangeRepair) XXX_Merge ¶
func (m *ViewChangeRepair) XXX_Merge(src proto.Message)
func (*ViewChangeRepair) XXX_Size ¶
func (m *ViewChangeRepair) XXX_Size() int
func (*ViewChangeRepair) XXX_Unmarshal ¶
func (m *ViewChangeRepair) XXX_Unmarshal(b []byte) error
type ViewChangeRepairReply ¶
type ViewChangeRepairReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` CheckpointSlotNum LogSlotID `` /* 134-byte string literal not displayed */ Checkpoint []byte `protobuf:"bytes,5,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` SlotNums []LogSlotID `protobuf:"varint,6,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"` }
func NewPopulatedViewChangeRepairReply ¶
func NewPopulatedViewChangeRepairReply(r randyProtocol, easy bool) *ViewChangeRepairReply
func (*ViewChangeRepairReply) Descriptor ¶
func (*ViewChangeRepairReply) Descriptor() ([]byte, []int)
func (*ViewChangeRepairReply) Equal ¶
func (this *ViewChangeRepairReply) Equal(that interface{}) bool
func (*ViewChangeRepairReply) GetCheckpoint ¶
func (m *ViewChangeRepairReply) GetCheckpoint() []byte
func (*ViewChangeRepairReply) GetCheckpointSlotNum ¶
func (m *ViewChangeRepairReply) GetCheckpointSlotNum() LogSlotID
func (*ViewChangeRepairReply) GetMessageNum ¶
func (m *ViewChangeRepairReply) GetMessageNum() MessageID
func (*ViewChangeRepairReply) GetSender ¶
func (m *ViewChangeRepairReply) GetSender() MemberID
func (*ViewChangeRepairReply) GetSlotNums ¶
func (m *ViewChangeRepairReply) GetSlotNums() []LogSlotID
func (*ViewChangeRepairReply) GetViewID ¶
func (m *ViewChangeRepairReply) GetViewID() *ViewId
func (*ViewChangeRepairReply) Marshal ¶
func (m *ViewChangeRepairReply) Marshal() (dAtA []byte, err error)
func (*ViewChangeRepairReply) MarshalTo ¶
func (m *ViewChangeRepairReply) MarshalTo(dAtA []byte) (int, error)
func (*ViewChangeRepairReply) MarshalToSizedBuffer ¶
func (m *ViewChangeRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewChangeRepairReply) ProtoMessage ¶
func (*ViewChangeRepairReply) ProtoMessage()
func (*ViewChangeRepairReply) Reset ¶
func (m *ViewChangeRepairReply) Reset()
func (*ViewChangeRepairReply) Size ¶
func (m *ViewChangeRepairReply) Size() (n int)
func (*ViewChangeRepairReply) String ¶
func (m *ViewChangeRepairReply) String() string
func (*ViewChangeRepairReply) Unmarshal ¶
func (m *ViewChangeRepairReply) Unmarshal(dAtA []byte) error
func (*ViewChangeRepairReply) XXX_DiscardUnknown ¶
func (m *ViewChangeRepairReply) XXX_DiscardUnknown()
func (*ViewChangeRepairReply) XXX_Marshal ¶
func (m *ViewChangeRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewChangeRepairReply) XXX_Merge ¶
func (m *ViewChangeRepairReply) XXX_Merge(src proto.Message)
func (*ViewChangeRepairReply) XXX_Size ¶
func (m *ViewChangeRepairReply) XXX_Size() int
func (*ViewChangeRepairReply) XXX_Unmarshal ¶
func (m *ViewChangeRepairReply) XXX_Unmarshal(b []byte) error
type ViewChangeRequest ¶
type ViewChangeRequest struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` }
func NewPopulatedViewChangeRequest ¶
func NewPopulatedViewChangeRequest(r randyProtocol, easy bool) *ViewChangeRequest
func (*ViewChangeRequest) Descriptor ¶
func (*ViewChangeRequest) Descriptor() ([]byte, []int)
func (*ViewChangeRequest) Equal ¶
func (this *ViewChangeRequest) Equal(that interface{}) bool
func (*ViewChangeRequest) GetSender ¶
func (m *ViewChangeRequest) GetSender() MemberID
func (*ViewChangeRequest) GetViewID ¶
func (m *ViewChangeRequest) GetViewID() *ViewId
func (*ViewChangeRequest) Marshal ¶
func (m *ViewChangeRequest) Marshal() (dAtA []byte, err error)
func (*ViewChangeRequest) MarshalTo ¶
func (m *ViewChangeRequest) MarshalTo(dAtA []byte) (int, error)
func (*ViewChangeRequest) MarshalToSizedBuffer ¶
func (m *ViewChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewChangeRequest) ProtoMessage ¶
func (*ViewChangeRequest) ProtoMessage()
func (*ViewChangeRequest) Reset ¶
func (m *ViewChangeRequest) Reset()
func (*ViewChangeRequest) Size ¶
func (m *ViewChangeRequest) Size() (n int)
func (*ViewChangeRequest) String ¶
func (m *ViewChangeRequest) String() string
func (*ViewChangeRequest) Unmarshal ¶
func (m *ViewChangeRequest) Unmarshal(dAtA []byte) error
func (*ViewChangeRequest) XXX_DiscardUnknown ¶
func (m *ViewChangeRequest) XXX_DiscardUnknown()
func (*ViewChangeRequest) XXX_Marshal ¶
func (m *ViewChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewChangeRequest) XXX_Merge ¶
func (m *ViewChangeRequest) XXX_Merge(src proto.Message)
func (*ViewChangeRequest) XXX_Size ¶
func (m *ViewChangeRequest) XXX_Size() int
func (*ViewChangeRequest) XXX_Unmarshal ¶
func (m *ViewChangeRequest) XXX_Unmarshal(b []byte) error
type ViewId ¶
type ViewId struct { LeaderNum LeaderID `protobuf:"varint,1,opt,name=leader_num,json=leaderNum,proto3,casttype=LeaderID" json:"leader_num,omitempty"` SessionNum SessionID `protobuf:"varint,2,opt,name=session_num,json=sessionNum,proto3,casttype=SessionID" json:"session_num,omitempty"` }
func NewPopulatedViewId ¶
func (*ViewId) Descriptor ¶
func (*ViewId) GetLeaderNum ¶
func (*ViewId) GetSessionNum ¶
func (*ViewId) MarshalToSizedBuffer ¶
func (*ViewId) ProtoMessage ¶
func (*ViewId) ProtoMessage()
func (*ViewId) XXX_DiscardUnknown ¶
func (m *ViewId) XXX_DiscardUnknown()
func (*ViewId) XXX_Marshal ¶
func (*ViewId) XXX_Unmarshal ¶
type ViewRepair ¶
type ViewRepair struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` MessageNum MessageID `protobuf:"varint,3,opt,name=message_num,json=messageNum,proto3,casttype=MessageID" json:"message_num,omitempty"` Checkpoint LogSlotID `protobuf:"varint,4,opt,name=checkpoint,proto3,casttype=LogSlotID" json:"checkpoint,omitempty"` SlotNums []LogSlotID `protobuf:"varint,5,rep,packed,name=slot_nums,json=slotNums,proto3,casttype=LogSlotID" json:"slot_nums,omitempty"` }
func NewPopulatedViewRepair ¶
func NewPopulatedViewRepair(r randyProtocol, easy bool) *ViewRepair
func (*ViewRepair) Descriptor ¶
func (*ViewRepair) Descriptor() ([]byte, []int)
func (*ViewRepair) Equal ¶
func (this *ViewRepair) Equal(that interface{}) bool
func (*ViewRepair) GetCheckpoint ¶
func (m *ViewRepair) GetCheckpoint() LogSlotID
func (*ViewRepair) GetMessageNum ¶
func (m *ViewRepair) GetMessageNum() MessageID
func (*ViewRepair) GetSender ¶
func (m *ViewRepair) GetSender() MemberID
func (*ViewRepair) GetSlotNums ¶
func (m *ViewRepair) GetSlotNums() []LogSlotID
func (*ViewRepair) GetViewID ¶
func (m *ViewRepair) GetViewID() *ViewId
func (*ViewRepair) Marshal ¶
func (m *ViewRepair) Marshal() (dAtA []byte, err error)
func (*ViewRepair) MarshalToSizedBuffer ¶
func (m *ViewRepair) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewRepair) ProtoMessage ¶
func (*ViewRepair) ProtoMessage()
func (*ViewRepair) Reset ¶
func (m *ViewRepair) Reset()
func (*ViewRepair) Size ¶
func (m *ViewRepair) Size() (n int)
func (*ViewRepair) String ¶
func (m *ViewRepair) String() string
func (*ViewRepair) Unmarshal ¶
func (m *ViewRepair) Unmarshal(dAtA []byte) error
func (*ViewRepair) XXX_DiscardUnknown ¶
func (m *ViewRepair) XXX_DiscardUnknown()
func (*ViewRepair) XXX_Marshal ¶
func (m *ViewRepair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewRepair) XXX_Merge ¶
func (m *ViewRepair) XXX_Merge(src proto.Message)
func (*ViewRepair) XXX_Size ¶
func (m *ViewRepair) XXX_Size() int
func (*ViewRepair) XXX_Unmarshal ¶
func (m *ViewRepair) XXX_Unmarshal(b []byte) error
type ViewRepairReply ¶
type ViewRepairReply struct { Sender MemberID `protobuf:"bytes,1,opt,name=sender,proto3,casttype=MemberID" json:"sender,omitempty"` ViewID *ViewId `protobuf:"bytes,2,opt,name=view_id,json=viewId,proto3" json:"view_id,omitempty"` CheckpointSlotNum LogSlotID `` /* 134-byte string literal not displayed */ Checkpoint []byte `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"` Entries []*LogEntry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"` }
func NewPopulatedViewRepairReply ¶
func NewPopulatedViewRepairReply(r randyProtocol, easy bool) *ViewRepairReply
func (*ViewRepairReply) Descriptor ¶
func (*ViewRepairReply) Descriptor() ([]byte, []int)
func (*ViewRepairReply) Equal ¶
func (this *ViewRepairReply) Equal(that interface{}) bool
func (*ViewRepairReply) GetCheckpoint ¶
func (m *ViewRepairReply) GetCheckpoint() []byte
func (*ViewRepairReply) GetCheckpointSlotNum ¶
func (m *ViewRepairReply) GetCheckpointSlotNum() LogSlotID
func (*ViewRepairReply) GetEntries ¶
func (m *ViewRepairReply) GetEntries() []*LogEntry
func (*ViewRepairReply) GetSender ¶
func (m *ViewRepairReply) GetSender() MemberID
func (*ViewRepairReply) GetViewID ¶
func (m *ViewRepairReply) GetViewID() *ViewId
func (*ViewRepairReply) Marshal ¶
func (m *ViewRepairReply) Marshal() (dAtA []byte, err error)
func (*ViewRepairReply) MarshalToSizedBuffer ¶
func (m *ViewRepairReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewRepairReply) ProtoMessage ¶
func (*ViewRepairReply) ProtoMessage()
func (*ViewRepairReply) Reset ¶
func (m *ViewRepairReply) Reset()
func (*ViewRepairReply) Size ¶
func (m *ViewRepairReply) Size() (n int)
func (*ViewRepairReply) String ¶
func (m *ViewRepairReply) String() string
func (*ViewRepairReply) Unmarshal ¶
func (m *ViewRepairReply) Unmarshal(dAtA []byte) error
func (*ViewRepairReply) XXX_DiscardUnknown ¶
func (m *ViewRepairReply) XXX_DiscardUnknown()
func (*ViewRepairReply) XXX_Marshal ¶
func (m *ViewRepairReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewRepairReply) XXX_Merge ¶
func (m *ViewRepairReply) XXX_Merge(src proto.Message)
func (*ViewRepairReply) XXX_Size ¶
func (m *ViewRepairReply) XXX_Size() int
func (*ViewRepairReply) XXX_Unmarshal ¶
func (m *ViewRepairReply) XXX_Unmarshal(b []byte) error