backends

Documentation

Index

• type RedisBackend
  • func (b *RedisBackend) Get(id string) ([]byte, error)
  • func (b *RedisBackend) Set(id string, result []byte) error

Types

type RedisBackend

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

RedisBackend implements CeleryBackend interface for Redis

func (*RedisBackend) Get

func (b *RedisBackend) Get(id string) ([]byte, error)

Get calls API to get asynchronous result "GET" "celery-task-meta-bbe9bb43-6e6b-4d7e-90f4-b3af5e3eef2f"

func (*RedisBackend) Set

func (b *RedisBackend) Set(id string, result []byte) error

Set pushes result back into backend