Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

raftpb

package

Go to main page

Versions in this module

v3

v3.6.0

Feb 5, 2025

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 ErrUnexpectedEndOfGroupRaft = fmt.Errorf("proto: unexpected end of group")

+ 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

+ 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) 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 ConfChangeI interface

+ AsV1 func() (ConfChange, bool)

+ AsV2 func() ConfChangeV2

+ type ConfChangeSingle struct

+ NodeID uint64

+ Type ConfChangeType

+ 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) 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 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

+ 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) 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

+ 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) 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

+ Data []byte

+ Index uint64

+ Term uint64

+ Type EntryType

+ 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) 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 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

+ 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) 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

+ Entries []Entry

+ From uint64

+ Index uint64

+ LogTerm uint64

+ Reject bool

+ RejectHint uint64

+ Responses []Message

+ Snapshot *Snapshot

+ Term uint64

+ To uint64

+ Type MessageType

+ Vote uint64

+ 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) 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 MsgApp

+ const MsgAppResp

+ const MsgBeat

+ const MsgCheckQuorum

+ const MsgForgetLeader

+ const MsgHeartbeat

+ const MsgHeartbeatResp

+ const MsgHup

+ const MsgPreVote

+ const MsgPreVoteResp

+ const MsgProp

+ const MsgReadIndex

+ const MsgReadIndexResp

+ const MsgSnap

+ const MsgSnapStatus

+ const MsgStorageAppend

+ const MsgStorageAppendResp

+ const MsgStorageApply

+ const MsgStorageApplyResp

+ 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

+ 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) 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

+ 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) 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

v3.6.0-beta.0

Nov 20, 2024

v3.6.0-alpha.0

Jan 10, 2024