jobs

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2026 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type JobFn

type JobFn func(ctx context.Context) error

func KeyRotateJob

func KeyRotateJob() JobFn

func OutboxSendingJob

func OutboxSendingJob(dp *ioc.DependencyProvider) JobFn

type JobManager

type JobManager interface {
	QueueJob(JobFn, time.Duration, ...JobOption)
	Start(context.Context)
	Stop()
}

func NewJobManager

func NewJobManager(opts ...ManagerOption) JobManager

type JobOption

type JobOption func(*job)

func WithName

func WithName(name string) JobOption

func WithStartImmediate

func WithStartImmediate() JobOption

func WithTimeout

func WithTimeout(timeout time.Duration) JobOption

type ManagerOption

type ManagerOption func(*jobManager)

func WithOnError

func WithOnError(onError func(error)) ManagerOption

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL