redis

Oct 12, 2025

Changes in this version

type RedisQueueService

+ func (r *RedisQueueService) Close() error

Jul 20, 2025

Changes in this version

+ type RedisQueueService struct

+ func GetRedisQueueDriver(cfg *models.Config) (*RedisQueueService, error)

+ func (r *RedisQueueService) Publish(ctx context.Context, chanel string, data interface{}) error

+ func (r *RedisQueueService) Subscribe(ctx context.Context, chanel string) *redis.PubSub

+ func (s *RedisQueueService) AddSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)

+ func (s *RedisQueueService) GetSubscriber(ctx context.Context, userID string) (*models.Subscriber, error)

+ func (s *RedisQueueService) RemoveSubscriber(ctx context.Context, userID string) error