Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 Changes in this version + var ConfChangeType_name = map[int32]string + var ConfChangeType_value = map[string]int32 + var EntryType_name = map[int32]string + var EntryType_value = map[string]int32 + var ErrIntOverflowEraftpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEraftpb = fmt.Errorf("proto: negative length found during unmarshaling") + var MessageType_name = map[int32]string + var MessageType_value = map[string]int32 + type ConfChange struct + ChangeType *ConfChangeType + Context []byte + Id *uint64 + NodeId *uint64 + XXX_unrecognized []byte + func (*ConfChange) Descriptor() ([]byte, []int) + func (*ConfChange) ProtoMessage() + func (m *ConfChange) GetChangeType() ConfChangeType + func (m *ConfChange) GetContext() []byte + func (m *ConfChange) GetId() uint64 + func (m *ConfChange) GetNodeId() uint64 + func (m *ConfChange) Marshal() (dAtA []byte, err error) + func (m *ConfChange) MarshalTo(dAtA []byte) (int, error) + func (m *ConfChange) Reset() + func (m *ConfChange) Size() (n int) + func (m *ConfChange) String() string + func (m *ConfChange) Unmarshal(dAtA []byte) error + type ConfChangeType int32 + const ConfChangeType_AddNode + const ConfChangeType_RemoveNode + func (ConfChangeType) EnumDescriptor() ([]byte, []int) + func (x *ConfChangeType) UnmarshalJSON(data []byte) error + func (x ConfChangeType) Enum() *ConfChangeType + func (x ConfChangeType) String() string + type ConfState struct + Nodes []uint64 + XXX_unrecognized []byte + func (*ConfState) Descriptor() ([]byte, []int) + func (*ConfState) ProtoMessage() + func (m *ConfState) GetNodes() []uint64 + func (m *ConfState) Marshal() (dAtA []byte, err error) + func (m *ConfState) MarshalTo(dAtA []byte) (int, error) + func (m *ConfState) Reset() + func (m *ConfState) Size() (n int) + func (m *ConfState) String() string + func (m *ConfState) Unmarshal(dAtA []byte) error + type Entry struct + Data []byte + EntryType *EntryType + Index *uint64 + SyncLog *bool + Term *uint64 + XXX_unrecognized []byte + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + func (m *Entry) GetData() []byte + func (m *Entry) GetEntryType() EntryType + func (m *Entry) GetIndex() uint64 + func (m *Entry) GetSyncLog() bool + func (m *Entry) GetTerm() uint64 + func (m *Entry) Marshal() (dAtA []byte, err error) + func (m *Entry) MarshalTo(dAtA []byte) (int, error) + func (m *Entry) Reset() + func (m *Entry) Size() (n int) + func (m *Entry) String() string + func (m *Entry) Unmarshal(dAtA []byte) error + type EntryType int32 + const EntryType_EntryConfChange + const EntryType_EntryNormal + func (EntryType) EnumDescriptor() ([]byte, []int) + func (x *EntryType) UnmarshalJSON(data []byte) error + func (x EntryType) Enum() *EntryType + func (x EntryType) String() string + type HardState struct + Commit *uint64 + Term *uint64 + Vote *uint64 + XXX_unrecognized []byte + func (*HardState) Descriptor() ([]byte, []int) + func (*HardState) ProtoMessage() + func (m *HardState) GetCommit() uint64 + func (m *HardState) GetTerm() uint64 + func (m *HardState) GetVote() uint64 + func (m *HardState) Marshal() (dAtA []byte, err error) + func (m *HardState) MarshalTo(dAtA []byte) (int, error) + func (m *HardState) Reset() + func (m *HardState) Size() (n int) + func (m *HardState) String() string + func (m *HardState) Unmarshal(dAtA []byte) error + type Message struct + Commit *uint64 + Context []byte + Entries []*Entry + From *uint64 + Index *uint64 + LogTerm *uint64 + MsgType *MessageType + Reject *bool + RejectHint *uint64 + Snapshot *Snapshot + Term *uint64 + To *uint64 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetCommit() uint64 + func (m *Message) GetContext() []byte + func (m *Message) GetEntries() []*Entry + func (m *Message) GetFrom() uint64 + func (m *Message) GetIndex() uint64 + func (m *Message) GetLogTerm() uint64 + func (m *Message) GetMsgType() MessageType + func (m *Message) GetReject() bool + func (m *Message) GetRejectHint() uint64 + func (m *Message) GetSnapshot() *Snapshot + func (m *Message) GetTerm() uint64 + func (m *Message) GetTo() uint64 + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + type MessageType int32 + const MessageType_MsgAppend + const MessageType_MsgAppendResponse + const MessageType_MsgBeat + const MessageType_MsgCheckQuorum + const MessageType_MsgHeartbeat + const MessageType_MsgHeartbeatResponse + const MessageType_MsgHup + const MessageType_MsgPropose + const MessageType_MsgReadIndex + const MessageType_MsgReadIndexResp + const MessageType_MsgRequestPreVote + const MessageType_MsgRequestPreVoteResponse + const MessageType_MsgRequestVote + const MessageType_MsgRequestVoteResponse + const MessageType_MsgSnapStatus + const MessageType_MsgSnapshot + const MessageType_MsgTimeoutNow + const MessageType_MsgTransferLeader + const MessageType_MsgUnreachable + func (MessageType) EnumDescriptor() ([]byte, []int) + func (x *MessageType) UnmarshalJSON(data []byte) error + func (x MessageType) Enum() *MessageType + func (x MessageType) String() string + type Snapshot struct + Data []byte + Metadata *SnapshotMetadata + XXX_unrecognized []byte + func (*Snapshot) Descriptor() ([]byte, []int) + func (*Snapshot) ProtoMessage() + func (m *Snapshot) GetData() []byte + func (m *Snapshot) GetMetadata() *SnapshotMetadata + func (m *Snapshot) Marshal() (dAtA []byte, err error) + func (m *Snapshot) MarshalTo(dAtA []byte) (int, error) + func (m *Snapshot) Reset() + func (m *Snapshot) Size() (n int) + func (m *Snapshot) String() string + func (m *Snapshot) Unmarshal(dAtA []byte) error + type SnapshotMetadata struct + ConfState *ConfState + Index *uint64 + Term *uint64 + XXX_unrecognized []byte + func (*SnapshotMetadata) Descriptor() ([]byte, []int) + func (*SnapshotMetadata) ProtoMessage() + func (m *SnapshotMetadata) GetConfState() *ConfState + func (m *SnapshotMetadata) GetIndex() uint64 + func (m *SnapshotMetadata) GetTerm() uint64 + func (m *SnapshotMetadata) Marshal() (dAtA []byte, err error) + func (m *SnapshotMetadata) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotMetadata) Reset() + func (m *SnapshotMetadata) Size() (n int) + func (m *SnapshotMetadata) String() string + func (m *SnapshotMetadata) Unmarshal(dAtA []byte) error