pbscheduler

Documentation

Index

• Constants
• func EmergencyProbeName(userID interface{}) string
• type ProbeScheduler
  • func NewProbeScheduler(workerPoolAdapter *work.WorkerPoolAdapter, msgClient *twilio.ClientWrapper, ...) (*ProbeScheduler, error)
  • func (pbs ProbeScheduler) DisablePeriodicProbe(user *models.User) error
  • func (pbs ProbeScheduler) PeriodicallyPerfomProbe(user models.User) error
  • func (pScheduler ProbeScheduler) ScheduleProbes()

Constants

const (
	SEND_LIVELINESS_PROBE_HANDLER   = "send_liveliness_probe"
	SEND_FOLLOWUP_PROBE_HANDLER     = "send_followup_probe"
	SEND_EMERGENCY_PROBE_HANDLER    = "send_emergency_probe"
	ENQUEUE_FOLLOWUP_PROBES_HANDLER = "enqueue_followup_probes"
	SEND_DYNAMIC_PROBE_HANDLER      = "send_dynamic_probe"
)

Functions

func EmergencyProbeName

func EmergencyProbeName(userID interface{}) string

EmergencyProbeName returns the string used as tag for an emergency probe job name

Types

type ProbeScheduler

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

func NewProbeScheduler

func NewProbeScheduler(
	workerPoolAdapter *work.WorkerPoolAdapter,
	msgClient *twilio.ClientWrapper,
	followProbesCronSchedule string,
) (*ProbeScheduler, error)

NewProbeScheduler creates new probe scheduler

func (ProbeScheduler) DisablePeriodicProbe

func (pbs ProbeScheduler) DisablePeriodicProbe(user *models.User) error

DisablePeriodicProbe removes probe from scheduler & disables probe in user settings

func (ProbeScheduler) PeriodicallyPerfomProbe

func (pbs ProbeScheduler) PeriodicallyPerfomProbe(user models.User) error

PeriodicallyPerfomProbe creates 'liveliness probe' cron jobs for user. And when each cron is triggered, the job is sent to a job to be executed.

func (ProbeScheduler) ScheduleProbes

func (pScheduler ProbeScheduler) ScheduleProbes()

ScheduleProbes adds probes to cron scheduler, as well as check-ins for possible followup probes