scheduler

package
v0.0.0-...-bcb65b6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 18, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CronScheduler

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

CronScheduler Implementation for Scheduler interface contains the needed properties

func (*CronScheduler) Add

func (c *CronScheduler) Add(job *job.SchedulerJob) (jobID string, err error)

Add to register a job in the scheduler

func (*CronScheduler) Exists

func (c *CronScheduler) Exists(jobName string) bool

Exists to verify if the job already registered

type Scheduler

type Scheduler interface {
	Add(job *job.SchedulerJob) (jobID string, err error)
	Exists(jobName string) bool
}

Scheduler an interface for the scheduler operations

func New

func New(logger *zap.Logger, k8s k8s.K8S) Scheduler

New instance of Scheduler

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL