asynchook

Overview ¶

usage:

import (

"log/slog"

"github.com/unkn0wn-root/cascache/v3"
"github.com/unkn0wn-root/cascache/v3/codec"
"github.com/unkn0wn-root/cascache/v3/hooks/async"
"github.com/unkn0wn-root/cascache/v3/hooks/slog"
cascacheredis "github.com/unkn0wn-root/cascache/v3/redis"

)

raw := sloghook.New(slog.Default(), sloghook.Options{
    SelfHealEvery:   10, // sample logs: ~every 10th self-heal
    BatchRejectEvery: 1,  // log every batch rejection
})

hooks := asynchook.New(raw, 1, 1000) // 1 worker; queue 1000 events defer hooks.Close()

sharedVersionStore, _ := cascacheredis.NewVersionStore(rdb)

cache, _ := cascache.New[User](cascache.Options[User]{
    Namespace: "app:prod:user",
    Provider:  provider,
    Codec:     codec.JSON[User]{},
    VersionStore:  sharedVersionStore,
    Hooks:     hooks, // or `raw` if you don’t want async
})