wal

type Entry struct {
	Op        OpType
	Entity    string // e.g. "processes", "executors"
	Key       string // primary key
	Data      []byte // JSON-encoded record (nil for deletes)
	Timestamp int64  // unix nanoseconds
}

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

type OpType uint8

type SyncMode int

type WAL interface {
	// Append writes an entry to the log. Depending on the SyncMode, the
	// entry may or may not be durable when Append returns.
	Append(entry Entry) error

	// Replay reads all entries from the log in order, calling fn for each.
	// If fn returns an error, replay stops and the error is returned.
	Replay(fn func(Entry) error) error

	// Truncate removes all entries from the log. Called after a successful
	// flush to disk.
	Truncate() error

	// Close flushes any buffered data and closes the log.
	Close() error
}