requeue

Documentation

Index

• type Ctx
  • func (c Ctx) Job() *client.Job
  • func (c Ctx) Manager() manager.Manager
  • func (c Ctx) Reservation() *manager.Reservation
• type RequeueSubsystem
  • func (r *RequeueSubsystem) Name() string
  • func (r *RequeueSubsystem) Reload(s *server.Server) error
  • func (r *RequeueSubsystem) Start(s *server.Server) error

Types

type Ctx

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

Ctx implements Faktory's `manager.Context`. Duplicated from https://github.com/contribsys/faktory/blob/v1.8.0/manager/middleware.go#L24-L40

func (Ctx) Job

func (c Ctx) Job() *client.Job

func (Ctx) Manager

func (c Ctx) Manager() manager.Manager

func (Ctx) Reservation

func (c Ctx) Reservation() *manager.Reservation

type RequeueSubsystem

type RequeueSubsystem struct{}

RequeueSubsystem allows a client to indicate that it is not able to complete the job and that it should be retried.

func (*RequeueSubsystem) Name

func (r *RequeueSubsystem) Name() string

Name returns the name of the plugin.

func (*RequeueSubsystem) Reload

func (r *RequeueSubsystem) Reload(s *server.Server) error

Reload does not do anything.

func (*RequeueSubsystem) Start

func (r *RequeueSubsystem) Start(s *server.Server) error

Start loads the plugin.