wal

package

v0.1.1 Latest Latest Go to latest Published: Nov 19, 2023 License: MIT Imports: 6 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

Repository

github.com/Kurt212/zapp

Links

Open Source Insights

Documentation ¶

Index ¶

func AppendAction(file io.Writer, action Action) error
func CreateWalAndReturnNotAppliedActions(file *os.File, lastAppliedLSN uint64) (*W, []Action, error)
type Action
type ActionType
type W

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AppendAction ¶

func AppendAction(file io.Writer, action Action) error

func CreateWalAndReturnNotAppliedActions ¶

func CreateWalAndReturnNotAppliedActions(file *os.File, lastAppliedLSN uint64) (*W, []Action, error)

Types ¶

type Action ¶

type Action struct {
	Type   ActionType
	LSN    uint64
	Key    []byte
	Value  []byte // optional
	Expire uint32 // optional. 0 is default and means no expire time
}

type ActionType ¶

type ActionType byte

const (
	ActionTypeUnknown ActionType = iota
	ActionTypeSet
	ActionTypeDel
)

type W ¶

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

func (*W) AppendDel ¶

func (w *W) AppendDel(key []byte) (uint64, error)

func (*W) AppendSet ¶

func (w *W) AppendSet(key []byte, value []byte, expire uint32) (uint64, error)

func (*W) Checkpoint ¶

func (w *W) Checkpoint() error

Checkpoint for now checkpointing WAL means it's safe to delete all entries from the file Checkpoint mush be called only after the segment's file is persisted to the disk fully Otherwise some data changes can be lost in case of software or hardware faults

func (*W) LastLSN ¶

func (w *W) LastLSN() uint64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL