dummybackend

Documentation

Index

• type Backend
  • func New() *Backend
  • func (b *Backend) ArchivedTasks(_ context.Context, queueID string) ([]async.TaskRef, error)
  • func (b *Backend) CancelTask(_ context.Context, queueID string, refID string) error
  • func (b *Backend) CheckTask(_ context.Context, queueID string, refID string) (async.Status, error)
  • func (b *Backend) CompletedTasks(_ context.Context, queueID string) ([]async.TaskRef, error)
  • func (b *Backend) CreateQueue(_ context.Context, name string) error
  • func (b *Backend) EnqueueTask(_ context.Context, e async.TaskEnvelope) error
  • func (b *Backend) ListQueues(_ context.Context) ([]string, error)
  • func (b *Backend) PendingTasks(_ context.Context, queueID string) ([]async.TaskRef, error)
  • func (b *Backend) SubscribeQueue(_ context.Context, queueID string) (<-chan async.TaskEnvelope, error)

Types

type Backend

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

func New

func New() *Backend

func (*Backend) ArchivedTasks

func (b *Backend) ArchivedTasks(_ context.Context, queueID string) ([]async.TaskRef, error)

func (*Backend) CancelTask

func (b *Backend) CancelTask(_ context.Context, queueID string, refID string) error

func (*Backend) CheckTask

func (b *Backend) CheckTask(_ context.Context, queueID string, refID string) (async.Status, error)

func (*Backend) CompletedTasks

func (b *Backend) CompletedTasks(_ context.Context, queueID string) ([]async.TaskRef, error)

func (*Backend) CreateQueue

func (b *Backend) CreateQueue(_ context.Context, name string) error

func (*Backend) EnqueueTask

func (b *Backend) EnqueueTask(_ context.Context, e async.TaskEnvelope) error

func (*Backend) ListQueues

func (b *Backend) ListQueues(_ context.Context) ([]string, error)

func (*Backend) PendingTasks

func (b *Backend) PendingTasks(_ context.Context, queueID string) ([]async.TaskRef, error)

func (*Backend) SubscribeQueue

func (b *Backend) SubscribeQueue(_ context.Context, queueID string) (<-chan async.TaskEnvelope, error)