Versions in this module Expand all Collapse all v3 v3.4.6 Mar 19, 2020 Changes in this version + var ConfChangeTransition_name = map[int32]string + var ConfChangeTransition_value = map[string]int32 + 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 + func ConfChangesToString(ccs []ConfChangeSingle) string + type ConfChange struct + Context []byte + ID uint64 + NodeID uint64 + Type ConfChangeType + XXX_unrecognized []byte + func (*ConfChange) Descriptor() ([]byte, []int) + func (*ConfChange) ProtoMessage() + func (c ConfChange) AsV1() (ConfChange, bool) + func (c ConfChange) AsV2() ConfChangeV2 + 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 ConfChangeI interface + AsV1 func() (ConfChange, bool) + AsV2 func() ConfChangeV2 + type ConfChangeSingle struct + NodeID uint64 + Type ConfChangeType + XXX_unrecognized []byte + func ConfChangesFromString(s string) ([]ConfChangeSingle, error) + func (*ConfChangeSingle) Descriptor() ([]byte, []int) + func (*ConfChangeSingle) ProtoMessage() + func (m *ConfChangeSingle) Marshal() (dAtA []byte, err error) + func (m *ConfChangeSingle) MarshalTo(dAtA []byte) (int, error) + func (m *ConfChangeSingle) Reset() + func (m *ConfChangeSingle) Size() (n int) + func (m *ConfChangeSingle) String() string + func (m *ConfChangeSingle) Unmarshal(dAtA []byte) error + type ConfChangeTransition int32 + const ConfChangeTransitionAuto + const ConfChangeTransitionJointExplicit + const ConfChangeTransitionJointImplicit + func (ConfChangeTransition) EnumDescriptor() ([]byte, []int) + func (x *ConfChangeTransition) UnmarshalJSON(data []byte) error + func (x ConfChangeTransition) Enum() *ConfChangeTransition + func (x ConfChangeTransition) String() string + 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 ConfChangeV2 struct + Changes []ConfChangeSingle + Context []byte + Transition ConfChangeTransition + XXX_unrecognized []byte + func (*ConfChangeV2) Descriptor() ([]byte, []int) + func (*ConfChangeV2) ProtoMessage() + func (c ConfChangeV2) AsV1() (ConfChange, bool) + func (c ConfChangeV2) AsV2() ConfChangeV2 + func (c ConfChangeV2) EnterJoint() (autoLeave bool, ok bool) + func (c ConfChangeV2) LeaveJoint() bool + func (m *ConfChangeV2) Marshal() (dAtA []byte, err error) + func (m *ConfChangeV2) MarshalTo(dAtA []byte) (int, error) + func (m *ConfChangeV2) Reset() + func (m *ConfChangeV2) Size() (n int) + func (m *ConfChangeV2) String() string + func (m *ConfChangeV2) Unmarshal(dAtA []byte) error + type ConfState struct + AutoLeave bool + Learners []uint64 + LearnersNext []uint64 + Voters []uint64 + VotersOutgoing []uint64 + XXX_unrecognized []byte + func (*ConfState) Descriptor() ([]byte, []int) + func (*ConfState) ProtoMessage() + func (cs ConfState) Equivalent(cs2 ConfState) error + 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 EntryConfChangeV2 + const EntryNormal + func MarshalConfChange(c ConfChangeI) (EntryType, []byte, error) + 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