wrapper

Documentation

Index

• Variables
• func WithErrorResult(job func(context.Context) error, result func(error)) func(context.Context)
• func WithRetry(job func(context.Context) error, retries uint) func(context.Context)

Variables

var ErrNotRetryable = errors.New("not retryable")

Functions

func WithErrorResult

func WithErrorResult(job func(context.Context) error, result func(error)) func(context.Context)

WithErrorResult is a job wrapper that allows to receive the error result of the job.

For example it can be used to build logging or monitoring pipelines on the job.

func WithRetry

func WithRetry(job func(context.Context) error, retries uint) func(context.Context)

WithRetry is a job wrapper that allows to retry a job if it returns an error.

If you consider than the error is not retryable you can either return nil or the custom "ErrNotRetryable".