cron

package
v0.0.0-...-576d0f4 Latest Latest
Warning

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

Go to latest
Published: Sep 6, 2018 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var New = func(dockerHost string) (Croner, error) {
	service, err := docker.New(dockerHost)
	if err != nil {
		return &Cron{}, err
	}
	c := rcron.New()
	c.Start()
	return &Cron{Cron: c, Service: service, Jobs: map[string]rcron.EntryID{}}, nil
}

Functions

This section is empty.

Types

type Cron

type Cron struct {
	Cron    *rcron.Cron
	Service docker.Servicer
	Jobs    map[string]rcron.EntryID
}

func (*Cron) AddJob

func (c *Cron) AddJob(data JobData) error

func (*Cron) GetJobs

func (c *Cron) GetJobs() (map[string]JobData, error)

func (*Cron) RemoveJob

func (c *Cron) RemoveJob(jobName string) error

func (*Cron) RescheduleJobs

func (c *Cron) RescheduleJobs() error

func (*Cron) Stop

func (c *Cron) Stop()

type Croner

type Croner interface {
	AddJob(data JobData) error
	Stop()
	GetJobs() (map[string]JobData, error)
	RemoveJob(jobName string) error
	RescheduleJobs() error
}

type JobData

type JobData struct {
	Name        string   `json:"name"`
	ServiceName string   `json:"servicename"`
	Image       string   `json:"image"`
	Command     string   `json:"command"`
	Schedule    string   `json:"schedule"`
	Args        []string `json:"args"`
	Created     bool     `json:"created`
}

Jump to

Keyboard shortcuts

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