libkvstore

type Config struct {
	Addr     string
	Password string
}

type KVExecutor interface {
	// Basic operations
	Get(ctx context.Context, key Key) (json.RawMessage, error)
	Set(ctx context.Context, key Key, value json.RawMessage) error
	SetWithTTL(ctx context.Context, key Key, value json.RawMessage, ttl time.Duration) error
	Delete(ctx context.Context, key Key) error
	Exists(ctx context.Context, key Key) (bool, error)
	Keys(ctx context.Context, pattern string) ([]Key, error)

	// List operations
	ListPush(ctx context.Context, key Key, value json.RawMessage) error
	ListRange(ctx context.Context, key Key, start, stop int64) ([]json.RawMessage, error)
	ListTrim(ctx context.Context, key Key, start, stop int64) error
	ListLength(ctx context.Context, key Key) (int64, error)
	ListRPop(ctx context.Context, key Key) (json.RawMessage, error)

	// Set operations
	SetAdd(ctx context.Context, key Key, member json.RawMessage) error
	SetMembers(ctx context.Context, key Key) ([]json.RawMessage, error)
	SetRemove(ctx context.Context, key Key, member json.RawMessage) error
}

type KVManager interface {
	// Executor returns a non-transactional executor
	Executor(ctx context.Context) (KVExecutor, error)
	Close() error
}

type Key = string

type KeyValue struct {
	Key   string
	Value json.RawMessage
	TTL   time.Time
}

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

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