redisx

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
}

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 Repository[T any] struct {
	// contains filtered or unexported fields
}