redis

Documentation

Index

• type RedisQueueService
  • func GetRedisQueueDriver(cfg *models.Config) (*RedisQueueService, error)
  • 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 (r *RedisQueueService) Publish(ctx context.Context, chanel string, data interface{}) error
  • func (s *RedisQueueService) RemoveSubscriber(ctx context.Context, userID string) error
  • func (r *RedisQueueService) Subscribe(ctx context.Context, chanel string) *redis.PubSub

Types

type RedisQueueService

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

func GetRedisQueueDriver

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

func (*RedisQueueService) AddSubscriber

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

func (*RedisQueueService) GetSubscriber

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

func (*RedisQueueService) Publish

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

func (*RedisQueueService) RemoveSubscriber

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

func (*RedisQueueService) Subscribe

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