brokers

Documentation

Index

• type RedisBroker
  • func (b *RedisBroker) Get() ([]byte, error)
  • func (b *RedisBroker) Set(payload []byte) error

Types

type RedisBroker

type RedisBroker struct {
	Client    *redis.Client
	QueueName string
}

RedisBroker implements CeleryBroker interface for Redis connection should be handled by caller

func (*RedisBroker) Get

func (b *RedisBroker) Get() ([]byte, error)

Get - "BRPOP" "celery" "celery\x06\x163" "celery\x06\x166" "celery\x06\x169" "1"

func (*RedisBroker) Set

func (b *RedisBroker) Set(payload []byte) error

Set - "LPUSH" "celery" data