cachecore

type BaseConfig struct {
	DefaultTTL    time.Duration
	Prefix        string
	Compression   CompressionCodec
	MaxValueBytes int
	EncryptionKey []byte
}

type CacheEntry struct {
	Key       string
	SizeBytes int
	ExpiresAt *int64
}

type CompressionCodec string

type Driver string

type Inspector interface {
	Capabilities() InspectorCapabilities
	ListPage(ctx context.Context, opts ListPageOptions) (ListPageResult, error)
}

type InspectorCapabilities struct {
	CanList   bool
	CanRead   bool
	CanDelete bool
	CanTTL    bool
}

type ListPageOptions struct {
	// Query filters entries by matching any part of the cache key.
	// Prefix is retained as a backward-compatible alias.
	Query  string
	Prefix string
	Cursor string
	Limit  int
}

type ListPageResult struct {
	Entries    []CacheEntry
	NextCursor string
	HasMore    bool
}

type Store interface {
	Driver() Driver
	Ready(ctx context.Context) error
	Get(ctx context.Context, key string) ([]byte, bool, error)
	Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
	Add(ctx context.Context, key string, value []byte, ttl time.Duration) (bool, error)
	Increment(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
	Decrement(ctx context.Context, key string, delta int64, ttl time.Duration) (int64, error)
	Delete(ctx context.Context, key string) error
	DeleteMany(ctx context.Context, keys ...string) error
	Flush(ctx context.Context) error
}