storage

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

type CachedKVConfig struct {
	// MaxCacheBytes is the maximum size of the cache in bytes.
	MaxCacheBytes int64
	// TTL is the time-to-live for cached entries.
	TTL time.Duration
	// SkipWriteIfCachedValueMatches skips writing to underlying storage if cached value equals new value.
	// This is disabled by default to maintain strong consistency.
	// Enable only if you control all writes and accept eventual consistency risks.
	SkipWriteIfCachedValueMatches bool
}

type CachedKVConfigFunc func(config *CachedKVConfig)

type InMemoryKV struct {
	KV map[string][]byte
	// contains filtered or unexported fields
}

type InMemorySet struct {
	HM map[string]map[string]struct{}
	// contains filtered or unexported fields
}

type KV interface {
	Get(key []byte) ([]byte, error)
	Set(key []byte, value []byte, opts ...SetOptionsFunc) ([]byte, error)
	Delete(key []byte) error
}

type KeysOptions struct {
	MaxKeys uint32
}

type KeysOptionsFunc func(opts *KeysOptions)

type Set interface {
	Add(key []byte, value []byte) error
	Delete(key []byte, value []byte) error
	All(key []byte) ([][]byte, error)
	Drop(key []byte) error
}

type SetOptions struct {
	SkipIfKeyAlreadyExists bool
	ReturnPreviousValue    bool
}

type SetOptionsFunc func(opts *SetOptions)