cron

Documentation

Index

• Variables
• func AddJobConfig(job utils.CRONConfig)
• func CancelJob(scheduler string, jobName string) error
• func DeleteJobRoute(w http.ResponseWriter, req *http.Request)
• func DeregisterJob(scheduler string, name string)
• func GetJobRoute(w http.ResponseWriter, req *http.Request)
• func GetJobsList() map[string]map[string]ConfigJob
• func GetRunningJobsRoute(w http.ResponseWriter, req *http.Request)
• func Init()
• func InitJobs()
• func InitScheduler()
• func JobFromCommand(command string, args ...string) ...
• func JobFromCommandWithEnv(env []string, command string, args ...string) ...
• func JobFromContainerCommand(containerID string, command string, args ...string) ...
• func ListJobs(w http.ResponseWriter, req *http.Request)
• func ManualRunJob(scheduler string, name string) error
• func RegisterJob(job ConfigJob)
• func RemoveJobConfig(name string)
• func ResetScheduler(scheduler string)
• func RunJobRoute(w http.ResponseWriter, req *http.Request)
• func RunOneTimeJob(job ConfigJob)
• func RunningJobs() []string
• func StopJobRoute(w http.ResponseWriter, req *http.Request)
• func WaitForAllJobs()
• type ConfigJob
• type ExecuterFn
• type JobRequestJSON
• type ProcessTracker
  • func NewProcessTracker() *ProcessTracker
  • func (pt *ProcessTracker) EndProcess()
  • func (pt *ProcessTracker) StartProcess()
  • func (pt *ProcessTracker) WaitForZero()

Variables

var CRONLock = make(chan bool, 1)

var InternalProcessTracker = NewProcessTracker()

var RunningLock = make(chan bool, 1)

Functions

func AddJobConfig

func AddJobConfig(job utils.CRONConfig)

func CancelJob

func CancelJob(scheduler string, jobName string) error

func DeleteJobRoute

func DeleteJobRoute(w http.ResponseWriter, req *http.Request)

func DeregisterJob

func DeregisterJob(scheduler string, name string)

func GetJobRoute

func GetJobRoute(w http.ResponseWriter, req *http.Request)

func GetJobsList

func GetJobsList() map[string]map[string]ConfigJob

func GetRunningJobsRoute

func GetRunningJobsRoute(w http.ResponseWriter, req *http.Request)

func Init

func Init()

func InitJobs

func InitJobs()

func InitScheduler

func InitScheduler()

func JobFromCommand

func JobFromCommand(command string, args ...string) func(OnLog func(string), OnFail func(error), OnSuccess func(), ctx context.Context, cancel context.CancelFunc)

func JobFromCommandWithEnv

func JobFromCommandWithEnv(env []string, command string, args ...string) func(OnLog func(string), OnFail func(error), OnSuccess func(), ctx context.Context, cancel context.CancelFunc)

func JobFromContainerCommand

func JobFromContainerCommand(containerID string, command string, args ...string) func(OnLog func(string), OnFail func(error), OnSuccess func(), ctx context.Context, cancel context.CancelFunc)

func ListJobs

func ListJobs(w http.ResponseWriter, req *http.Request)

func ManualRunJob

func ManualRunJob(scheduler string, name string) error

func RegisterJob

func RegisterJob(job ConfigJob)

func RemoveJobConfig

func RemoveJobConfig(name string)

func ResetScheduler

func ResetScheduler(scheduler string)

func RunJobRoute

func RunJobRoute(w http.ResponseWriter, req *http.Request)

func RunOneTimeJob

func RunOneTimeJob(job ConfigJob)

func RunningJobs

func RunningJobs() []string

func StopJobRoute

func StopJobRoute(w http.ResponseWriter, req *http.Request)

func WaitForAllJobs

func WaitForAllJobs()

Types

type ConfigJob

type ConfigJob struct {
	Disabled       bool
	Scheduler      string
	Name           string
	Cancellable    bool
	Job            func(OnLog func(string), OnFail func(error), OnSuccess func(), ctx context.Context, cancel context.CancelFunc) `json:"-"`
	Crontab        string
	Running        bool
	LastStarted    time.Time
	LastRun        time.Time
	LastRunSuccess bool
	Logs           []string
	Ctx            context.Context    `json:"-"`
	CancelFunc     context.CancelFunc `json:"-"`
	Container      string
	Timeout        time.Duration
	MaxLogs        int
	Resource       string
}

type ExecuterFn

type ExecuterFn func(OnLog func(string), OnFail func(error), OnSuccess func(), ctx context.Context, cancel context.CancelFunc)

type JobRequestJSON

type JobRequestJSON struct {
	Scheduler string `validate:"required,min=3,max=32,alphanum"`
	Name      string `validate:"required,min=3,max=32,alphanum"`
}

type ProcessTracker

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

func NewProcessTracker

func NewProcessTracker() *ProcessTracker

func (*ProcessTracker) EndProcess

func (pt *ProcessTracker) EndProcess()

func (*ProcessTracker) StartProcess

func (pt *ProcessTracker) StartProcess()

func (*ProcessTracker) WaitForZero

func (pt *ProcessTracker) WaitForZero()