kubernetes/vendor/go.etcd.io/etcd/raft/v3/storage.go

var ErrCompacted …

var ErrSnapOutOfDate …

var ErrUnavailable …

var ErrSnapshotTemporarilyUnavailable …

type Storage …

type MemoryStorage …

// NewMemoryStorage creates an empty MemoryStorage.
func NewMemoryStorage() *MemoryStorage { … }

// InitialState implements the Storage interface.
func (ms *MemoryStorage) InitialState() (pb.HardState, pb.ConfState, error) { … }

// SetHardState saves the current HardState.
func (ms *MemoryStorage) SetHardState(st pb.HardState) error { … }

// Entries implements the Storage interface.
func (ms *MemoryStorage) Entries(lo, hi, maxSize uint64) ([]pb.Entry, error) { … }

// Term implements the Storage interface.
func (ms *MemoryStorage) Term(i uint64) (uint64, error) { … }

// LastIndex implements the Storage interface.
func (ms *MemoryStorage) LastIndex() (uint64, error) { … }

func (ms *MemoryStorage) lastIndex() uint64 { … }

// FirstIndex implements the Storage interface.
func (ms *MemoryStorage) FirstIndex() (uint64, error) { … }

func (ms *MemoryStorage) firstIndex() uint64 { … }

// Snapshot implements the Storage interface.
func (ms *MemoryStorage) Snapshot() (pb.Snapshot, error) { … }

// ApplySnapshot overwrites the contents of this Storage object with
// those of the given snapshot.
func (ms *MemoryStorage) ApplySnapshot(snap pb.Snapshot) error { … }

// CreateSnapshot makes a snapshot which can be retrieved with Snapshot() and
// can be used to reconstruct the state at that point.
// If any configuration changes have been made since the last compaction,
// the result of the last ApplyConfChange must be passed in.
func (ms *MemoryStorage) CreateSnapshot(i uint64, cs *pb.ConfState, data []byte) (pb.Snapshot, error) { … }

// Compact discards all log entries prior to compactIndex.
// It is the application's responsibility to not attempt to compact an index
// greater than raftLog.applied.
func (ms *MemoryStorage) Compact(compactIndex uint64) error { … }

// Append the new entries to storage.
// TODO (xiangli): ensure the entries are continuous and
// entries[0].Index > ms.entries[0].Index
func (ms *MemoryStorage) Append(entries []pb.Entry) error { … }