Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 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 ErrIntOverflowEraftpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEraftpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEraftpb = fmt.Errorf("proto: unexpected end of group") + var MessageType_name = map[int32]string + var MessageType_value = map[string]int32 + type ConfChange struct + ChangeType ConfChangeType + Context []byte + Id uint64 + NodeId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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) MarshalToSizedBuffer(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 + func (m *ConfChange) XXX_DiscardUnknown() + func (m *ConfChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfChange) XXX_Merge(src proto.Message) + func (m *ConfChange) XXX_Size() int + func (m *ConfChange) XXX_Unmarshal(b []byte) error + type ConfChangeSingle struct + ChangeType ConfChangeType + NodeId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfChangeSingle) Descriptor() ([]byte, []int) + func (*ConfChangeSingle) ProtoMessage() + func (m *ConfChangeSingle) GetChangeType() ConfChangeType + func (m *ConfChangeSingle) GetNodeId() uint64 + func (m *ConfChangeSingle) Marshal() (dAtA []byte, err error) + func (m *ConfChangeSingle) MarshalTo(dAtA []byte) (int, error) + func (m *ConfChangeSingle) MarshalToSizedBuffer(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 + func (m *ConfChangeSingle) XXX_DiscardUnknown() + func (m *ConfChangeSingle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfChangeSingle) XXX_Merge(src proto.Message) + func (m *ConfChangeSingle) XXX_Size() int + func (m *ConfChangeSingle) XXX_Unmarshal(b []byte) error + type ConfChangeTransition int32 + const ConfChangeTransition_Auto + const ConfChangeTransition_Explicit + const ConfChangeTransition_Implicit + func (ConfChangeTransition) EnumDescriptor() ([]byte, []int) + func (x ConfChangeTransition) String() string + type ConfChangeType int32 + const ConfChangeType_AddLearnerNode + const ConfChangeType_AddNode + const ConfChangeType_RemoveNode + func (ConfChangeType) EnumDescriptor() ([]byte, []int) + func (x ConfChangeType) String() string + type ConfChangeV2 struct + Changes []*ConfChangeSingle + Context []byte + Transition ConfChangeTransition + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfChangeV2) Descriptor() ([]byte, []int) + func (*ConfChangeV2) ProtoMessage() + func (m *ConfChangeV2) GetChanges() []*ConfChangeSingle + func (m *ConfChangeV2) GetContext() []byte + func (m *ConfChangeV2) GetTransition() ConfChangeTransition + func (m *ConfChangeV2) Marshal() (dAtA []byte, err error) + func (m *ConfChangeV2) MarshalTo(dAtA []byte) (int, error) + func (m *ConfChangeV2) MarshalToSizedBuffer(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 + func (m *ConfChangeV2) XXX_DiscardUnknown() + func (m *ConfChangeV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfChangeV2) XXX_Merge(src proto.Message) + func (m *ConfChangeV2) XXX_Size() int + func (m *ConfChangeV2) XXX_Unmarshal(b []byte) error + type ConfState struct + AutoLeave bool + Learners []uint64 + LearnersNext []uint64 + Voters []uint64 + VotersOutgoing []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfState) Descriptor() ([]byte, []int) + func (*ConfState) ProtoMessage() + func (m *ConfState) GetAutoLeave() bool + func (m *ConfState) GetLearners() []uint64 + func (m *ConfState) GetLearnersNext() []uint64 + func (m *ConfState) GetVoters() []uint64 + func (m *ConfState) GetVotersOutgoing() []uint64 + func (m *ConfState) Marshal() (dAtA []byte, err error) + func (m *ConfState) MarshalTo(dAtA []byte) (int, error) + func (m *ConfState) MarshalToSizedBuffer(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 + func (m *ConfState) XXX_DiscardUnknown() + func (m *ConfState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfState) XXX_Merge(src proto.Message) + func (m *ConfState) XXX_Size() int + func (m *ConfState) XXX_Unmarshal(b []byte) error + type Entry struct + Context []byte + Data []byte + EntryType EntryType + Index uint64 + SyncLog bool + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + func (m *Entry) GetContext() []byte + 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) MarshalToSizedBuffer(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 + func (m *Entry) XXX_DiscardUnknown() + func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Entry) XXX_Merge(src proto.Message) + func (m *Entry) XXX_Size() int + func (m *Entry) XXX_Unmarshal(b []byte) error + type EntryType int32 + const EntryType_EntryConfChange + const EntryType_EntryConfChangeV2 + const EntryType_EntryNormal + func (EntryType) EnumDescriptor() ([]byte, []int) + func (x EntryType) String() string + type HardState struct + Commit uint64 + Term uint64 + Vote uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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) MarshalToSizedBuffer(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 + func (m *HardState) XXX_DiscardUnknown() + func (m *HardState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HardState) XXX_Merge(src proto.Message) + func (m *HardState) XXX_Size() int + func (m *HardState) XXX_Unmarshal(b []byte) error + type Message struct + Commit uint64 + Context []byte + DeprecatedPriority uint64 + Entries []*Entry + From uint64 + Index uint64 + LogTerm uint64 + MsgType MessageType + Priority int64 + Reject bool + RejectHint uint64 + RequestSnapshot uint64 + Snapshot *Snapshot + Term uint64 + To uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetCommit() uint64 + func (m *Message) GetContext() []byte + func (m *Message) GetDeprecatedPriority() uint64 + 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) GetPriority() int64 + func (m *Message) GetReject() bool + func (m *Message) GetRejectHint() uint64 + func (m *Message) GetRequestSnapshot() 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) MarshalToSizedBuffer(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 + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []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) String() string + type Snapshot struct + Data []byte + Metadata *SnapshotMetadata + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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) MarshalToSizedBuffer(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 + func (m *Snapshot) XXX_DiscardUnknown() + func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Snapshot) XXX_Merge(src proto.Message) + func (m *Snapshot) XXX_Size() int + func (m *Snapshot) XXX_Unmarshal(b []byte) error + type SnapshotMetadata struct + ConfState *ConfState + Index uint64 + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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) MarshalToSizedBuffer(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 + func (m *SnapshotMetadata) XXX_DiscardUnknown() + func (m *SnapshotMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotMetadata) XXX_Merge(src proto.Message) + func (m *SnapshotMetadata) XXX_Size() int + func (m *SnapshotMetadata) XXX_Unmarshal(b []byte) error