Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

redis

package

Go to main page

Versions in this module

v0

v0.6.0

Jun 15, 2021

v0.5.0

May 31, 2021

Changes in this version

+ const HistoryLengthMax

v0.4.1

Nov 13, 2020

v0.4.0

Sep 29, 2020

v0.3.5

Sep 2, 2020

v0.3.4

Aug 14, 2020

Changes in this version

type Backend

+ func (b *Backend) GetProcessingTasks(ctx context.Context, queueName string) ([]*task.Task, error)

v0.3.3

Jul 15, 2020

v0.3.2

Jun 24, 2020

Changes in this version

+ const GlobalKeyPrefix

+ const KB

+ const MaxNameLength

+ const MessageMaxSizeInKB

+ const PayloadMaxSizeInKB

+ const RetryLimitMax

+ func NewBackend(logger zerolog.Logger, cfg config.Config) (iface.Backend, error)

+ type Backend struct

+ func (b *Backend) AddTask(ctx context.Context, queueName string, spec task.TaskSpec) (*task.Task, error)

+ func (b *Backend) CreateQueue(ctx context.Context, queueSpec taskqueue.TaskQueueSpec) (*taskqueue.TaskQueue, error)

+ func (b *Backend) DeleteQueue(ctx context.Context, queueName string) error

+ func (b *Backend) GetAllQueues(ctx context.Context) ([]*taskqueue.TaskQueue, error)

+ func (b *Backend) GetAllTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetAllWorkers(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) GetCompletedTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetDeadLetter(ctx context.Context, queueName string) ([]taskqueue.TaskToDeadletterError, error)

+ func (b *Backend) GetFailedTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetFailedWorkers(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) GetLostWorker(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) GetPendingTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetQueueByName(ctx context.Context, queueName string) (*taskqueue.TaskQueue, error)

+ func (b *Backend) GetReceivedTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetRunningWorkers(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) GetSucceededTasks(ctx context.Context, queueName string) ([]*task.Task, error)

+ func (b *Backend) GetSucceededWorkers(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) GetWorker(ctx context.Context, queueUID, workerUID uuid.UUID) (*apiworker.Worker, error)

+ func (b *Backend) GetWorkersToSalvage(ctx context.Context, queueUID uuid.UUID) ([]*apiworker.Worker, error)

+ func (b *Backend) NextTask(ctx context.Context, queueUID, workerUID uuid.UUID) (*task.Task, error)

+ func (b *Backend) RecordFailure(ctx context.Context, queueUID, workerUID uuid.UUID, t *task.Task, ...) error

+ func (b *Backend) RegisterWorker(ctx context.Context, queueUID uuid.UUID, workerSpec apiworker.WorkerSpec) (*apiworker.Worker, error)

+ func (b *Backend) SalvageWorker(ctx context.Context, ...) (*apiworker.Worker, []*task.Task, error)

+ func (b *Backend) SendWorkerHeartBeat(ctx context.Context, queueUID, workerUID uuid.UUID) (*apiworker.Worker, error)

+ func (b *Backend) SetProcessing(ctx context.Context, queueUID, workerUID uuid.UUID, t *task.Task) error

+ func (b *Backend) SetSucceeded(ctx context.Context, queueUID, workerUID uuid.UUID, t *task.Task, ...) error

+ func (b *Backend) SetWorkerFailed(ctx context.Context, queueUID, workerUID uuid.UUID) (*apiworker.Worker, error)

+ func (b *Backend) SetWorkerSucceeded(ctx context.Context, queueUID, workerUID uuid.UUID) (*apiworker.Worker, error)

+ func (b *Backend) UpdateQueue(ctx context.Context, queueSpec taskqueue.TaskQueueSpec) (*taskqueue.TaskQueue, error)