cdule

Documentation

Index

• Variables
• type AbstractJob
  • func NewJob(job Job, jobData map[string]string) *AbstractJob
  • func (j *AbstractJob) Build(cronExpression string) (*model.Job, error)
• type Cdule
  • func (cdule *Cdule) NewCdule(param ...string)
  • func (cdule *Cdule) NewCduleWithWorker(workerName string, param ...string)
  • func (cdule Cdule) StopWatcher()
• type Job
• type ScheduleWatcher
  • func (t *ScheduleWatcher) Run()
  • func (t *ScheduleWatcher) Stop()
• type WorkerJobCount
• type WorkerWatcher
  • func (t *WorkerWatcher) Run()
  • func (t *WorkerWatcher) Stop()

Variables

var JobRegistry = make(map[string]reflect.Type)

JobRegistry job registry

var ScheduleParser cron.Parser

ScheduleParser cron parser

var WorkerID string

WorkerID string

Types

type AbstractJob

type AbstractJob struct {
	Job     Job
	JobData map[string]string
}

AbstractJob for holding job and jobdata

func NewJob

func NewJob(job Job, jobData map[string]string) *AbstractJob

NewJob to create new abstract job

func (*AbstractJob) Build

func (j *AbstractJob) Build(cronExpression string) (*model.Job, error)

Build to build job and store in the database

type Cdule

type Cdule struct {
	*WorkerWatcher
	*ScheduleWatcher
}

Cdule holds watcher objects

func (*Cdule) NewCdule

func (cdule *Cdule) NewCdule(param ...string)

NewCdule to create new scheduler with default worker name as hostname

func (*Cdule) NewCduleWithWorker

func (cdule *Cdule) NewCduleWithWorker(workerName string, param ...string)

NewCduleWithWorker to create new scheduler with worker

func (Cdule) StopWatcher

func (cdule Cdule) StopWatcher()

StopWatcher to stop watchers

type Job

type Job interface {
	Execute(map[string]string)
	JobName() string
	GetJobData() map[string]string
}

Job interface

type ScheduleWatcher

type ScheduleWatcher struct {
	Closed chan struct{}
	WG     sync.WaitGroup
	Ticker *time.Ticker
}

ScheduleWatcher struct

func (*ScheduleWatcher) Run

func (t *ScheduleWatcher) Run()

Run to run watcher in a continuous loop

func (*ScheduleWatcher) Stop

func (t *ScheduleWatcher) Stop()

Stop to stop scheduler watcher

type WorkerJobCount

type WorkerJobCount struct {
	WorkerID string `json:"worker_id"`
	Count    int64  `json:"count"`
}

WorkerJobCount struct

type WorkerWatcher

type WorkerWatcher struct {
	Closed chan struct{}
	WG     sync.WaitGroup
	Ticker *time.Ticker
}

WorkerWatcher struct

func (*WorkerWatcher) Run

func (t *WorkerWatcher) Run()

Run to run watcher in a continuous loop

func (*WorkerWatcher) Stop

func (t *WorkerWatcher) Stop()

Stop to stop worker watcher