runtime_cron

Documentation

Index

• func NewCron(configurations ...runtime.Configuration[*Cron]) runtime.Runtime
• func WithCronJob[T any](schedule string, scheduler task.Scheduler[T], channel task.Channel[T]) runtime.Configuration[*Cron]
• func WithTaskProducer(taskProducer task.Producer) runtime.Configuration[*Cron]
• type Cron
  • func (c *Cron) Start() error
  • func (c *Cron) Stop()
• type Job
  • func (j *Job[T]) Run()

Functions

func NewCron

func NewCron(configurations ...runtime.Configuration[*Cron]) runtime.Runtime

constructor

func WithCronJob

func WithCronJob[T any](
	schedule string,
	scheduler task.Scheduler[T],
	channel task.Channel[T],
) runtime.Configuration[*Cron]

func WithTaskProducer

func WithTaskProducer(taskProducer task.Producer) runtime.Configuration[*Cron]

Types

type Cron

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

implementation

func (*Cron) Start

func (c *Cron) Start() error

func (*Cron) Stop

func (c *Cron) Stop()

type Job

type Job[T any] struct {
	// contains filtered or unexported fields
}

func (*Job[T]) Run

func (j *Job[T]) Run()