redisx

type Cache interface {
	Get(ctx context.Context, key string, value interface{}) error
	GetCache(ctx context.Context, key string, value interface{}, ttl *time.Duration, loadFunc func() (interface{}, error)) error
	Set(ctx context.Context, key string, cacheItem *Item) error
	Delete(ctx context.Context, key string) error
	Exists(ctx context.Context, key string) bool
	IsErrCacheMiss(err error) bool
	ListKeysByPrefix(ctx context.Context, prefix string) ([]string, error)
	DeleteByPrefix(ctx context.Context, prefix string) error
}

type Client interface {
	Publish(ctx context.Context, channel string, message interface{}) error
	Subscribe(ctx context.Context, channel string) *redis.PubSub
	PSubscribe(ctx context.Context, channel string) *redis.PubSub
	Get(ctx context.Context, key string) (string, error)
	Set(ctx context.Context, key, value string, expiration time.Duration) error
	SubscribeMessage(ctx context.Context, options *SubscribeMessageOptions) func()
	PSubscribeMessage(ctx context.Context, channel string, userIdPrefix string, onMessage func(id, message string)) func()
	Client() redis.UniversalClient
	Close() error
}

type DataSource interface {
	WithTTL(ttl time.Duration) DataSourceBuilder

	// Record CRUD (stored as JSON string)
	Create(ctx context.Context, key string, value any) error
	Update(ctx context.Context, key string, value any) error
	Delete(ctx context.Context, key string) error
	Get(ctx context.Context, key string, dest any) error

	// Index operations
	AddToIndex(ctx context.Context, indexKey, id string, score float64) error
	RemoveFromIndex(ctx context.Context, indexKey, id string) error
	GetAllFromIndex(ctx context.Context, indexKey string, start, stop int64) ([]string, error)

	// Atomic helpers (production-safe)
	UpsertWithIndex(ctx context.Context, key, indexKey, id string, score float64, value any, ttl time.Duration) error
	DeleteWithIndex(ctx context.Context, key, indexKey, id string) error

	// Bulk read
	GetAll(ctx context.Context, indexKey string, destSlice any) error

	// Pub/Sub
	Publish(ctx context.Context, channel string, message any) error
	Subscribe(ctx context.Context, channels ...string) *redis.PubSub
}

type DataSourceBuilder interface {
	Create(ctx context.Context, key string, value any) error
	Update(ctx context.Context, key string, value any) error
	AddToIndex(ctx context.Context, indexKey, id string, score float64) error
	UpsertWithIndex(ctx context.Context, key, indexKey, id string, score float64, value any) error
}

type Item struct {
	Value interface{}
	TTL   *time.Duration
}

type RedisOptions struct {
	ClusterMode bool
	Addr        string
	DB          int
	Username    string
	Password    string
	TraceEnable bool
}

type Repository[T any] struct {
	// contains filtered or unexported fields
}

type SubscribeMessageOptions struct {
	Channel     string
	OnMessage   func(message string)
	ChannelSize int
}