cache

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

type ClientOption func(*Client)

type Codec interface {
	Marshal(v any) ([]byte, error)
	Unmarshal(data []byte, dst any) error
}

type GetOrLoadPolicy[T any] struct {
	TTL       time.Duration
	Tags      []string
	Cacheable func(v T) bool
}

type ICache interface {
	scene.Named
	Get(ctx context.Context, key string) (value []byte, hit bool, err error)
	Set(ctx context.Context, key string, value []byte, expiration time.Duration, tags ...string) error
	Delete(ctx context.Context, keys ...string) error
	InvalidateTags(ctx context.Context, tags ...string) error
}

type JSONCodec struct{}

type Loader[T any] func(ctx context.Context) (T, error)

type Metrics interface {
	RecordGet(hit bool, d time.Duration, err error)
	RecordLoad(d time.Duration, err error)
	RecordSet(d time.Duration, err error)
	RecordDelete(d time.Duration, err error)
	RecordDecodeError(err error)
}

type NopMetrics struct{}