wal

package

v0.1.4 Latest Latest Go to latest Published: Dec 29, 2025 License: BSD-3-Clause Imports: 9 Imported by: 0

Details

View Source

const (
	WalFlags       = os.O_APPEND | os.O_CREATE | os.O_RDWR
	WalPermissions = 0666
)

View Source

var ErrInvalidCRC = errors.New("invalid CRC checksum")

View Source

var (
	ErrReadingRecord = errors.New("error reading record")
)

This section is empty.

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

func NewMemWAL(t *testing.T) *InMemWAL

func (wal *InMemWAL) Append(b []byte) error

func (wal *InMemWAL) ReadAll() ([][]byte, error)

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

func New(fileName string) (*WriteAheadLog, error)

New opens a write ahead log file, creating one if necessary. Call Close() on the WriteAheadLog to ensure the file is closed after use.

func (w *WriteAheadLog) Append(b []byte) error

Appends a record to the write ahead log Must flush the OS cache on every append to ensure consistency

func (w *WriteAheadLog) Close() error

func (w *WriteAheadLog) ReadAll() ([][]byte, error)

func (w *WriteAheadLog) Truncate() error

Truncate truncates the write ahead log