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.