wal

type Config struct {
	Enabled      bool          `mapstructure:"enabled"       yaml:"enabled"`
	Path         string        `mapstructure:"path"          yaml:"path"`
	SyncInterval time.Duration `mapstructure:"sync_interval" yaml:"sync_interval"` // How often to fsync WAL to disk
}

type Entry struct {
	ID        uint64    `json:"id"`
	Slot      uint64    `json:"slot"`
	Type      EntryType `json:"type"`
	Data      []byte    `json:"data"`
	Timestamp time.Time `json:"timestamp"`
	Checksum  []byte    `json:"checksum"`
}

type EntryType string

type Manager interface {
	WriteEntry(ctx context.Context, entry *Entry) error
	ReadEntries(ctx context.Context, checkpoint uint64) ([]*Entry, error)
	Checkpoint(ctx context.Context, slot uint64) error
	Truncate(ctx context.Context, beforeSlot uint64) error
	Close() error
}