runtime_cron

Documentation

Index

• Variables
• func WithCronJob[OK any, OV any, T any](schedule string, scheduler task.Scheduler[OK, OV, 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[OK, OV, T]) Run()

Variables

var NewCron = runtime.ConstructorFor[*Cron, runtime.Runtime](
	func() *Cron {
		return &Cron{
			cron: cron.New(
				cron.WithLocation(time.UTC),
				cron.WithSeconds(),
			),
		}
	},
	func(hr *Cron) runtime.Runtime {
		return hr
	},
)

constructor

Functions

func WithCronJob

func WithCronJob[OK any, OV any, T any](
	schedule string,
	scheduler task.Scheduler[OK, OV, 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[OK any, OV any, T any] struct {
	// contains filtered or unexported fields
}

func (*Job[OK, OV, T]) Run

func (j *Job[OK, OV, T]) Run()