data

Documentation

Index

• func CheckAndRecover(path string, cfg *config.Config) error
• type Datafile
  • func NewDatafile(path string, id int, readonly bool, maxKeySize uint32, maxValueSize uint64, ...) (Datafile, error)

Functions

func CheckAndRecover

func CheckAndRecover(path string, cfg *config.Config) error

CheckAndRecover checks and recovers the last datafile. If the datafile isn't corrupted, this is a noop. If it is, the longest non-corrupted prefix will be kept and the rest will be *deleted*. Also, the index file is also *deleted* which will be automatically recreated on next startup.

Types

type Datafile

type Datafile interface {
	FileID() int
	Name() string
	Close() error
	Sync() error
	Size() int64
	Read() (internal.Entry, int64, error)
	ReadAt(index, size int64) (internal.Entry, error)
	Write(internal.Entry) (int64, int64, error)
}

Datafile is an interface that represents a readable and writeable datafile

func NewDatafile

func NewDatafile(path string, id int, readonly bool, maxKeySize uint32, maxValueSize uint64, fileMode os.FileMode) (Datafile, error)

NewDatafile opens an existing datafile