subjectdelete

Documentation

Index

• func IsInvalidConfig(err error) bool
• func IsTimeout(err error) bool
• type Handler
  • func NewHandler(c HandlerConfig) (*Handler, error)
  • func (h *Handler) Ensure(tsk *task.Task) error
  • func (h *Handler) Filter(tsk *task.Task) bool
• type HandlerConfig

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

func IsTimeout

func IsTimeout(err error) bool

Types

type Handler

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

func NewHandler

func NewHandler(c HandlerConfig) (*Handler, error)

func (*Handler) Ensure

func (h *Handler) Ensure(tsk *task.Task) error

func (*Handler) Filter

func (h *Handler) Filter(tsk *task.Task) bool

type HandlerConfig

type HandlerConfig struct {
	Logger logger.Interface
	Redigo redigo.Interface
	Rescue rescue.Interface

	Timeout time.Duration
}