Documentation ¶
Index ¶
- type ProtoAppendEntriesRequest
- func (m *ProtoAppendEntriesRequest) GetCommitIndex() uint64
- func (m *ProtoAppendEntriesRequest) GetEntries() []*ProtoAppendEntriesRequest_ProtoLogEntry
- func (m *ProtoAppendEntriesRequest) GetLeaderName() string
- func (m *ProtoAppendEntriesRequest) GetPrevLogIndex() uint64
- func (m *ProtoAppendEntriesRequest) GetPrevLogTerm() uint64
- func (m *ProtoAppendEntriesRequest) GetTerm() uint64
- func (*ProtoAppendEntriesRequest) ProtoMessage()
- func (m *ProtoAppendEntriesRequest) Reset()
- func (m *ProtoAppendEntriesRequest) String() string
- type ProtoAppendEntriesRequest_ProtoLogEntry
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetCommand() []byte
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetCommandName() string
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetIndex() uint64
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetTerm() uint64
- func (*ProtoAppendEntriesRequest_ProtoLogEntry) ProtoMessage()
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) Reset()
- func (m *ProtoAppendEntriesRequest_ProtoLogEntry) String() string
- type ProtoAppendEntriesResponse
- func (m *ProtoAppendEntriesResponse) GetCommitIndex() uint64
- func (m *ProtoAppendEntriesResponse) GetIndex() uint64
- func (m *ProtoAppendEntriesResponse) GetSuccess() bool
- func (m *ProtoAppendEntriesResponse) GetTerm() uint64
- func (*ProtoAppendEntriesResponse) ProtoMessage()
- func (m *ProtoAppendEntriesResponse) Reset()
- func (m *ProtoAppendEntriesResponse) String() string
- type ProtoLogEntry
- type ProtoRequestVoteRequest
- func (m *ProtoRequestVoteRequest) GetCandidateName() string
- func (m *ProtoRequestVoteRequest) GetLastLogIndex() uint64
- func (m *ProtoRequestVoteRequest) GetLastLogTerm() uint64
- func (m *ProtoRequestVoteRequest) GetTerm() uint64
- func (*ProtoRequestVoteRequest) ProtoMessage()
- func (m *ProtoRequestVoteRequest) Reset()
- func (m *ProtoRequestVoteRequest) String() string
- type ProtoRequestVoteResponse
- type ProtoSnapshotRecoveryRequest
- func (m *ProtoSnapshotRecoveryRequest) GetLastIndex() uint64
- func (m *ProtoSnapshotRecoveryRequest) GetLastTerm() uint64
- func (m *ProtoSnapshotRecoveryRequest) GetLeaderName() string
- func (m *ProtoSnapshotRecoveryRequest) GetPeers() []string
- func (m *ProtoSnapshotRecoveryRequest) GetState() []byte
- func (*ProtoSnapshotRecoveryRequest) ProtoMessage()
- func (m *ProtoSnapshotRecoveryRequest) Reset()
- func (m *ProtoSnapshotRecoveryRequest) String() string
- type ProtoSnapshotRecoveryResponse
- func (m *ProtoSnapshotRecoveryResponse) GetCommitIndex() uint64
- func (m *ProtoSnapshotRecoveryResponse) GetSuccess() bool
- func (m *ProtoSnapshotRecoveryResponse) GetTerm() uint64
- func (*ProtoSnapshotRecoveryResponse) ProtoMessage()
- func (m *ProtoSnapshotRecoveryResponse) Reset()
- func (m *ProtoSnapshotRecoveryResponse) String() string
- type ProtoSnapshotRequest
- type ProtoSnapshotResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProtoAppendEntriesRequest ¶
type ProtoAppendEntriesRequest struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` PrevLogIndex *uint64 `protobuf:"varint,2,req" json:"PrevLogIndex,omitempty"` PrevLogTerm *uint64 `protobuf:"varint,3,req" json:"PrevLogTerm,omitempty"` CommitIndex *uint64 `protobuf:"varint,4,req" json:"CommitIndex,omitempty"` LeaderName *string `protobuf:"bytes,5,req" json:"LeaderName,omitempty"` Entries []*ProtoAppendEntriesRequest_ProtoLogEntry `protobuf:"bytes,6,rep" json:"Entries,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoAppendEntriesRequest) GetCommitIndex ¶
func (m *ProtoAppendEntriesRequest) GetCommitIndex() uint64
func (*ProtoAppendEntriesRequest) GetEntries ¶
func (m *ProtoAppendEntriesRequest) GetEntries() []*ProtoAppendEntriesRequest_ProtoLogEntry
func (*ProtoAppendEntriesRequest) GetLeaderName ¶
func (m *ProtoAppendEntriesRequest) GetLeaderName() string
func (*ProtoAppendEntriesRequest) GetPrevLogIndex ¶
func (m *ProtoAppendEntriesRequest) GetPrevLogIndex() uint64
func (*ProtoAppendEntriesRequest) GetPrevLogTerm ¶
func (m *ProtoAppendEntriesRequest) GetPrevLogTerm() uint64
func (*ProtoAppendEntriesRequest) GetTerm ¶
func (m *ProtoAppendEntriesRequest) GetTerm() uint64
func (*ProtoAppendEntriesRequest) ProtoMessage ¶
func (*ProtoAppendEntriesRequest) ProtoMessage()
func (*ProtoAppendEntriesRequest) Reset ¶
func (m *ProtoAppendEntriesRequest) Reset()
func (*ProtoAppendEntriesRequest) String ¶
func (m *ProtoAppendEntriesRequest) String() string
type ProtoAppendEntriesRequest_ProtoLogEntry ¶
type ProtoAppendEntriesRequest_ProtoLogEntry struct { Index *uint64 `protobuf:"varint,1,req" json:"Index,omitempty"` Term *uint64 `protobuf:"varint,2,req" json:"Term,omitempty"` CommandName *string `protobuf:"bytes,3,req" json:"CommandName,omitempty"` Command []byte `protobuf:"bytes,4,opt" json:"Command,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoAppendEntriesRequest_ProtoLogEntry) GetCommand ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetCommand() []byte
func (*ProtoAppendEntriesRequest_ProtoLogEntry) GetCommandName ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetCommandName() string
func (*ProtoAppendEntriesRequest_ProtoLogEntry) GetIndex ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetIndex() uint64
func (*ProtoAppendEntriesRequest_ProtoLogEntry) GetTerm ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) GetTerm() uint64
func (*ProtoAppendEntriesRequest_ProtoLogEntry) ProtoMessage ¶
func (*ProtoAppendEntriesRequest_ProtoLogEntry) ProtoMessage()
func (*ProtoAppendEntriesRequest_ProtoLogEntry) Reset ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) Reset()
func (*ProtoAppendEntriesRequest_ProtoLogEntry) String ¶
func (m *ProtoAppendEntriesRequest_ProtoLogEntry) String() string
type ProtoAppendEntriesResponse ¶
type ProtoAppendEntriesResponse struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` Index *uint64 `protobuf:"varint,2,req" json:"Index,omitempty"` CommitIndex *uint64 `protobuf:"varint,3,req" json:"CommitIndex,omitempty"` Success *bool `protobuf:"varint,4,req" json:"Success,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoAppendEntriesResponse) GetCommitIndex ¶
func (m *ProtoAppendEntriesResponse) GetCommitIndex() uint64
func (*ProtoAppendEntriesResponse) GetIndex ¶
func (m *ProtoAppendEntriesResponse) GetIndex() uint64
func (*ProtoAppendEntriesResponse) GetSuccess ¶
func (m *ProtoAppendEntriesResponse) GetSuccess() bool
func (*ProtoAppendEntriesResponse) GetTerm ¶
func (m *ProtoAppendEntriesResponse) GetTerm() uint64
func (*ProtoAppendEntriesResponse) ProtoMessage ¶
func (*ProtoAppendEntriesResponse) ProtoMessage()
func (*ProtoAppendEntriesResponse) Reset ¶
func (m *ProtoAppendEntriesResponse) Reset()
func (*ProtoAppendEntriesResponse) String ¶
func (m *ProtoAppendEntriesResponse) String() string
type ProtoLogEntry ¶
type ProtoLogEntry struct { Index *uint64 `protobuf:"varint,1,req" json:"Index,omitempty"` Term *uint64 `protobuf:"varint,2,req" json:"Term,omitempty"` CommandName *string `protobuf:"bytes,3,req" json:"CommandName,omitempty"` Command []byte `protobuf:"bytes,4,opt" json:"Command,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoLogEntry) GetCommand ¶
func (m *ProtoLogEntry) GetCommand() []byte
func (*ProtoLogEntry) GetCommandName ¶
func (m *ProtoLogEntry) GetCommandName() string
func (*ProtoLogEntry) GetIndex ¶
func (m *ProtoLogEntry) GetIndex() uint64
func (*ProtoLogEntry) GetTerm ¶
func (m *ProtoLogEntry) GetTerm() uint64
func (*ProtoLogEntry) ProtoMessage ¶
func (*ProtoLogEntry) ProtoMessage()
func (*ProtoLogEntry) Reset ¶
func (m *ProtoLogEntry) Reset()
func (*ProtoLogEntry) String ¶
func (m *ProtoLogEntry) String() string
type ProtoRequestVoteRequest ¶
type ProtoRequestVoteRequest struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` LastLogIndex *uint64 `protobuf:"varint,2,req" json:"LastLogIndex,omitempty"` LastLogTerm *uint64 `protobuf:"varint,3,req" json:"LastLogTerm,omitempty"` CandidateName *string `protobuf:"bytes,4,req" json:"CandidateName,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoRequestVoteRequest) GetCandidateName ¶
func (m *ProtoRequestVoteRequest) GetCandidateName() string
func (*ProtoRequestVoteRequest) GetLastLogIndex ¶
func (m *ProtoRequestVoteRequest) GetLastLogIndex() uint64
func (*ProtoRequestVoteRequest) GetLastLogTerm ¶
func (m *ProtoRequestVoteRequest) GetLastLogTerm() uint64
func (*ProtoRequestVoteRequest) GetTerm ¶
func (m *ProtoRequestVoteRequest) GetTerm() uint64
func (*ProtoRequestVoteRequest) ProtoMessage ¶
func (*ProtoRequestVoteRequest) ProtoMessage()
func (*ProtoRequestVoteRequest) Reset ¶
func (m *ProtoRequestVoteRequest) Reset()
func (*ProtoRequestVoteRequest) String ¶
func (m *ProtoRequestVoteRequest) String() string
type ProtoRequestVoteResponse ¶
type ProtoRequestVoteResponse struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` VoteGranted *bool `protobuf:"varint,2,req" json:"VoteGranted,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoRequestVoteResponse) GetTerm ¶
func (m *ProtoRequestVoteResponse) GetTerm() uint64
func (*ProtoRequestVoteResponse) GetVoteGranted ¶
func (m *ProtoRequestVoteResponse) GetVoteGranted() bool
func (*ProtoRequestVoteResponse) ProtoMessage ¶
func (*ProtoRequestVoteResponse) ProtoMessage()
func (*ProtoRequestVoteResponse) Reset ¶
func (m *ProtoRequestVoteResponse) Reset()
func (*ProtoRequestVoteResponse) String ¶
func (m *ProtoRequestVoteResponse) String() string
type ProtoSnapshotRecoveryRequest ¶
type ProtoSnapshotRecoveryRequest struct { LeaderName *string `protobuf:"bytes,1,req" json:"LeaderName,omitempty"` LastIndex *uint64 `protobuf:"varint,2,req" json:"LastIndex,omitempty"` LastTerm *uint64 `protobuf:"varint,3,req" json:"LastTerm,omitempty"` Peers []string `protobuf:"bytes,4,rep" json:"Peers,omitempty"` State []byte `protobuf:"bytes,5,req" json:"State,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoSnapshotRecoveryRequest) GetLastIndex ¶
func (m *ProtoSnapshotRecoveryRequest) GetLastIndex() uint64
func (*ProtoSnapshotRecoveryRequest) GetLastTerm ¶
func (m *ProtoSnapshotRecoveryRequest) GetLastTerm() uint64
func (*ProtoSnapshotRecoveryRequest) GetLeaderName ¶
func (m *ProtoSnapshotRecoveryRequest) GetLeaderName() string
func (*ProtoSnapshotRecoveryRequest) GetPeers ¶
func (m *ProtoSnapshotRecoveryRequest) GetPeers() []string
func (*ProtoSnapshotRecoveryRequest) GetState ¶
func (m *ProtoSnapshotRecoveryRequest) GetState() []byte
func (*ProtoSnapshotRecoveryRequest) ProtoMessage ¶
func (*ProtoSnapshotRecoveryRequest) ProtoMessage()
func (*ProtoSnapshotRecoveryRequest) Reset ¶
func (m *ProtoSnapshotRecoveryRequest) Reset()
func (*ProtoSnapshotRecoveryRequest) String ¶
func (m *ProtoSnapshotRecoveryRequest) String() string
type ProtoSnapshotRecoveryResponse ¶
type ProtoSnapshotRecoveryResponse struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` Success *bool `protobuf:"varint,2,req" json:"Success,omitempty"` CommitIndex *uint64 `protobuf:"varint,3,req" json:"CommitIndex,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoSnapshotRecoveryResponse) GetCommitIndex ¶
func (m *ProtoSnapshotRecoveryResponse) GetCommitIndex() uint64
func (*ProtoSnapshotRecoveryResponse) GetSuccess ¶
func (m *ProtoSnapshotRecoveryResponse) GetSuccess() bool
func (*ProtoSnapshotRecoveryResponse) GetTerm ¶
func (m *ProtoSnapshotRecoveryResponse) GetTerm() uint64
func (*ProtoSnapshotRecoveryResponse) ProtoMessage ¶
func (*ProtoSnapshotRecoveryResponse) ProtoMessage()
func (*ProtoSnapshotRecoveryResponse) Reset ¶
func (m *ProtoSnapshotRecoveryResponse) Reset()
func (*ProtoSnapshotRecoveryResponse) String ¶
func (m *ProtoSnapshotRecoveryResponse) String() string
type ProtoSnapshotRequest ¶
type ProtoSnapshotRequest struct { LeaderName *string `protobuf:"bytes,1,req" json:"LeaderName,omitempty"` LastIndex *uint64 `protobuf:"varint,2,req" json:"LastIndex,omitempty"` LastTerm *uint64 `protobuf:"varint,3,req" json:"LastTerm,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoSnapshotRequest) GetLastIndex ¶
func (m *ProtoSnapshotRequest) GetLastIndex() uint64
func (*ProtoSnapshotRequest) GetLastTerm ¶
func (m *ProtoSnapshotRequest) GetLastTerm() uint64
func (*ProtoSnapshotRequest) GetLeaderName ¶
func (m *ProtoSnapshotRequest) GetLeaderName() string
func (*ProtoSnapshotRequest) ProtoMessage ¶
func (*ProtoSnapshotRequest) ProtoMessage()
func (*ProtoSnapshotRequest) Reset ¶
func (m *ProtoSnapshotRequest) Reset()
func (*ProtoSnapshotRequest) String ¶
func (m *ProtoSnapshotRequest) String() string
type ProtoSnapshotResponse ¶
type ProtoSnapshotResponse struct { Success *bool `protobuf:"varint,1,req" json:"Success,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ProtoSnapshotResponse) GetSuccess ¶
func (m *ProtoSnapshotResponse) GetSuccess() bool
func (*ProtoSnapshotResponse) ProtoMessage ¶
func (*ProtoSnapshotResponse) ProtoMessage()
func (*ProtoSnapshotResponse) Reset ¶
func (m *ProtoSnapshotResponse) Reset()
func (*ProtoSnapshotResponse) String ¶
func (m *ProtoSnapshotResponse) String() string
Click to show internal directories.
Click to hide internal directories.