asynchook

Overview ¶

usage:

import (

"log/slog"

"github.com/unkn0wn-root/cascache"
"github.com/unkn0wn-root/cascache/codec"
"github.com/unkn0wn-root/cascache/genstore"
"github.com/unkn0wn-root/cascache/hooks/async"
"github.com/unkn0wn-root/cascache/hooks/slog"

)

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

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

cache, _ := cascache.New[User](cascache.Options[User]{
    Namespace: "app:prod:user",
    Provider:  provider,
    Codec:     codec.JSON[User]{},
    GenStore:  genstore.NewRedisGenStoreWithTTL(rdb, "app:prod:user", 24*time.Hour),
    Hooks:     hooks, // or `raw` if you don’t want async
})