Documentation
¶
Overview ¶
Package protobuf is a generated protocol buffer package.
It is generated from these files:
append_entries_request.proto append_entries_responses.proto log_entry.proto request_vote_request.proto request_vote_responses.proto snapshot_recovery_request.proto snapshot_recovery_response.proto snapshot_request.proto snapshot_response.proto
It has these top-level messages:
AppendEntriesRequest
Index ¶
- type AppendEntriesRequest
- func (m *AppendEntriesRequest) GetCommitIndex() uint64
- func (m *AppendEntriesRequest) GetEntries() []*LogEntry
- func (m *AppendEntriesRequest) GetLeaderName() string
- func (m *AppendEntriesRequest) GetPrevLogIndex() uint64
- func (m *AppendEntriesRequest) GetPrevLogTerm() uint64
- func (m *AppendEntriesRequest) GetTerm() uint64
- func (*AppendEntriesRequest) ProtoMessage()
- func (m *AppendEntriesRequest) Reset()
- func (m *AppendEntriesRequest) String() string
- type AppendEntriesResponse
- func (m *AppendEntriesResponse) GetCommitIndex() uint64
- func (m *AppendEntriesResponse) GetIndex() uint64
- func (m *AppendEntriesResponse) GetSuccess() bool
- func (m *AppendEntriesResponse) GetTerm() uint64
- func (*AppendEntriesResponse) ProtoMessage()
- func (m *AppendEntriesResponse) Reset()
- func (m *AppendEntriesResponse) String() string
- type LogEntry
- type RequestVoteRequest
- func (m *RequestVoteRequest) GetCandidateName() string
- func (m *RequestVoteRequest) GetLastLogIndex() uint64
- func (m *RequestVoteRequest) GetLastLogTerm() uint64
- func (m *RequestVoteRequest) GetTerm() uint64
- func (*RequestVoteRequest) ProtoMessage()
- func (m *RequestVoteRequest) Reset()
- func (m *RequestVoteRequest) String() string
- type RequestVoteResponse
- type SnapshotRecoveryRequest
- func (m *SnapshotRecoveryRequest) GetLastIndex() uint64
- func (m *SnapshotRecoveryRequest) GetLastTerm() uint64
- func (m *SnapshotRecoveryRequest) GetLeaderName() string
- func (m *SnapshotRecoveryRequest) GetPeers() []*SnapshotRecoveryRequest_Peer
- func (m *SnapshotRecoveryRequest) GetState() []byte
- func (*SnapshotRecoveryRequest) ProtoMessage()
- func (m *SnapshotRecoveryRequest) Reset()
- func (m *SnapshotRecoveryRequest) String() string
- type SnapshotRecoveryRequest_Peer
- type SnapshotRecoveryResponse
- func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64
- func (m *SnapshotRecoveryResponse) GetSuccess() bool
- func (m *SnapshotRecoveryResponse) GetTerm() uint64
- func (*SnapshotRecoveryResponse) ProtoMessage()
- func (m *SnapshotRecoveryResponse) Reset()
- func (m *SnapshotRecoveryResponse) String() string
- type SnapshotRequest
- type SnapshotResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppendEntriesRequest ¶
type AppendEntriesRequest 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 []*LogEntry `protobuf:"bytes,6,rep" json:"Entries,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*AppendEntriesRequest) GetCommitIndex ¶
func (m *AppendEntriesRequest) GetCommitIndex() uint64
func (*AppendEntriesRequest) GetEntries ¶
func (m *AppendEntriesRequest) GetEntries() []*LogEntry
func (*AppendEntriesRequest) GetLeaderName ¶
func (m *AppendEntriesRequest) GetLeaderName() string
func (*AppendEntriesRequest) GetPrevLogIndex ¶
func (m *AppendEntriesRequest) GetPrevLogIndex() uint64
func (*AppendEntriesRequest) GetPrevLogTerm ¶
func (m *AppendEntriesRequest) GetPrevLogTerm() uint64
func (*AppendEntriesRequest) GetTerm ¶
func (m *AppendEntriesRequest) GetTerm() uint64
func (*AppendEntriesRequest) ProtoMessage ¶
func (*AppendEntriesRequest) ProtoMessage()
func (*AppendEntriesRequest) Reset ¶
func (m *AppendEntriesRequest) Reset()
func (*AppendEntriesRequest) String ¶
func (m *AppendEntriesRequest) String() string
type AppendEntriesResponse ¶
type AppendEntriesResponse 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 (*AppendEntriesResponse) GetCommitIndex ¶
func (m *AppendEntriesResponse) GetCommitIndex() uint64
func (*AppendEntriesResponse) GetIndex ¶
func (m *AppendEntriesResponse) GetIndex() uint64
func (*AppendEntriesResponse) GetSuccess ¶
func (m *AppendEntriesResponse) GetSuccess() bool
func (*AppendEntriesResponse) GetTerm ¶
func (m *AppendEntriesResponse) GetTerm() uint64
func (*AppendEntriesResponse) ProtoMessage ¶
func (*AppendEntriesResponse) ProtoMessage()
func (*AppendEntriesResponse) Reset ¶
func (m *AppendEntriesResponse) Reset()
func (*AppendEntriesResponse) String ¶
func (m *AppendEntriesResponse) String() string
type LogEntry ¶
type LogEntry 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 (*LogEntry) GetCommand ¶
func (*LogEntry) GetCommandName ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
type RequestVoteRequest ¶
type RequestVoteRequest 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 (*RequestVoteRequest) GetCandidateName ¶
func (m *RequestVoteRequest) GetCandidateName() string
func (*RequestVoteRequest) GetLastLogIndex ¶
func (m *RequestVoteRequest) GetLastLogIndex() uint64
func (*RequestVoteRequest) GetLastLogTerm ¶
func (m *RequestVoteRequest) GetLastLogTerm() uint64
func (*RequestVoteRequest) GetTerm ¶
func (m *RequestVoteRequest) GetTerm() uint64
func (*RequestVoteRequest) ProtoMessage ¶
func (*RequestVoteRequest) ProtoMessage()
func (*RequestVoteRequest) Reset ¶
func (m *RequestVoteRequest) Reset()
func (*RequestVoteRequest) String ¶
func (m *RequestVoteRequest) String() string
type RequestVoteResponse ¶
type RequestVoteResponse struct {
Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"`
VoteGranted *bool `protobuf:"varint,2,req" json:"VoteGranted,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*RequestVoteResponse) GetTerm ¶
func (m *RequestVoteResponse) GetTerm() uint64
func (*RequestVoteResponse) GetVoteGranted ¶
func (m *RequestVoteResponse) GetVoteGranted() bool
func (*RequestVoteResponse) ProtoMessage ¶
func (*RequestVoteResponse) ProtoMessage()
func (*RequestVoteResponse) Reset ¶
func (m *RequestVoteResponse) Reset()
func (*RequestVoteResponse) String ¶
func (m *RequestVoteResponse) String() string
type SnapshotRecoveryRequest ¶
type SnapshotRecoveryRequest 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 []*SnapshotRecoveryRequest_Peer `protobuf:"bytes,4,rep" json:"Peers,omitempty"`
State []byte `protobuf:"bytes,5,req" json:"State,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*SnapshotRecoveryRequest) GetLastIndex ¶
func (m *SnapshotRecoveryRequest) GetLastIndex() uint64
func (*SnapshotRecoveryRequest) GetLastTerm ¶
func (m *SnapshotRecoveryRequest) GetLastTerm() uint64
func (*SnapshotRecoveryRequest) GetLeaderName ¶
func (m *SnapshotRecoveryRequest) GetLeaderName() string
func (*SnapshotRecoveryRequest) GetPeers ¶
func (m *SnapshotRecoveryRequest) GetPeers() []*SnapshotRecoveryRequest_Peer
func (*SnapshotRecoveryRequest) GetState ¶
func (m *SnapshotRecoveryRequest) GetState() []byte
func (*SnapshotRecoveryRequest) ProtoMessage ¶
func (*SnapshotRecoveryRequest) ProtoMessage()
func (*SnapshotRecoveryRequest) Reset ¶
func (m *SnapshotRecoveryRequest) Reset()
func (*SnapshotRecoveryRequest) String ¶
func (m *SnapshotRecoveryRequest) String() string
type SnapshotRecoveryRequest_Peer ¶
type SnapshotRecoveryRequest_Peer struct {
Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"`
ConnectionString *string `protobuf:"bytes,2,req" json:"ConnectionString,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*SnapshotRecoveryRequest_Peer) GetConnectionString ¶
func (m *SnapshotRecoveryRequest_Peer) GetConnectionString() string
func (*SnapshotRecoveryRequest_Peer) GetName ¶
func (m *SnapshotRecoveryRequest_Peer) GetName() string
func (*SnapshotRecoveryRequest_Peer) ProtoMessage ¶
func (*SnapshotRecoveryRequest_Peer) ProtoMessage()
func (*SnapshotRecoveryRequest_Peer) Reset ¶
func (m *SnapshotRecoveryRequest_Peer) Reset()
func (*SnapshotRecoveryRequest_Peer) String ¶
func (m *SnapshotRecoveryRequest_Peer) String() string
type SnapshotRecoveryResponse ¶
type SnapshotRecoveryResponse 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 (*SnapshotRecoveryResponse) GetCommitIndex ¶
func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64
func (*SnapshotRecoveryResponse) GetSuccess ¶
func (m *SnapshotRecoveryResponse) GetSuccess() bool
func (*SnapshotRecoveryResponse) GetTerm ¶
func (m *SnapshotRecoveryResponse) GetTerm() uint64
func (*SnapshotRecoveryResponse) ProtoMessage ¶
func (*SnapshotRecoveryResponse) ProtoMessage()
func (*SnapshotRecoveryResponse) Reset ¶
func (m *SnapshotRecoveryResponse) Reset()
func (*SnapshotRecoveryResponse) String ¶
func (m *SnapshotRecoveryResponse) String() string
type SnapshotRequest ¶
type SnapshotRequest 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 (*SnapshotRequest) GetLastIndex ¶
func (m *SnapshotRequest) GetLastIndex() uint64
func (*SnapshotRequest) GetLastTerm ¶
func (m *SnapshotRequest) GetLastTerm() uint64
func (*SnapshotRequest) GetLeaderName ¶
func (m *SnapshotRequest) GetLeaderName() string
func (*SnapshotRequest) ProtoMessage ¶
func (*SnapshotRequest) ProtoMessage()
func (*SnapshotRequest) Reset ¶
func (m *SnapshotRequest) Reset()
func (*SnapshotRequest) String ¶
func (m *SnapshotRequest) String() string
type SnapshotResponse ¶
type SnapshotResponse struct {
Success *bool `protobuf:"varint,1,req" json:"Success,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*SnapshotResponse) GetSuccess ¶
func (m *SnapshotResponse) GetSuccess() bool
func (*SnapshotResponse) ProtoMessage ¶
func (*SnapshotResponse) ProtoMessage()
func (*SnapshotResponse) Reset ¶
func (m *SnapshotResponse) Reset()
func (*SnapshotResponse) String ¶
func (m *SnapshotResponse) String() string
Click to show internal directories.
Click to hide internal directories.