wal

package

v0.0.0-...-303e327 Latest Latest Go to latest Published: May 22, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	EntryType recordType = iota + 1
	IndexType
	FooterType
)

View Source

const (
	TrashPath = ".trash"
)

This section is empty.

func InitPath(dir string) error

func IsLogError(err error) bool

func NewLogError(filename string, offset int64, reason string) *logError

NewCorruptError new

type Entry struct {
	pb.Entry
}

func (entry *Entry) Decode(data []byte) error

func (entry *Entry) Encode(w io.Writer) (err error)

func (entry *Entry) Size() uint64

type RecordReadAt interface {
	ReadAt(offset int64) (rec record, err error)
}

type Recorder interface {
	Encode(w io.Writer) error
	Size() uint64
}

type Snapshot struct {
	Index uint64
	Term  uint64
}

func NewMeta(dir string) (mt *meta, st Snapshot, hs pb.HardState, err error)

type Wal struct {
	// contains filtered or unexported fields
}

Storage the storage

func OpenWal(dir string, sync bool) (*Wal, error)

OpenWal

func (w *Wal) ApplySnapshot(st Snapshot) error

func (w *Wal) Close()

func (w *Wal) Entries(lo, hi uint64, maxSize uint64) (entries []pb.Entry, err error)

func (w *Wal) FirstIndex() uint64

func (w *Wal) InitialState() pb.HardState

func (w *Wal) LastIndex() uint64

func (w *Wal) SaveEntries(entries []pb.Entry) error

func (w *Wal) SaveHardState(hs pb.HardState) error

func (w *Wal) Sync() error

func (w *Wal) Term(index uint64) (term uint64, err error)

func (w *Wal) Truncate(index uint64) error