kron

package

v0.26.7 Latest Latest Go to latest Published: Jun 12, 2024 License: AGPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Job struct {
	MaxErrors int
	Handler   JobHandler
	Interval  time.Duration
	// contains filtered or unexported fields
}

func NewJob(interval time.Duration, handler JobHandler) *Job

func (j *Job) AddMiddleware(middleware MiddlewareFunc)

type JobHandler func(ctx context.Context) error

type MiddlewareFunc func(ctx context.Context) (context.Context, error)

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

func NewService() *Service

func (s *Service) AddJob(job *Job)

func (s *Service) Start(ctx context.Context) error

func (s *Service) Stop() error