Documentation ¶
Index ¶
- Variables
- type AppendEntriesRequest
- func (*AppendEntriesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendEntriesRequest) GetEntries() []*LogEntry
- 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) 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 LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetCommandName() string
- func (x *LogEntry) GetIndex() uint64
- func (x *LogEntry) GetTerm() uint64
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type Raft
- func (*Raft) Descriptor() ([]byte, []int)deprecated
- func (x *Raft) GetAppendEntriesRequest() *AppendEntriesRequest
- func (x *Raft) GetAppendEntriesResponse() *AppendEntriesResponse
- func (x *Raft) GetCommandName() string
- func (m *Raft) GetMessage() isRaft_Message
- func (x *Raft) GetRequestVoteRequest() *RequestVoteRequest
- func (x *Raft) GetRequestVoteResponse() *RequestVoteResponse
- func (*Raft) ProtoMessage()
- func (x *Raft) ProtoReflect() protoreflect.Message
- func (x *Raft) Reset()
- func (x *Raft) String() string
- type Raft_AppendEntriesRequest
- type Raft_AppendEntriesResponse
- type Raft_CommandName
- type Raft_RequestVoteRequest
- type Raft_RequestVoteResponse
- type RequestVoteRequest
- func (*RequestVoteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RequestVoteRequest) GetCandidateName() 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
Constants ¶
This section is empty.
Variables ¶
View Source
var File_miniraft_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AppendEntriesRequest ¶
type AppendEntriesRequest struct { Term uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"` PrevLogIndex uint64 `protobuf:"varint,2,opt,name=PrevLogIndex,proto3" json:"PrevLogIndex,omitempty"` PrevLogTerm uint64 `protobuf:"varint,3,opt,name=PrevLogTerm,proto3" json:"PrevLogTerm,omitempty"` LeaderCommit uint64 `protobuf:"varint,4,opt,name=LeaderCommit,proto3" json:"LeaderCommit,omitempty"` LeaderId string `protobuf:"bytes,5,opt,name=LeaderId,proto3" json:"LeaderId,omitempty"` Entries []*LogEntry `protobuf:"bytes,6,rep,name=Entries,proto3" json:"Entries,omitempty"` // contains filtered or unexported fields }
AppendEntries RPC
func (*AppendEntriesRequest) Descriptor
deprecated
func (*AppendEntriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendEntriesRequest.ProtoReflect.Descriptor instead.
func (*AppendEntriesRequest) GetEntries ¶
func (x *AppendEntriesRequest) GetEntries() []*LogEntry
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"` Success bool `protobuf:"varint,4,opt,name=Success,proto3" json:"Success,omitempty"` // contains filtered or unexported fields }
func (*AppendEntriesResponse) Descriptor
deprecated
func (*AppendEntriesResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendEntriesResponse.ProtoReflect.Descriptor instead.
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 LogEntry ¶
type LogEntry struct { Index uint64 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"` Term uint64 `protobuf:"varint,2,opt,name=Term,proto3" json:"Term,omitempty"` CommandName string `protobuf:"bytes,3,opt,name=CommandName,proto3" json:"CommandName,omitempty"` // Empty string is noop // contains filtered or unexported fields }
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetCommandName ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type Raft ¶
type Raft struct { // Types that are assignable to Message: // // *Raft_AppendEntriesRequest // *Raft_AppendEntriesResponse // *Raft_RequestVoteRequest // *Raft_RequestVoteResponse // *Raft_CommandName Message isRaft_Message `protobuf_oneof:"Message"` // contains filtered or unexported fields }
Wrapper
func (*Raft) Descriptor
deprecated
func (*Raft) GetAppendEntriesRequest ¶
func (x *Raft) GetAppendEntriesRequest() *AppendEntriesRequest
func (*Raft) GetAppendEntriesResponse ¶
func (x *Raft) GetAppendEntriesResponse() *AppendEntriesResponse
func (*Raft) GetCommandName ¶
func (*Raft) GetMessage ¶
func (m *Raft) GetMessage() isRaft_Message
func (*Raft) GetRequestVoteRequest ¶
func (x *Raft) GetRequestVoteRequest() *RequestVoteRequest
func (*Raft) GetRequestVoteResponse ¶
func (x *Raft) GetRequestVoteResponse() *RequestVoteResponse
func (*Raft) ProtoMessage ¶
func (*Raft) ProtoMessage()
func (*Raft) ProtoReflect ¶
func (x *Raft) ProtoReflect() protoreflect.Message
type Raft_AppendEntriesRequest ¶
type Raft_AppendEntriesRequest struct {
AppendEntriesRequest *AppendEntriesRequest `protobuf:"bytes,1,opt,name=AppendEntriesRequest,proto3,oneof"`
}
type Raft_AppendEntriesResponse ¶
type Raft_AppendEntriesResponse struct {
AppendEntriesResponse *AppendEntriesResponse `protobuf:"bytes,2,opt,name=AppendEntriesResponse,proto3,oneof"`
}
type Raft_CommandName ¶
type Raft_CommandName struct {
CommandName string `protobuf:"bytes,5,opt,name=CommandName,proto3,oneof"`
}
type Raft_RequestVoteRequest ¶
type Raft_RequestVoteRequest struct {
RequestVoteRequest *RequestVoteRequest `protobuf:"bytes,3,opt,name=RequestVoteRequest,proto3,oneof"`
}
type Raft_RequestVoteResponse ¶
type Raft_RequestVoteResponse struct {
RequestVoteResponse *RequestVoteResponse `protobuf:"bytes,4,opt,name=RequestVoteResponse,proto3,oneof"`
}
type RequestVoteRequest ¶
type RequestVoteRequest struct { Term uint64 `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"` LastLogIndex uint64 `protobuf:"varint,2,opt,name=LastLogIndex,proto3" json:"LastLogIndex,omitempty"` LastLogTerm uint64 `protobuf:"varint,3,opt,name=LastLogTerm,proto3" json:"LastLogTerm,omitempty"` CandidateName string `protobuf:"bytes,4,opt,name=CandidateName,proto3" json:"CandidateName,omitempty"` // contains filtered or unexported fields }
RequestVote RPC
func (*RequestVoteRequest) Descriptor
deprecated
func (*RequestVoteRequest) Descriptor() ([]byte, []int)
Deprecated: Use RequestVoteRequest.ProtoReflect.Descriptor instead.
func (*RequestVoteRequest) GetCandidateName ¶
func (x *RequestVoteRequest) GetCandidateName() 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"` VoteGranted bool `protobuf:"varint,2,opt,name=VoteGranted,proto3" json:"VoteGranted,omitempty"` // 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
Click to show internal directories.
Click to hide internal directories.