cron

Documentation

Index

• type CronController
  • func NewController(ctx context.Context, pu *processor.Unit, queue cronq.Queue) *CronController
  • func (cc *CronController) Start()
  • func (cc *CronController) Stop()

Types

type CronController

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

func NewController

func NewController(ctx context.Context, pu *processor.Unit, queue cronq.Queue) *CronController

NewController builds the cron controller around an opened cron Queue (the scheduler enqueues onto it; the worker drains it). Mirrors controlpublish.NewController(ctx, pu, sink).

func (*CronController) Start

func (cc *CronController) Start()

Start launches the worker (drains the queue, dispatches) and the scheduler (wall-clock-aligned ticks, enqueues per target). No-op when the cron personality is disabled or no queue is wired (data-plane-only chassis / tests).

func (*CronController) Stop

func (cc *CronController) Stop()