wal

type Closer interface {
	Close() error
}

type Commit func() error

type EventHandler interface {
	Typ() string
	Check(context.Context, any) (need bool, err error)
	Encode(any) ([]byte, error)
	Decode([]byte) (any, error)
	Handle(context.Context, any) error
}

type Hydro struct {
	*haxmap.Map[string, EventHandler]
	// contains filtered or unexported fields
}

type HydroEvent struct {
	// A global unique identifier.
	ID uint64 `json:"ID"`

	// Registered event type name.
	Type string `json:"type"`

	// The encoded log item.
	Item []byte `json:"item"`
}

type Logger interface {
	Log(string, any) (Commit, error)
}

type Recoverer interface {
	Recover(context.Context)
}

type Registry interface {
	Register(EventHandler)
}

type WAL interface {
	Registry
	Recoverer
	Logger
	Closer
}