models

Documentation

Index

• Variables
• type Job
  • func NewJob(lock lockmodels.Lock, action JobAction, errHandler JobErrorHandler) (job Job, err error)
  • func NewJobEx(lock lockmodels.Lock, action JobAction, peekTimeoutSec int, errTimeoutSec int, ...) (job Job, err error)
  • func NewJobExPnc(lock lockmodels.Lock, action JobAction, peekTimeoutSec int, errTimeoutSec int, ...) (job Job)
  • func NewJobPnc(lock lockmodels.Lock, action JobAction, errHandler JobErrorHandler) (job Job)
  • func (j Job) Validate() (err error)
• type JobAction
• type JobErrorHandler

Variables

var DefaultErrTimeoutSec = 10

Default time period after error occurs

var DefaultPeekTimeoutSec = 10

Default spap in retry cycle (in addition to duration of job lock)

Types

type Job

type Job struct {
	Lock lockmodels.Lock

	// Job action
	Action JobAction

	// Span in retry cycle (in addition to duration of job lock)
	PeekTimeoutSec int
	// Time period after error occurs
	ErrTimeoutSec int

	// Error handler
	ErrHandler JobErrorHandler
}

func NewJob

func NewJob(
	lock lockmodels.Lock,
	action JobAction,
	errHandler JobErrorHandler,
) (job Job, err error)

func NewJobEx

func NewJobEx(
	lock lockmodels.Lock,
	action JobAction,
	peekTimeoutSec int,
	errTimeoutSec int,
	errHandler JobErrorHandler,
) (job Job, err error)

func NewJobExPnc

func NewJobExPnc(
	lock lockmodels.Lock,
	action JobAction,
	peekTimeoutSec int,
	errTimeoutSec int,
	errHandler JobErrorHandler,
) (job Job)

func NewJobPnc

func NewJobPnc(
	lock lockmodels.Lock,
	action JobAction,
	errHandler JobErrorHandler,
) (job Job)

func (Job) Validate

func (j Job) Validate() (err error)

type JobAction

type JobAction func(context.Context, Job) error

type JobErrorHandler

type JobErrorHandler func(context.Context, Job, error)