job

Documentation

Index

• func ListenAndHandleOnDemandJobs(apiClient api.Client, pub, sub *pubsub.RabbitMQ, queue, exchange string, ...)
• func ListenAndHandleScheduledJobs(apiClient api.Client, pub *pubsub.RabbitMQ, c *cron.Cron)
• func ListenAndHandleSchedules(apiClient api.Client, sub *pubsub.RabbitMQ, schedulesQueue, exchange string, ...)

Functions

func ListenAndHandleOnDemandJobs

func ListenAndHandleOnDemandJobs(apiClient api.Client, pub, sub *pubsub.RabbitMQ, queue, exchange string, done chan<- error)

ListenAndHandleOnDemandJobs handles on-demand jobs (jobs arriving via a VCS webhook or from the UI directly).

func ListenAndHandleScheduledJobs

func ListenAndHandleScheduledJobs(apiClient api.Client, pub *pubsub.RabbitMQ, c *cron.Cron)

ListenAndHandleScheduledJobs handles scheduled jobs (jobs starting from a cron job). It regularly polls for schedules to detect which ones have not yet been submitted and submits cron jobs for those schedules that have not yet been setup to run.

func ListenAndHandleSchedules

func ListenAndHandleSchedules(apiClient api.Client, sub *pubsub.RabbitMQ, schedulesQueue, exchange string, done chan<- error, c *cron.Cron)

ListenAndHandleSchedules handles changes to schedules arriving from job workers (via changes to .kenza.yml)