Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronController ¶
type CronController struct {
// contains filtered or unexported fields
}
func NewController ¶
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()
Source Files
Click to show internal directories.
Click to hide internal directories.