Documentation ¶
Index ¶
- type AppendEntriesRequest
- func (this *AppendEntriesRequest) Equal(that interface{}) bool
- 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 (this *AppendEntriesRequest) GoString() string
- func (m *AppendEntriesRequest) Marshal() (data []byte, err error)
- func (m *AppendEntriesRequest) MarshalTo(data []byte) (n int, err error)
- func (*AppendEntriesRequest) ProtoMessage()
- func (m *AppendEntriesRequest) Reset()
- func (m *AppendEntriesRequest) Size() (n int)
- func (this *AppendEntriesRequest) String() string
- func (m *AppendEntriesRequest) Unmarshal(data []byte) error
- func (this *AppendEntriesRequest) VerboseEqual(that interface{}) error
- type AppendEntriesResponse
- func (this *AppendEntriesResponse) Equal(that interface{}) bool
- func (m *AppendEntriesResponse) GetCommitIndex() uint64
- func (m *AppendEntriesResponse) GetIndex() uint64
- func (m *AppendEntriesResponse) GetSuccess() bool
- func (m *AppendEntriesResponse) GetTerm() uint64
- func (this *AppendEntriesResponse) GoString() string
- func (m *AppendEntriesResponse) Marshal() (data []byte, err error)
- func (m *AppendEntriesResponse) MarshalTo(data []byte) (n int, err error)
- func (*AppendEntriesResponse) ProtoMessage()
- func (m *AppendEntriesResponse) Reset()
- func (m *AppendEntriesResponse) Size() (n int)
- func (this *AppendEntriesResponse) String() string
- func (m *AppendEntriesResponse) Unmarshal(data []byte) error
- func (this *AppendEntriesResponse) VerboseEqual(that interface{}) error
- type LogEntry
- func (this *LogEntry) Equal(that interface{}) bool
- func (m *LogEntry) GetCommand() []byte
- func (m *LogEntry) GetCommandName() string
- func (m *LogEntry) GetIndex() uint64
- func (m *LogEntry) GetTerm() uint64
- func (this *LogEntry) GoString() string
- func (m *LogEntry) Marshal() (data []byte, err error)
- func (m *LogEntry) MarshalTo(data []byte) (n int, err error)
- func (*LogEntry) ProtoMessage()
- func (m *LogEntry) Reset()
- func (m *LogEntry) Size() (n int)
- func (this *LogEntry) String() string
- func (m *LogEntry) Unmarshal(data []byte) error
- func (this *LogEntry) VerboseEqual(that interface{}) error
- type RequestVoteRequest
- func (this *RequestVoteRequest) Equal(that interface{}) bool
- func (m *RequestVoteRequest) GetCandidateName() string
- func (m *RequestVoteRequest) GetLastLogIndex() uint64
- func (m *RequestVoteRequest) GetLastLogTerm() uint64
- func (m *RequestVoteRequest) GetTerm() uint64
- func (this *RequestVoteRequest) GoString() string
- func (m *RequestVoteRequest) Marshal() (data []byte, err error)
- func (m *RequestVoteRequest) MarshalTo(data []byte) (n int, err error)
- func (*RequestVoteRequest) ProtoMessage()
- func (m *RequestVoteRequest) Reset()
- func (m *RequestVoteRequest) Size() (n int)
- func (this *RequestVoteRequest) String() string
- func (m *RequestVoteRequest) Unmarshal(data []byte) error
- func (this *RequestVoteRequest) VerboseEqual(that interface{}) error
- type RequestVoteResponse
- func (this *RequestVoteResponse) Equal(that interface{}) bool
- func (m *RequestVoteResponse) GetTerm() uint64
- func (m *RequestVoteResponse) GetVoteGranted() bool
- func (this *RequestVoteResponse) GoString() string
- func (m *RequestVoteResponse) Marshal() (data []byte, err error)
- func (m *RequestVoteResponse) MarshalTo(data []byte) (n int, err error)
- func (*RequestVoteResponse) ProtoMessage()
- func (m *RequestVoteResponse) Reset()
- func (m *RequestVoteResponse) Size() (n int)
- func (this *RequestVoteResponse) String() string
- func (m *RequestVoteResponse) Unmarshal(data []byte) error
- func (this *RequestVoteResponse) VerboseEqual(that interface{}) error
- type SnapshotRecoveryRequest
- func (this *SnapshotRecoveryRequest) Equal(that interface{}) bool
- 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 (this *SnapshotRecoveryRequest) GoString() string
- func (m *SnapshotRecoveryRequest) Marshal() (data []byte, err error)
- func (m *SnapshotRecoveryRequest) MarshalTo(data []byte) (n int, err error)
- func (*SnapshotRecoveryRequest) ProtoMessage()
- func (m *SnapshotRecoveryRequest) Reset()
- func (m *SnapshotRecoveryRequest) Size() (n int)
- func (this *SnapshotRecoveryRequest) String() string
- func (m *SnapshotRecoveryRequest) Unmarshal(data []byte) error
- func (this *SnapshotRecoveryRequest) VerboseEqual(that interface{}) error
- type SnapshotRecoveryRequest_Peer
- func (this *SnapshotRecoveryRequest_Peer) Equal(that interface{}) bool
- func (m *SnapshotRecoveryRequest_Peer) GetConnectionString() string
- func (m *SnapshotRecoveryRequest_Peer) GetName() string
- func (this *SnapshotRecoveryRequest_Peer) GoString() string
- func (m *SnapshotRecoveryRequest_Peer) Marshal() (data []byte, err error)
- func (m *SnapshotRecoveryRequest_Peer) MarshalTo(data []byte) (n int, err error)
- func (*SnapshotRecoveryRequest_Peer) ProtoMessage()
- func (m *SnapshotRecoveryRequest_Peer) Reset()
- func (m *SnapshotRecoveryRequest_Peer) Size() (n int)
- func (this *SnapshotRecoveryRequest_Peer) String() string
- func (m *SnapshotRecoveryRequest_Peer) Unmarshal(data []byte) error
- func (this *SnapshotRecoveryRequest_Peer) VerboseEqual(that interface{}) error
- type SnapshotRecoveryResponse
- func (this *SnapshotRecoveryResponse) Equal(that interface{}) bool
- func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64
- func (m *SnapshotRecoveryResponse) GetSuccess() bool
- func (m *SnapshotRecoveryResponse) GetTerm() uint64
- func (this *SnapshotRecoveryResponse) GoString() string
- func (m *SnapshotRecoveryResponse) Marshal() (data []byte, err error)
- func (m *SnapshotRecoveryResponse) MarshalTo(data []byte) (n int, err error)
- func (*SnapshotRecoveryResponse) ProtoMessage()
- func (m *SnapshotRecoveryResponse) Reset()
- func (m *SnapshotRecoveryResponse) Size() (n int)
- func (this *SnapshotRecoveryResponse) String() string
- func (m *SnapshotRecoveryResponse) Unmarshal(data []byte) error
- func (this *SnapshotRecoveryResponse) VerboseEqual(that interface{}) error
- type SnapshotRequest
- func (this *SnapshotRequest) Equal(that interface{}) bool
- func (m *SnapshotRequest) GetLastIndex() uint64
- func (m *SnapshotRequest) GetLastTerm() uint64
- func (m *SnapshotRequest) GetLeaderName() string
- func (this *SnapshotRequest) GoString() string
- func (m *SnapshotRequest) Marshal() (data []byte, err error)
- func (m *SnapshotRequest) MarshalTo(data []byte) (n int, err error)
- func (*SnapshotRequest) ProtoMessage()
- func (m *SnapshotRequest) Reset()
- func (m *SnapshotRequest) Size() (n int)
- func (this *SnapshotRequest) String() string
- func (m *SnapshotRequest) Unmarshal(data []byte) error
- func (this *SnapshotRequest) VerboseEqual(that interface{}) error
- type SnapshotResponse
- func (this *SnapshotResponse) Equal(that interface{}) bool
- func (m *SnapshotResponse) GetSuccess() bool
- func (this *SnapshotResponse) GoString() string
- func (m *SnapshotResponse) Marshal() (data []byte, err error)
- func (m *SnapshotResponse) MarshalTo(data []byte) (n int, err error)
- func (*SnapshotResponse) ProtoMessage()
- func (m *SnapshotResponse) Reset()
- func (m *SnapshotResponse) Size() (n int)
- func (this *SnapshotResponse) String() string
- func (m *SnapshotResponse) Unmarshal(data []byte) error
- func (this *SnapshotResponse) VerboseEqual(that interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppendEntriesRequest ¶ added in v0.3.0
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 NewPopulatedAppendEntriesRequest ¶ added in v0.3.0
func NewPopulatedAppendEntriesRequest(r randyAppendEntriesRequest, easy bool) *AppendEntriesRequest
func (*AppendEntriesRequest) Equal ¶ added in v0.3.0
func (this *AppendEntriesRequest) Equal(that interface{}) bool
func (*AppendEntriesRequest) GetCommitIndex ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetCommitIndex() uint64
func (*AppendEntriesRequest) GetEntries ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetEntries() []*LogEntry
func (*AppendEntriesRequest) GetLeaderName ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetLeaderName() string
func (*AppendEntriesRequest) GetPrevLogIndex ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetPrevLogIndex() uint64
func (*AppendEntriesRequest) GetPrevLogTerm ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetPrevLogTerm() uint64
func (*AppendEntriesRequest) GetTerm ¶ added in v0.3.0
func (m *AppendEntriesRequest) GetTerm() uint64
func (*AppendEntriesRequest) GoString ¶ added in v0.3.0
func (this *AppendEntriesRequest) GoString() string
func (*AppendEntriesRequest) Marshal ¶ added in v0.3.0
func (m *AppendEntriesRequest) Marshal() (data []byte, err error)
func (*AppendEntriesRequest) MarshalTo ¶ added in v0.3.0
func (m *AppendEntriesRequest) MarshalTo(data []byte) (n int, err error)
func (*AppendEntriesRequest) ProtoMessage ¶ added in v0.3.0
func (*AppendEntriesRequest) ProtoMessage()
func (*AppendEntriesRequest) Reset ¶ added in v0.3.0
func (m *AppendEntriesRequest) Reset()
func (*AppendEntriesRequest) Size ¶ added in v0.3.0
func (m *AppendEntriesRequest) Size() (n int)
func (*AppendEntriesRequest) String ¶ added in v0.3.0
func (this *AppendEntriesRequest) String() string
func (*AppendEntriesRequest) Unmarshal ¶ added in v0.3.0
func (m *AppendEntriesRequest) Unmarshal(data []byte) error
func (*AppendEntriesRequest) VerboseEqual ¶ added in v0.3.0
func (this *AppendEntriesRequest) VerboseEqual(that interface{}) error
type AppendEntriesResponse ¶ added in v0.3.0
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 NewPopulatedAppendEntriesResponse ¶ added in v0.3.0
func NewPopulatedAppendEntriesResponse(r randyAppendEntriesResponses, easy bool) *AppendEntriesResponse
func (*AppendEntriesResponse) Equal ¶ added in v0.3.0
func (this *AppendEntriesResponse) Equal(that interface{}) bool
func (*AppendEntriesResponse) GetCommitIndex ¶ added in v0.3.0
func (m *AppendEntriesResponse) GetCommitIndex() uint64
func (*AppendEntriesResponse) GetIndex ¶ added in v0.3.0
func (m *AppendEntriesResponse) GetIndex() uint64
func (*AppendEntriesResponse) GetSuccess ¶ added in v0.3.0
func (m *AppendEntriesResponse) GetSuccess() bool
func (*AppendEntriesResponse) GetTerm ¶ added in v0.3.0
func (m *AppendEntriesResponse) GetTerm() uint64
func (*AppendEntriesResponse) GoString ¶ added in v0.3.0
func (this *AppendEntriesResponse) GoString() string
func (*AppendEntriesResponse) Marshal ¶ added in v0.3.0
func (m *AppendEntriesResponse) Marshal() (data []byte, err error)
func (*AppendEntriesResponse) MarshalTo ¶ added in v0.3.0
func (m *AppendEntriesResponse) MarshalTo(data []byte) (n int, err error)
func (*AppendEntriesResponse) ProtoMessage ¶ added in v0.3.0
func (*AppendEntriesResponse) ProtoMessage()
func (*AppendEntriesResponse) Reset ¶ added in v0.3.0
func (m *AppendEntriesResponse) Reset()
func (*AppendEntriesResponse) Size ¶ added in v0.3.0
func (m *AppendEntriesResponse) Size() (n int)
func (*AppendEntriesResponse) String ¶ added in v0.3.0
func (this *AppendEntriesResponse) String() string
func (*AppendEntriesResponse) Unmarshal ¶ added in v0.3.0
func (m *AppendEntriesResponse) Unmarshal(data []byte) error
func (*AppendEntriesResponse) VerboseEqual ¶ added in v0.3.0
func (this *AppendEntriesResponse) VerboseEqual(that interface{}) error
type LogEntry ¶ added in v0.3.0
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 NewPopulatedLogEntry ¶ added in v0.3.0
func (*LogEntry) GetCommand ¶ added in v0.3.0
func (*LogEntry) GetCommandName ¶ added in v0.3.0
func (*LogEntry) ProtoMessage ¶ added in v0.3.0
func (*LogEntry) ProtoMessage()
func (*LogEntry) VerboseEqual ¶ added in v0.3.0
type RequestVoteRequest ¶ added in v0.3.0
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 NewPopulatedRequestVoteRequest ¶ added in v0.3.0
func NewPopulatedRequestVoteRequest(r randyRequestVoteRequest, easy bool) *RequestVoteRequest
func (*RequestVoteRequest) Equal ¶ added in v0.3.0
func (this *RequestVoteRequest) Equal(that interface{}) bool
func (*RequestVoteRequest) GetCandidateName ¶ added in v0.3.0
func (m *RequestVoteRequest) GetCandidateName() string
func (*RequestVoteRequest) GetLastLogIndex ¶ added in v0.3.0
func (m *RequestVoteRequest) GetLastLogIndex() uint64
func (*RequestVoteRequest) GetLastLogTerm ¶ added in v0.3.0
func (m *RequestVoteRequest) GetLastLogTerm() uint64
func (*RequestVoteRequest) GetTerm ¶ added in v0.3.0
func (m *RequestVoteRequest) GetTerm() uint64
func (*RequestVoteRequest) GoString ¶ added in v0.3.0
func (this *RequestVoteRequest) GoString() string
func (*RequestVoteRequest) Marshal ¶ added in v0.3.0
func (m *RequestVoteRequest) Marshal() (data []byte, err error)
func (*RequestVoteRequest) MarshalTo ¶ added in v0.3.0
func (m *RequestVoteRequest) MarshalTo(data []byte) (n int, err error)
func (*RequestVoteRequest) ProtoMessage ¶ added in v0.3.0
func (*RequestVoteRequest) ProtoMessage()
func (*RequestVoteRequest) Reset ¶ added in v0.3.0
func (m *RequestVoteRequest) Reset()
func (*RequestVoteRequest) Size ¶ added in v0.3.0
func (m *RequestVoteRequest) Size() (n int)
func (*RequestVoteRequest) String ¶ added in v0.3.0
func (this *RequestVoteRequest) String() string
func (*RequestVoteRequest) Unmarshal ¶ added in v0.3.0
func (m *RequestVoteRequest) Unmarshal(data []byte) error
func (*RequestVoteRequest) VerboseEqual ¶ added in v0.3.0
func (this *RequestVoteRequest) VerboseEqual(that interface{}) error
type RequestVoteResponse ¶ added in v0.3.0
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 NewPopulatedRequestVoteResponse ¶ added in v0.3.0
func NewPopulatedRequestVoteResponse(r randyRequestVoteResponses, easy bool) *RequestVoteResponse
func (*RequestVoteResponse) Equal ¶ added in v0.3.0
func (this *RequestVoteResponse) Equal(that interface{}) bool
func (*RequestVoteResponse) GetTerm ¶ added in v0.3.0
func (m *RequestVoteResponse) GetTerm() uint64
func (*RequestVoteResponse) GetVoteGranted ¶ added in v0.3.0
func (m *RequestVoteResponse) GetVoteGranted() bool
func (*RequestVoteResponse) GoString ¶ added in v0.3.0
func (this *RequestVoteResponse) GoString() string
func (*RequestVoteResponse) Marshal ¶ added in v0.3.0
func (m *RequestVoteResponse) Marshal() (data []byte, err error)
func (*RequestVoteResponse) MarshalTo ¶ added in v0.3.0
func (m *RequestVoteResponse) MarshalTo(data []byte) (n int, err error)
func (*RequestVoteResponse) ProtoMessage ¶ added in v0.3.0
func (*RequestVoteResponse) ProtoMessage()
func (*RequestVoteResponse) Reset ¶ added in v0.3.0
func (m *RequestVoteResponse) Reset()
func (*RequestVoteResponse) Size ¶ added in v0.3.0
func (m *RequestVoteResponse) Size() (n int)
func (*RequestVoteResponse) String ¶ added in v0.3.0
func (this *RequestVoteResponse) String() string
func (*RequestVoteResponse) Unmarshal ¶ added in v0.3.0
func (m *RequestVoteResponse) Unmarshal(data []byte) error
func (*RequestVoteResponse) VerboseEqual ¶ added in v0.3.0
func (this *RequestVoteResponse) VerboseEqual(that interface{}) error
type SnapshotRecoveryRequest ¶ added in v0.3.0
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 NewPopulatedSnapshotRecoveryRequest ¶ added in v0.3.0
func NewPopulatedSnapshotRecoveryRequest(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest
func (*SnapshotRecoveryRequest) Equal ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest) Equal(that interface{}) bool
func (*SnapshotRecoveryRequest) GetLastIndex ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) GetLastIndex() uint64
func (*SnapshotRecoveryRequest) GetLastTerm ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) GetLastTerm() uint64
func (*SnapshotRecoveryRequest) GetLeaderName ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) GetLeaderName() string
func (*SnapshotRecoveryRequest) GetPeers ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) GetPeers() []*SnapshotRecoveryRequest_Peer
func (*SnapshotRecoveryRequest) GetState ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) GetState() []byte
func (*SnapshotRecoveryRequest) GoString ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest) GoString() string
func (*SnapshotRecoveryRequest) Marshal ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) Marshal() (data []byte, err error)
func (*SnapshotRecoveryRequest) MarshalTo ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) MarshalTo(data []byte) (n int, err error)
func (*SnapshotRecoveryRequest) ProtoMessage ¶ added in v0.3.0
func (*SnapshotRecoveryRequest) ProtoMessage()
func (*SnapshotRecoveryRequest) Reset ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) Reset()
func (*SnapshotRecoveryRequest) Size ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) Size() (n int)
func (*SnapshotRecoveryRequest) String ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest) String() string
func (*SnapshotRecoveryRequest) Unmarshal ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest) Unmarshal(data []byte) error
func (*SnapshotRecoveryRequest) VerboseEqual ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest) VerboseEqual(that interface{}) error
type SnapshotRecoveryRequest_Peer ¶ added in v0.3.0
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 NewPopulatedSnapshotRecoveryRequest_Peer ¶ added in v0.3.0
func NewPopulatedSnapshotRecoveryRequest_Peer(r randySnapshotRecoveryRequest, easy bool) *SnapshotRecoveryRequest_Peer
func (*SnapshotRecoveryRequest_Peer) Equal ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest_Peer) Equal(that interface{}) bool
func (*SnapshotRecoveryRequest_Peer) GetConnectionString ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) GetConnectionString() string
func (*SnapshotRecoveryRequest_Peer) GetName ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) GetName() string
func (*SnapshotRecoveryRequest_Peer) GoString ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest_Peer) GoString() string
func (*SnapshotRecoveryRequest_Peer) Marshal ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) Marshal() (data []byte, err error)
func (*SnapshotRecoveryRequest_Peer) MarshalTo ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) MarshalTo(data []byte) (n int, err error)
func (*SnapshotRecoveryRequest_Peer) ProtoMessage ¶ added in v0.3.0
func (*SnapshotRecoveryRequest_Peer) ProtoMessage()
func (*SnapshotRecoveryRequest_Peer) Reset ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) Reset()
func (*SnapshotRecoveryRequest_Peer) Size ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) Size() (n int)
func (*SnapshotRecoveryRequest_Peer) String ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest_Peer) String() string
func (*SnapshotRecoveryRequest_Peer) Unmarshal ¶ added in v0.3.0
func (m *SnapshotRecoveryRequest_Peer) Unmarshal(data []byte) error
func (*SnapshotRecoveryRequest_Peer) VerboseEqual ¶ added in v0.3.0
func (this *SnapshotRecoveryRequest_Peer) VerboseEqual(that interface{}) error
type SnapshotRecoveryResponse ¶ added in v0.3.0
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 NewPopulatedSnapshotRecoveryResponse ¶ added in v0.3.0
func NewPopulatedSnapshotRecoveryResponse(r randySnapshotRecoveryResponse, easy bool) *SnapshotRecoveryResponse
func (*SnapshotRecoveryResponse) Equal ¶ added in v0.3.0
func (this *SnapshotRecoveryResponse) Equal(that interface{}) bool
func (*SnapshotRecoveryResponse) GetCommitIndex ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) GetCommitIndex() uint64
func (*SnapshotRecoveryResponse) GetSuccess ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) GetSuccess() bool
func (*SnapshotRecoveryResponse) GetTerm ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) GetTerm() uint64
func (*SnapshotRecoveryResponse) GoString ¶ added in v0.3.0
func (this *SnapshotRecoveryResponse) GoString() string
func (*SnapshotRecoveryResponse) Marshal ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) Marshal() (data []byte, err error)
func (*SnapshotRecoveryResponse) MarshalTo ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) MarshalTo(data []byte) (n int, err error)
func (*SnapshotRecoveryResponse) ProtoMessage ¶ added in v0.3.0
func (*SnapshotRecoveryResponse) ProtoMessage()
func (*SnapshotRecoveryResponse) Reset ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) Reset()
func (*SnapshotRecoveryResponse) Size ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) Size() (n int)
func (*SnapshotRecoveryResponse) String ¶ added in v0.3.0
func (this *SnapshotRecoveryResponse) String() string
func (*SnapshotRecoveryResponse) Unmarshal ¶ added in v0.3.0
func (m *SnapshotRecoveryResponse) Unmarshal(data []byte) error
func (*SnapshotRecoveryResponse) VerboseEqual ¶ added in v0.3.0
func (this *SnapshotRecoveryResponse) VerboseEqual(that interface{}) error
type SnapshotRequest ¶ added in v0.3.0
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 NewPopulatedSnapshotRequest ¶ added in v0.3.0
func NewPopulatedSnapshotRequest(r randySnapshotRequest, easy bool) *SnapshotRequest
func (*SnapshotRequest) Equal ¶ added in v0.3.0
func (this *SnapshotRequest) Equal(that interface{}) bool
func (*SnapshotRequest) GetLastIndex ¶ added in v0.3.0
func (m *SnapshotRequest) GetLastIndex() uint64
func (*SnapshotRequest) GetLastTerm ¶ added in v0.3.0
func (m *SnapshotRequest) GetLastTerm() uint64
func (*SnapshotRequest) GetLeaderName ¶ added in v0.3.0
func (m *SnapshotRequest) GetLeaderName() string
func (*SnapshotRequest) GoString ¶ added in v0.3.0
func (this *SnapshotRequest) GoString() string
func (*SnapshotRequest) Marshal ¶ added in v0.3.0
func (m *SnapshotRequest) Marshal() (data []byte, err error)
func (*SnapshotRequest) MarshalTo ¶ added in v0.3.0
func (m *SnapshotRequest) MarshalTo(data []byte) (n int, err error)
func (*SnapshotRequest) ProtoMessage ¶ added in v0.3.0
func (*SnapshotRequest) ProtoMessage()
func (*SnapshotRequest) Reset ¶ added in v0.3.0
func (m *SnapshotRequest) Reset()
func (*SnapshotRequest) Size ¶ added in v0.3.0
func (m *SnapshotRequest) Size() (n int)
func (*SnapshotRequest) String ¶ added in v0.3.0
func (this *SnapshotRequest) String() string
func (*SnapshotRequest) Unmarshal ¶ added in v0.3.0
func (m *SnapshotRequest) Unmarshal(data []byte) error
func (*SnapshotRequest) VerboseEqual ¶ added in v0.3.0
func (this *SnapshotRequest) VerboseEqual(that interface{}) error
type SnapshotResponse ¶ added in v0.3.0
type SnapshotResponse struct { Success *bool `protobuf:"varint,1,req" json:"Success,omitempty"` XXX_unrecognized []byte `json:"-"` }
func NewPopulatedSnapshotResponse ¶ added in v0.3.0
func NewPopulatedSnapshotResponse(r randySnapshotResponse, easy bool) *SnapshotResponse
func (*SnapshotResponse) Equal ¶ added in v0.3.0
func (this *SnapshotResponse) Equal(that interface{}) bool
func (*SnapshotResponse) GetSuccess ¶ added in v0.3.0
func (m *SnapshotResponse) GetSuccess() bool
func (*SnapshotResponse) GoString ¶ added in v0.3.0
func (this *SnapshotResponse) GoString() string
func (*SnapshotResponse) Marshal ¶ added in v0.3.0
func (m *SnapshotResponse) Marshal() (data []byte, err error)
func (*SnapshotResponse) MarshalTo ¶ added in v0.3.0
func (m *SnapshotResponse) MarshalTo(data []byte) (n int, err error)
func (*SnapshotResponse) ProtoMessage ¶ added in v0.3.0
func (*SnapshotResponse) ProtoMessage()
func (*SnapshotResponse) Reset ¶ added in v0.3.0
func (m *SnapshotResponse) Reset()
func (*SnapshotResponse) Size ¶ added in v0.3.0
func (m *SnapshotResponse) Size() (n int)
func (*SnapshotResponse) String ¶ added in v0.3.0
func (this *SnapshotResponse) String() string
func (*SnapshotResponse) Unmarshal ¶ added in v0.3.0
func (m *SnapshotResponse) Unmarshal(data []byte) error
func (*SnapshotResponse) VerboseEqual ¶ added in v0.3.0
func (this *SnapshotResponse) VerboseEqual(that interface{}) error
Click to show internal directories.
Click to hide internal directories.