wal

type Commit ¶

type Commit func() error

Commit drops a logged event once its operation has succeeded.

type EventHandler ¶

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

type Hydro ¶

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

Hydro is the simplest wal implementation.

func NewHydro(path string, timeout time.Duration) (*Hydro, error)

func (h *Hydro) Close() error

func (h *Hydro) Log(eventyp string, item any) (Commit, error)

func (h *Hydro) Recover(ctx context.Context)

func (h *Hydro) Register(handler EventHandler)

type HydroEvent ¶

type HydroEvent struct {
	ID   uint64 `json:"ID"`
	Type string `json:"type"`
	Item []byte `json:"item"`
}

HydroEvent indicates a log event.

func NewHydroEvent(ID uint64, typ string, item []byte) *HydroEvent

func (e HydroEvent) Encode() ([]byte, error)

func (e HydroEvent) Key() []byte

type WAL ¶

type WAL interface {
	Register(EventHandler)
	Recover(context.Context)
	Log(string, any) (Commit, error)
	Close() error
}

WAL logs an event before its operation runs and replays the unfinished ones on recovery.