walpb

Documentation

Index

• Variables
• func ValidateSnapshotForWrite(e *Snapshot) error
• type Record
  • func (*Record) Descriptor() ([]byte, []int)
  • func (x *Record) GetCrc() uint32
  • func (x *Record) GetData() []byte
  • func (x *Record) GetType() int64
  • func (*Record) ProtoMessage()
  • func (x *Record) ProtoReflect() protoreflect.Message
  • func (x *Record) Reset()
  • func (x *Record) String() string
  • func (rec *Record) Validate(crc uint32) error
• type Snapshot
  • func (s *Snapshot) Clone() *Snapshot
  • func (*Snapshot) Descriptor() ([]byte, []int)
  • func (x *Snapshot) GetConfState() *raftpb.ConfState
  • func (x *Snapshot) GetIndex() uint64
  • func (x *Snapshot) GetTerm() uint64
  • func (*Snapshot) ProtoMessage()
  • func (x *Snapshot) ProtoReflect() protoreflect.Message
  • func (x *Snapshot) Reset()
  • func (x *Snapshot) String() string

Variables

var ErrCRCMismatch = errors.New("walpb: crc mismatch")

var File_record_proto protoreflect.FileDescriptor

Functions

func ValidateSnapshotForWrite

func ValidateSnapshotForWrite(e *Snapshot) error

ValidateSnapshotForWrite ensures the Snapshot the newly written snapshot is valid.

There might exist log-entries written by old etcd versions that does not conform to the requirements.

Types

type Record

type Record struct {
	Type *int64  `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
	Crc  *uint32 `protobuf:"varint,2,opt,name=crc" json:"crc,omitempty"`
	Data []byte  `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor

func (*Record) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCrc

func (x *Record) GetCrc() uint32

func (*Record) GetData

func (x *Record) GetData() []byte

func (*Record) GetType

func (x *Record) GetType() int64

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

func (*Record) Validate

func (rec *Record) Validate(crc uint32) error

type Snapshot

type Snapshot struct {
	Index *uint64 `protobuf:"varint,1,opt,name=index" json:"index,omitempty"`
	Term  *uint64 `protobuf:"varint,2,opt,name=term" json:"term,omitempty"`
	// Field populated since >=etcd-3.5.0.
	ConfState *raftpb.ConfState `protobuf:"bytes,3,opt,name=conf_state,json=confState" json:"conf_state,omitempty"`
	// contains filtered or unexported fields
}

Keep in sync with raftpb.SnapshotMetadata.

func (*Snapshot) Clone

func (s *Snapshot) Clone() *Snapshot

Clone returns a deep copy of s, or an empty Snapshot if s is nil.

func (*Snapshot) Descriptor

func (*Snapshot) Descriptor() ([]byte, []int)

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetConfState

func (x *Snapshot) GetConfState() *raftpb.ConfState

func (*Snapshot) GetIndex

func (x *Snapshot) GetIndex() uint64

func (*Snapshot) GetTerm

func (x *Snapshot) GetTerm() uint64

func (*Snapshot) ProtoMessage

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect

func (x *Snapshot) ProtoReflect() protoreflect.Message

func (*Snapshot) Reset

func (x *Snapshot) Reset()

func (*Snapshot) String

func (x *Snapshot) String() string