Documentation ¶
Index ¶
- Variables
- func RegisterRaftNetworkServer(s grpc.ServiceRegistrar, srv RaftNetworkServer)
- type AppendEntriesRequest
- func (*AppendEntriesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendEntriesRequest) GetEntries() []*Entry
- func (x *AppendEntriesRequest) GetLeaderCommit() uint64
- func (x *AppendEntriesRequest) GetLeaderId() string
- func (x *AppendEntriesRequest) GetPrevLogIndex() uint64
- func (x *AppendEntriesRequest) GetPrevLogTerm() uint64
- func (x *AppendEntriesRequest) GetTerm() uint64
- func (*AppendEntriesRequest) ProtoMessage()
- func (x *AppendEntriesRequest) ProtoReflect() protoreflect.Message
- func (x *AppendEntriesRequest) Reset()
- func (x *AppendEntriesRequest) String() string
- type AppendEntriesResponse
- func (*AppendEntriesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AppendEntriesResponse) GetNextIndex() uint64
- func (x *AppendEntriesResponse) GetSuccess() bool
- func (x *AppendEntriesResponse) GetTerm() uint64
- func (*AppendEntriesResponse) ProtoMessage()
- func (x *AppendEntriesResponse) ProtoReflect() protoreflect.Message
- func (x *AppendEntriesResponse) Reset()
- func (x *AppendEntriesResponse) String() string
- type Configuration
- func (*Configuration) Descriptor() ([]byte, []int)deprecated
- func (x *Configuration) GetNodes() []*Node
- func (x *Configuration) GetType() Configuration_ConfigurationType
- func (*Configuration) ProtoMessage()
- func (x *Configuration) ProtoReflect() protoreflect.Message
- func (x *Configuration) Reset()
- func (x *Configuration) String() string
- type Configuration_ConfigurationType
- func (Configuration_ConfigurationType) Descriptor() protoreflect.EnumDescriptor
- func (x Configuration_ConfigurationType) Enum() *Configuration_ConfigurationType
- func (Configuration_ConfigurationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Configuration_ConfigurationType) Number() protoreflect.EnumNumber
- func (x Configuration_ConfigurationType) String() string
- func (Configuration_ConfigurationType) Type() protoreflect.EnumType
- type DemoCommand
- type EmptyMessage
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)deprecated
- func (x *Entry) GetCommand() *StateMachineCommand
- func (x *Entry) GetConfig() *Configuration
- func (x *Entry) GetDemo() *DemoCommand
- func (x *Entry) GetKeyCommand() *KeyStateCommand
- func (x *Entry) GetType() Entry_EntryType
- func (x *Entry) GetUuid() string
- func (*Entry) ProtoMessage()
- func (x *Entry) ProtoReflect() protoreflect.Message
- func (x *Entry) Reset()
- func (x *Entry) String() string
- type EntryRequest
- func (*EntryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EntryRequest) GetEntry() *Entry
- func (x *EntryRequest) GetSenderId() string
- func (*EntryRequest) ProtoMessage()
- func (x *EntryRequest) ProtoReflect() protoreflect.Message
- func (x *EntryRequest) Reset()
- func (x *EntryRequest) String() string
- type Entry_EntryType
- func (Entry_EntryType) Descriptor() protoreflect.EnumDescriptor
- func (x Entry_EntryType) Enum() *Entry_EntryType
- func (Entry_EntryType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Entry_EntryType) Number() protoreflect.EnumNumber
- func (x Entry_EntryType) String() string
- func (Entry_EntryType) Type() protoreflect.EnumType
- type KeyStateCommand
- func (*KeyStateCommand) Descriptor() ([]byte, []int)deprecated
- func (x *KeyStateCommand) GetGeneration() int64
- func (x *KeyStateCommand) GetKeyHolder() *Node
- func (x *KeyStateCommand) GetKeyOwner() *Node
- func (x *KeyStateCommand) GetNewNode() string
- func (x *KeyStateCommand) GetOwnerComplete() string
- func (x *KeyStateCommand) GetType() KeyStateCommand_KSMType
- func (*KeyStateCommand) ProtoMessage()
- func (x *KeyStateCommand) ProtoReflect() protoreflect.Message
- func (x *KeyStateCommand) Reset()
- func (x *KeyStateCommand) String() string
- type KeyStateCommand_KSMType
- func (KeyStateCommand_KSMType) Descriptor() protoreflect.EnumDescriptor
- func (x KeyStateCommand_KSMType) Enum() *KeyStateCommand_KSMType
- func (KeyStateCommand_KSMType) EnumDescriptor() ([]byte, []int)deprecated
- func (x KeyStateCommand_KSMType) Number() protoreflect.EnumNumber
- func (x KeyStateCommand_KSMType) String() string
- func (KeyStateCommand_KSMType) Type() protoreflect.EnumType
- type LogEntry
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetCommonName() string
- func (x *Node) GetIp() string
- func (x *Node) GetNodeId() string
- func (x *Node) GetPort() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type RaftNetworkClient
- type RaftNetworkServer
- type RequestVoteRequest
- func (*RequestVoteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RequestVoteRequest) GetCandidateId() string
- func (x *RequestVoteRequest) GetLastLogIndex() uint64
- func (x *RequestVoteRequest) GetLastLogTerm() uint64
- func (x *RequestVoteRequest) GetTerm() uint64
- func (*RequestVoteRequest) ProtoMessage()
- func (x *RequestVoteRequest) ProtoReflect() protoreflect.Message
- func (x *RequestVoteRequest) Reset()
- func (x *RequestVoteRequest) String() string
- type RequestVoteResponse
- func (*RequestVoteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RequestVoteResponse) GetTerm() uint64
- func (x *RequestVoteResponse) GetVoteGranted() bool
- func (*RequestVoteResponse) ProtoMessage()
- func (x *RequestVoteResponse) ProtoReflect() protoreflect.Message
- func (x *RequestVoteResponse) Reset()
- func (x *RequestVoteResponse) String() string
- type SnapshotRequest
- func (*SnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SnapshotRequest) GetData() []byte
- func (x *SnapshotRequest) GetDone() bool
- func (x *SnapshotRequest) GetLastIncludedIndex() uint64
- func (x *SnapshotRequest) GetLastIncludedTerm() uint64
- func (x *SnapshotRequest) GetLeaderId() string
- func (x *SnapshotRequest) GetOffset() uint64
- func (x *SnapshotRequest) GetTerm() uint64
- func (*SnapshotRequest) ProtoMessage()
- func (x *SnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *SnapshotRequest) Reset()
- func (x *SnapshotRequest) String() string
- type SnapshotResponse
- type StateMachineCommand
- func (*StateMachineCommand) Descriptor() ([]byte, []int)deprecated
- func (x *StateMachineCommand) GetAccessNanoseconds() int64
- func (x *StateMachineCommand) GetAccessSeconds() int64
- func (x *StateMachineCommand) GetData() []byte
- func (x *StateMachineCommand) GetLength() int64
- func (x *StateMachineCommand) GetMode() uint32
- func (x *StateMachineCommand) GetModifyNanoseconds() int64
- func (x *StateMachineCommand) GetModifySeconds() int64
- func (x *StateMachineCommand) GetNewPath() string
- func (x *StateMachineCommand) GetOffset() int64
- func (x *StateMachineCommand) GetOldPath() string
- func (x *StateMachineCommand) GetPath() string
- func (x *StateMachineCommand) GetType() uint32
- func (*StateMachineCommand) ProtoMessage()
- func (x *StateMachineCommand) ProtoReflect() protoreflect.Message
- func (x *StateMachineCommand) Reset()
- func (x *StateMachineCommand) String() string
- type UnimplementedRaftNetworkServer
- func (UnimplementedRaftNetworkServer) AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
- func (UnimplementedRaftNetworkServer) ClientToLeaderRequest(context.Context, *EntryRequest) (*EmptyMessage, error)
- func (UnimplementedRaftNetworkServer) InstallSnapshot(context.Context, *SnapshotRequest) (*SnapshotResponse, error)
- func (UnimplementedRaftNetworkServer) RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
- type UnsafeRaftNetworkServer
Constants ¶
This section is empty.
Variables ¶
var ( KeyStateCommand_KSMType_name = map[int32]string{ 0: "UpdateKeyPiece", 1: "NewGeneration", 2: "OwnerComplete", } KeyStateCommand_KSMType_value = map[string]int32{ "UpdateKeyPiece": 0, "NewGeneration": 1, "OwnerComplete": 2, } )
Enum value maps for KeyStateCommand_KSMType.
var ( Configuration_ConfigurationType_name = map[int32]string{ 0: "CurrentConfiguration", 1: "FutureConfiguration", } Configuration_ConfigurationType_value = map[string]int32{ "CurrentConfiguration": 0, "FutureConfiguration": 1, } )
Enum value maps for Configuration_ConfigurationType.
var ( Entry_EntryType_name = map[int32]string{ 0: "StateMachineCommand", 1: "ConfigurationChange", 2: "Demo", 3: "KeyStateCommand", } Entry_EntryType_value = map[string]int32{ "StateMachineCommand": 0, "ConfigurationChange": 1, "Demo": 2, "KeyStateCommand": 3, } )
Enum value maps for Entry_EntryType.
var File_raft_raft_proto protoreflect.FileDescriptor
var RaftNetwork_ServiceDesc = grpc.ServiceDesc{ ServiceName: "raft.RaftNetwork", HandlerType: (*RaftNetworkServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AppendEntries", Handler: _RaftNetwork_AppendEntries_Handler, }, { MethodName: "RequestVote", Handler: _RaftNetwork_RequestVote_Handler, }, { MethodName: "ClientToLeaderRequest", Handler: _RaftNetwork_ClientToLeaderRequest_Handler, }, { MethodName: "InstallSnapshot", Handler: _RaftNetwork_InstallSnapshot_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "raft/raft.proto", }
RaftNetwork_ServiceDesc is the grpc.ServiceDesc for RaftNetwork service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRaftNetworkServer ¶
func RegisterRaftNetworkServer(s grpc.ServiceRegistrar, srv RaftNetworkServer)
Types ¶
type AppendEntriesRequest ¶
type AppendEntriesRequest struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required LeaderId string `protobuf:"bytes,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"` // required PrevLogIndex uint64 `protobuf:"varint,3,opt,name=prev_log_index,json=prevLogIndex,proto3" json:"prev_log_index,omitempty"` // required PrevLogTerm uint64 `protobuf:"varint,4,opt,name=prev_log_term,json=prevLogTerm,proto3" json:"prev_log_term,omitempty"` // required Entries []*Entry `protobuf:"bytes,5,rep,name=entries,proto3" json:"entries,omitempty"` // optional LeaderCommit uint64 `protobuf:"varint,6,opt,name=leader_commit,json=leaderCommit,proto3" json:"leader_commit,omitempty"` // required // contains filtered or unexported fields }
func (*AppendEntriesRequest) Descriptor
deprecated
func (*AppendEntriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.
func (*AppendEntriesRequest) GetEntries ¶
func (x *AppendEntriesRequest) GetEntries() []*Entry
func (*AppendEntriesRequest) GetLeaderCommit ¶
func (x *AppendEntriesRequest) GetLeaderCommit() uint64
func (*AppendEntriesRequest) GetLeaderId ¶
func (x *AppendEntriesRequest) GetLeaderId() string
func (*AppendEntriesRequest) GetPrevLogIndex ¶
func (x *AppendEntriesRequest) GetPrevLogIndex() uint64
func (*AppendEntriesRequest) GetPrevLogTerm ¶
func (x *AppendEntriesRequest) GetPrevLogTerm() uint64
func (*AppendEntriesRequest) GetTerm ¶
func (x *AppendEntriesRequest) GetTerm() uint64
func (*AppendEntriesRequest) ProtoMessage ¶
func (*AppendEntriesRequest) ProtoMessage()
func (*AppendEntriesRequest) ProtoReflect ¶
func (x *AppendEntriesRequest) ProtoReflect() protoreflect.Message
func (*AppendEntriesRequest) Reset ¶
func (x *AppendEntriesRequest) Reset()
func (*AppendEntriesRequest) String ¶
func (x *AppendEntriesRequest) String() string
type AppendEntriesResponse ¶
type AppendEntriesResponse struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required NextIndex uint64 `protobuf:"varint,2,opt,name=next_index,json=nextIndex,proto3" json:"next_index,omitempty"` // required Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"` // required // contains filtered or unexported fields }
func (*AppendEntriesResponse) Descriptor
deprecated
func (*AppendEntriesResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendEntriesResponse.ProtoReflect.Descriptor instead.
func (*AppendEntriesResponse) GetNextIndex ¶
func (x *AppendEntriesResponse) GetNextIndex() uint64
func (*AppendEntriesResponse) GetSuccess ¶
func (x *AppendEntriesResponse) GetSuccess() bool
func (*AppendEntriesResponse) GetTerm ¶
func (x *AppendEntriesResponse) GetTerm() uint64
func (*AppendEntriesResponse) ProtoMessage ¶
func (*AppendEntriesResponse) ProtoMessage()
func (*AppendEntriesResponse) ProtoReflect ¶
func (x *AppendEntriesResponse) ProtoReflect() protoreflect.Message
func (*AppendEntriesResponse) Reset ¶
func (x *AppendEntriesResponse) Reset()
func (*AppendEntriesResponse) String ¶
func (x *AppendEntriesResponse) String() string
type Configuration ¶
type Configuration struct { Type Configuration_ConfigurationType `protobuf:"varint,1,opt,name=type,proto3,enum=raft.Configuration_ConfigurationType" json:"type,omitempty"` // required Nodes []*Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"` // required // contains filtered or unexported fields }
func (*Configuration) Descriptor
deprecated
func (*Configuration) Descriptor() ([]byte, []int)
Deprecated: Use Configuration.ProtoReflect.Descriptor instead.
func (*Configuration) GetNodes ¶
func (x *Configuration) GetNodes() []*Node
func (*Configuration) GetType ¶
func (x *Configuration) GetType() Configuration_ConfigurationType
func (*Configuration) ProtoMessage ¶
func (*Configuration) ProtoMessage()
func (*Configuration) ProtoReflect ¶
func (x *Configuration) ProtoReflect() protoreflect.Message
func (*Configuration) Reset ¶
func (x *Configuration) Reset()
func (*Configuration) String ¶
func (x *Configuration) String() string
type Configuration_ConfigurationType ¶
type Configuration_ConfigurationType int32
const ( Configuration_CurrentConfiguration Configuration_ConfigurationType = 0 Configuration_FutureConfiguration Configuration_ConfigurationType = 1 )
func (Configuration_ConfigurationType) Descriptor ¶
func (Configuration_ConfigurationType) Descriptor() protoreflect.EnumDescriptor
func (Configuration_ConfigurationType) Enum ¶
func (x Configuration_ConfigurationType) Enum() *Configuration_ConfigurationType
func (Configuration_ConfigurationType) EnumDescriptor
deprecated
func (Configuration_ConfigurationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Configuration_ConfigurationType.Descriptor instead.
func (Configuration_ConfigurationType) Number ¶
func (x Configuration_ConfigurationType) Number() protoreflect.EnumNumber
func (Configuration_ConfigurationType) String ¶
func (x Configuration_ConfigurationType) String() string
func (Configuration_ConfigurationType) Type ¶
func (Configuration_ConfigurationType) Type() protoreflect.EnumType
type DemoCommand ¶
type DemoCommand struct { Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` // required // contains filtered or unexported fields }
func (*DemoCommand) Descriptor
deprecated
func (*DemoCommand) Descriptor() ([]byte, []int)
Deprecated: Use DemoCommand.ProtoReflect.Descriptor instead.
func (*DemoCommand) GetNumber ¶
func (x *DemoCommand) GetNumber() uint64
func (*DemoCommand) ProtoMessage ¶
func (*DemoCommand) ProtoMessage()
func (*DemoCommand) ProtoReflect ¶
func (x *DemoCommand) ProtoReflect() protoreflect.Message
func (*DemoCommand) Reset ¶
func (x *DemoCommand) Reset()
func (*DemoCommand) String ¶
func (x *DemoCommand) String() string
type EmptyMessage ¶
type EmptyMessage struct {
// contains filtered or unexported fields
}
func (*EmptyMessage) Descriptor
deprecated
func (*EmptyMessage) Descriptor() ([]byte, []int)
Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.
func (*EmptyMessage) ProtoMessage ¶
func (*EmptyMessage) ProtoMessage()
func (*EmptyMessage) ProtoReflect ¶
func (x *EmptyMessage) ProtoReflect() protoreflect.Message
func (*EmptyMessage) Reset ¶
func (x *EmptyMessage) Reset()
func (*EmptyMessage) String ¶
func (x *EmptyMessage) String() string
type Entry ¶
type Entry struct { Type Entry_EntryType `protobuf:"varint,1,opt,name=type,proto3,enum=raft.Entry_EntryType" json:"type,omitempty"` // required Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"` // required Command *StateMachineCommand `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` // optional Config *Configuration `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` // optional Demo *DemoCommand `protobuf:"bytes,5,opt,name=demo,proto3" json:"demo,omitempty"` // optional KeyCommand *KeyStateCommand `protobuf:"bytes,6,opt,name=key_command,json=keyCommand,proto3" json:"key_command,omitempty"` // optional // contains filtered or unexported fields }
func (*Entry) Descriptor
deprecated
func (*Entry) GetCommand ¶
func (x *Entry) GetCommand() *StateMachineCommand
func (*Entry) GetConfig ¶
func (x *Entry) GetConfig() *Configuration
func (*Entry) GetDemo ¶
func (x *Entry) GetDemo() *DemoCommand
func (*Entry) GetKeyCommand ¶
func (x *Entry) GetKeyCommand() *KeyStateCommand
func (*Entry) GetType ¶
func (x *Entry) GetType() Entry_EntryType
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) ProtoReflect ¶
func (x *Entry) ProtoReflect() protoreflect.Message
type EntryRequest ¶
type EntryRequest struct { SenderId string `protobuf:"bytes,1,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"` // required Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"` // required // contains filtered or unexported fields }
func (*EntryRequest) Descriptor
deprecated
func (*EntryRequest) Descriptor() ([]byte, []int)
Deprecated: Use EntryRequest.ProtoReflect.Descriptor instead.
func (*EntryRequest) GetEntry ¶
func (x *EntryRequest) GetEntry() *Entry
func (*EntryRequest) GetSenderId ¶
func (x *EntryRequest) GetSenderId() string
func (*EntryRequest) ProtoMessage ¶
func (*EntryRequest) ProtoMessage()
func (*EntryRequest) ProtoReflect ¶
func (x *EntryRequest) ProtoReflect() protoreflect.Message
func (*EntryRequest) Reset ¶
func (x *EntryRequest) Reset()
func (*EntryRequest) String ¶
func (x *EntryRequest) String() string
type Entry_EntryType ¶
type Entry_EntryType int32
const ( Entry_StateMachineCommand Entry_EntryType = 0 Entry_ConfigurationChange Entry_EntryType = 1 Entry_Demo Entry_EntryType = 2 Entry_KeyStateCommand Entry_EntryType = 3 )
func (Entry_EntryType) Descriptor ¶
func (Entry_EntryType) Descriptor() protoreflect.EnumDescriptor
func (Entry_EntryType) Enum ¶
func (x Entry_EntryType) Enum() *Entry_EntryType
func (Entry_EntryType) EnumDescriptor
deprecated
func (Entry_EntryType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Entry_EntryType.Descriptor instead.
func (Entry_EntryType) Number ¶
func (x Entry_EntryType) Number() protoreflect.EnumNumber
func (Entry_EntryType) String ¶
func (x Entry_EntryType) String() string
func (Entry_EntryType) Type ¶
func (Entry_EntryType) Type() protoreflect.EnumType
type KeyStateCommand ¶
type KeyStateCommand struct { Type KeyStateCommand_KSMType `protobuf:"varint,1,opt,name=type,proto3,enum=raft.KeyStateCommand_KSMType" json:"type,omitempty"` // UpdateKeyPiece arguments KeyOwner *Node `protobuf:"bytes,2,opt,name=key_owner,json=keyOwner,proto3" json:"key_owner,omitempty"` // optional KeyHolder *Node `protobuf:"bytes,3,opt,name=key_holder,json=keyHolder,proto3" json:"key_holder,omitempty"` // optional Generation int64 `protobuf:"varint,4,opt,name=generation,proto3" json:"generation,omitempty"` // optional // NewGeneration arguments NewNode string `protobuf:"bytes,5,opt,name=new_node,json=newNode,proto3" json:"new_node,omitempty"` // optional // OwnerCompete arguments OwnerComplete string `protobuf:"bytes,6,opt,name=owner_complete,json=ownerComplete,proto3" json:"owner_complete,omitempty"` // optional // contains filtered or unexported fields }
func (*KeyStateCommand) Descriptor
deprecated
func (*KeyStateCommand) Descriptor() ([]byte, []int)
Deprecated: Use KeyStateCommand.ProtoReflect.Descriptor instead.
func (*KeyStateCommand) GetGeneration ¶
func (x *KeyStateCommand) GetGeneration() int64
func (*KeyStateCommand) GetKeyHolder ¶
func (x *KeyStateCommand) GetKeyHolder() *Node
func (*KeyStateCommand) GetKeyOwner ¶
func (x *KeyStateCommand) GetKeyOwner() *Node
func (*KeyStateCommand) GetNewNode ¶
func (x *KeyStateCommand) GetNewNode() string
func (*KeyStateCommand) GetOwnerComplete ¶
func (x *KeyStateCommand) GetOwnerComplete() string
func (*KeyStateCommand) GetType ¶
func (x *KeyStateCommand) GetType() KeyStateCommand_KSMType
func (*KeyStateCommand) ProtoMessage ¶
func (*KeyStateCommand) ProtoMessage()
func (*KeyStateCommand) ProtoReflect ¶
func (x *KeyStateCommand) ProtoReflect() protoreflect.Message
func (*KeyStateCommand) Reset ¶
func (x *KeyStateCommand) Reset()
func (*KeyStateCommand) String ¶
func (x *KeyStateCommand) String() string
type KeyStateCommand_KSMType ¶
type KeyStateCommand_KSMType int32
const ( KeyStateCommand_UpdateKeyPiece KeyStateCommand_KSMType = 0 KeyStateCommand_NewGeneration KeyStateCommand_KSMType = 1 KeyStateCommand_OwnerComplete KeyStateCommand_KSMType = 2 )
func (KeyStateCommand_KSMType) Descriptor ¶
func (KeyStateCommand_KSMType) Descriptor() protoreflect.EnumDescriptor
func (KeyStateCommand_KSMType) Enum ¶
func (x KeyStateCommand_KSMType) Enum() *KeyStateCommand_KSMType
func (KeyStateCommand_KSMType) EnumDescriptor
deprecated
func (KeyStateCommand_KSMType) EnumDescriptor() ([]byte, []int)
Deprecated: Use KeyStateCommand_KSMType.Descriptor instead.
func (KeyStateCommand_KSMType) Number ¶
func (x KeyStateCommand_KSMType) Number() protoreflect.EnumNumber
func (KeyStateCommand_KSMType) String ¶
func (x KeyStateCommand_KSMType) String() string
func (KeyStateCommand_KSMType) Type ¶
func (KeyStateCommand_KSMType) Type() protoreflect.EnumType
type LogEntry ¶
type LogEntry struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"` // required // contains filtered or unexported fields }
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type Node ¶
type Node struct { Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` // required Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"` // required CommonName string `protobuf:"bytes,3,opt,name=common_name,json=commonName,proto3" json:"common_name,omitempty"` // required NodeId string `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // required // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetCommonName ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type RaftNetworkClient ¶
type RaftNetworkClient interface { AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesResponse, error) RequestVote(ctx context.Context, in *RequestVoteRequest, opts ...grpc.CallOption) (*RequestVoteResponse, error) ClientToLeaderRequest(ctx context.Context, in *EntryRequest, opts ...grpc.CallOption) (*EmptyMessage, error) InstallSnapshot(ctx context.Context, in *SnapshotRequest, opts ...grpc.CallOption) (*SnapshotResponse, error) }
RaftNetworkClient is the client API for RaftNetwork service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRaftNetworkClient ¶
func NewRaftNetworkClient(cc grpc.ClientConnInterface) RaftNetworkClient
type RaftNetworkServer ¶
type RaftNetworkServer interface { AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error) RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error) ClientToLeaderRequest(context.Context, *EntryRequest) (*EmptyMessage, error) InstallSnapshot(context.Context, *SnapshotRequest) (*SnapshotResponse, error) // contains filtered or unexported methods }
RaftNetworkServer is the server API for RaftNetwork service. All implementations must embed UnimplementedRaftNetworkServer for forward compatibility
type RequestVoteRequest ¶
type RequestVoteRequest struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required CandidateId string `protobuf:"bytes,2,opt,name=candidate_id,json=candidateId,proto3" json:"candidate_id,omitempty"` // required LastLogIndex uint64 `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex,proto3" json:"last_log_index,omitempty"` // required LastLogTerm uint64 `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm,proto3" json:"last_log_term,omitempty"` // required // contains filtered or unexported fields }
func (*RequestVoteRequest) Descriptor
deprecated
func (*RequestVoteRequest) Descriptor() ([]byte, []int)
Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.
func (*RequestVoteRequest) GetCandidateId ¶
func (x *RequestVoteRequest) GetCandidateId() string
func (*RequestVoteRequest) GetLastLogIndex ¶
func (x *RequestVoteRequest) GetLastLogIndex() uint64
func (*RequestVoteRequest) GetLastLogTerm ¶
func (x *RequestVoteRequest) GetLastLogTerm() uint64
func (*RequestVoteRequest) GetTerm ¶
func (x *RequestVoteRequest) GetTerm() uint64
func (*RequestVoteRequest) ProtoMessage ¶
func (*RequestVoteRequest) ProtoMessage()
func (*RequestVoteRequest) ProtoReflect ¶
func (x *RequestVoteRequest) ProtoReflect() protoreflect.Message
func (*RequestVoteRequest) Reset ¶
func (x *RequestVoteRequest) Reset()
func (*RequestVoteRequest) String ¶
func (x *RequestVoteRequest) String() string
type RequestVoteResponse ¶
type RequestVoteResponse struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required VoteGranted bool `protobuf:"varint,2,opt,name=vote_granted,json=voteGranted,proto3" json:"vote_granted,omitempty"` // required // contains filtered or unexported fields }
func (*RequestVoteResponse) Descriptor
deprecated
func (*RequestVoteResponse) Descriptor() ([]byte, []int)
Deprecated: Use RequestVoteResponse.ProtoReflect.Descriptor instead.
func (*RequestVoteResponse) GetTerm ¶
func (x *RequestVoteResponse) GetTerm() uint64
func (*RequestVoteResponse) GetVoteGranted ¶
func (x *RequestVoteResponse) GetVoteGranted() bool
func (*RequestVoteResponse) ProtoMessage ¶
func (*RequestVoteResponse) ProtoMessage()
func (*RequestVoteResponse) ProtoReflect ¶
func (x *RequestVoteResponse) ProtoReflect() protoreflect.Message
func (*RequestVoteResponse) Reset ¶
func (x *RequestVoteResponse) Reset()
func (*RequestVoteResponse) String ¶
func (x *RequestVoteResponse) String() string
type SnapshotRequest ¶
type SnapshotRequest struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required LeaderId string `protobuf:"bytes,2,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"` // required LastIncludedIndex uint64 `protobuf:"varint,3,opt,name=last_included_index,json=lastIncludedIndex,proto3" json:"last_included_index,omitempty"` // required LastIncludedTerm uint64 `protobuf:"varint,4,opt,name=last_included_term,json=lastIncludedTerm,proto3" json:"last_included_term,omitempty"` // required Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` // required Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // required Done bool `protobuf:"varint,7,opt,name=done,proto3" json:"done,omitempty"` // required // contains filtered or unexported fields }
func (*SnapshotRequest) Descriptor
deprecated
func (*SnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.
func (*SnapshotRequest) GetData ¶
func (x *SnapshotRequest) GetData() []byte
func (*SnapshotRequest) GetDone ¶
func (x *SnapshotRequest) GetDone() bool
func (*SnapshotRequest) GetLastIncludedIndex ¶
func (x *SnapshotRequest) GetLastIncludedIndex() uint64
func (*SnapshotRequest) GetLastIncludedTerm ¶
func (x *SnapshotRequest) GetLastIncludedTerm() uint64
func (*SnapshotRequest) GetLeaderId ¶
func (x *SnapshotRequest) GetLeaderId() string
func (*SnapshotRequest) GetOffset ¶
func (x *SnapshotRequest) GetOffset() uint64
func (*SnapshotRequest) GetTerm ¶
func (x *SnapshotRequest) GetTerm() uint64
func (*SnapshotRequest) ProtoMessage ¶
func (*SnapshotRequest) ProtoMessage()
func (*SnapshotRequest) ProtoReflect ¶
func (x *SnapshotRequest) ProtoReflect() protoreflect.Message
func (*SnapshotRequest) Reset ¶
func (x *SnapshotRequest) Reset()
func (*SnapshotRequest) String ¶
func (x *SnapshotRequest) String() string
type SnapshotResponse ¶
type SnapshotResponse struct { Term uint64 `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // required // contains filtered or unexported fields }
func (*SnapshotResponse) Descriptor
deprecated
func (*SnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.
func (*SnapshotResponse) GetTerm ¶
func (x *SnapshotResponse) GetTerm() uint64
func (*SnapshotResponse) ProtoMessage ¶
func (*SnapshotResponse) ProtoMessage()
func (*SnapshotResponse) ProtoReflect ¶
func (x *SnapshotResponse) ProtoReflect() protoreflect.Message
func (*SnapshotResponse) Reset ¶
func (x *SnapshotResponse) Reset()
func (*SnapshotResponse) String ¶
func (x *SnapshotResponse) String() string
type StateMachineCommand ¶
type StateMachineCommand struct { Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` // required Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // required //Used for Write command Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // optional Offset int64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` // optional //Used for Write and Truncate commands Length int64 `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"` // optional //Used for Link and Rename commands OldPath string `protobuf:"bytes,6,opt,name=old_path,json=oldPath,proto3" json:"old_path,omitempty"` // optional NewPath string `protobuf:"bytes,7,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"` // optional //Used for Create, Chmod and Mkdir commands Mode uint32 `protobuf:"varint,8,opt,name=mode,proto3" json:"mode,omitempty"` // optional //Used for Utimes command AccessSeconds int64 `protobuf:"varint,9,opt,name=access_seconds,json=accessSeconds,proto3" json:"access_seconds,omitempty"` // optional AccessNanoseconds int64 `protobuf:"varint,10,opt,name=access_nanoseconds,json=accessNanoseconds,proto3" json:"access_nanoseconds,omitempty"` // optional ModifySeconds int64 `protobuf:"varint,11,opt,name=modify_seconds,json=modifySeconds,proto3" json:"modify_seconds,omitempty"` // optional ModifyNanoseconds int64 `protobuf:"varint,12,opt,name=modify_nanoseconds,json=modifyNanoseconds,proto3" json:"modify_nanoseconds,omitempty"` // optional // contains filtered or unexported fields }
func (*StateMachineCommand) Descriptor
deprecated
func (*StateMachineCommand) Descriptor() ([]byte, []int)
Deprecated: Use StateMachineCommand.ProtoReflect.Descriptor instead.
func (*StateMachineCommand) GetAccessNanoseconds ¶
func (x *StateMachineCommand) GetAccessNanoseconds() int64
func (*StateMachineCommand) GetAccessSeconds ¶
func (x *StateMachineCommand) GetAccessSeconds() int64
func (*StateMachineCommand) GetData ¶
func (x *StateMachineCommand) GetData() []byte
func (*StateMachineCommand) GetLength ¶
func (x *StateMachineCommand) GetLength() int64
func (*StateMachineCommand) GetMode ¶
func (x *StateMachineCommand) GetMode() uint32
func (*StateMachineCommand) GetModifyNanoseconds ¶
func (x *StateMachineCommand) GetModifyNanoseconds() int64
func (*StateMachineCommand) GetModifySeconds ¶
func (x *StateMachineCommand) GetModifySeconds() int64
func (*StateMachineCommand) GetNewPath ¶
func (x *StateMachineCommand) GetNewPath() string
func (*StateMachineCommand) GetOffset ¶
func (x *StateMachineCommand) GetOffset() int64
func (*StateMachineCommand) GetOldPath ¶
func (x *StateMachineCommand) GetOldPath() string
func (*StateMachineCommand) GetPath ¶
func (x *StateMachineCommand) GetPath() string
func (*StateMachineCommand) GetType ¶
func (x *StateMachineCommand) GetType() uint32
func (*StateMachineCommand) ProtoMessage ¶
func (*StateMachineCommand) ProtoMessage()
func (*StateMachineCommand) ProtoReflect ¶
func (x *StateMachineCommand) ProtoReflect() protoreflect.Message
func (*StateMachineCommand) Reset ¶
func (x *StateMachineCommand) Reset()
func (*StateMachineCommand) String ¶
func (x *StateMachineCommand) String() string
type UnimplementedRaftNetworkServer ¶
type UnimplementedRaftNetworkServer struct { }
UnimplementedRaftNetworkServer must be embedded to have forward compatible implementations.
func (UnimplementedRaftNetworkServer) AppendEntries ¶
func (UnimplementedRaftNetworkServer) AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesResponse, error)
func (UnimplementedRaftNetworkServer) ClientToLeaderRequest ¶
func (UnimplementedRaftNetworkServer) ClientToLeaderRequest(context.Context, *EntryRequest) (*EmptyMessage, error)
func (UnimplementedRaftNetworkServer) InstallSnapshot ¶
func (UnimplementedRaftNetworkServer) InstallSnapshot(context.Context, *SnapshotRequest) (*SnapshotResponse, error)
func (UnimplementedRaftNetworkServer) RequestVote ¶
func (UnimplementedRaftNetworkServer) RequestVote(context.Context, *RequestVoteRequest) (*RequestVoteResponse, error)
type UnsafeRaftNetworkServer ¶
type UnsafeRaftNetworkServer interface {
// contains filtered or unexported methods
}
UnsafeRaftNetworkServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RaftNetworkServer will result in compilation errors.