Versions in this module Expand all Collapse all v0 v0.1.0 Jun 17, 2020 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 ErrIntOverflowRaft = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRaft = fmt.Errorf("proto: negative length found during unmarshaling") + var MessageType_name = map[int32]string + var MessageType_value = map[string]int32 + type ConfChange struct + Context []byte + ID uint64 + NodeID uint64 + Type ConfChangeType + XXX_unrecognized []byte + func (*ConfChange) Descriptor() ([]byte, []int) + func (*ConfChange) ProtoMessage() + 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 ConfChangeAddLearnerNode + const ConfChangeAddNode + const ConfChangeRemoveNode + const ConfChangeUpdateNode + 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 + Learners []uint64 + Nodes []uint64 + XXX_unrecognized []byte + func (*ConfState) Descriptor() ([]byte, []int) + func (*ConfState) ProtoMessage() + 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 + Index uint64 + Term uint64 + Type EntryType + XXX_unrecognized []byte + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + 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 EntryConfChange + const 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) 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 + Reject bool + RejectHint uint64 + Snapshot Snapshot + Term uint64 + To uint64 + Type MessageType + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + 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 MsgApp + const MsgAppResp + const MsgBeat + const MsgCheckQuorum + const MsgHeartbeat + const MsgHeartbeatResp + const MsgHup + const MsgPreVote + const MsgPreVoteResp + const MsgProp + const MsgReadIndex + const MsgReadIndexResp + const MsgSnap + const MsgSnapStatus + const MsgTimeoutNow + const MsgTransferLeader + const MsgUnreachable + const MsgVote + const MsgVoteResp + 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) 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) 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
Go to main page