jobhub

package module
v0.0.0-...-d5d3fc2 Latest Latest
Warning

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

Go to latest
Published: Aug 28, 2017 License: MIT Imports: 5 Imported by: 0

README

jobhub

A simple framework for scheduling jobs (processes) to be executed in a chain with status check and email notification.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExecutionStatus

type ExecutionStatus struct {
	ExecutionStart time.Time
	Code           StatusCode
	Runtime        time.Duration
}

type Job

type Job struct {
	Name    string
	Path    string
	Args    []string
	Retry   int
	Backoff backoff.BackOff
	// contains filtered or unexported fields
}

type JobStatus

type JobStatus struct {
	Job        Job
	JobID      int
	LastStatus ExecutionStatus
	Statuses   []ExecutionStatus
}

func (JobStatus) LastExecutionStatus

func (j JobStatus) LastExecutionStatus() *ExecutionStatus

type Pipeline

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

func NewPipeline

func NewPipeline(name string) *Pipeline

func (*Pipeline) AddJob

func (p *Pipeline) AddJob(job Job) (Job, error)

func (*Pipeline) AddJobDependency

func (p *Pipeline) AddJobDependency(job Job, deps ...Job) error

func (Pipeline) Run

func (p Pipeline) Run() (PipelineStatus, error)

type PipelineStatus

type PipelineStatus struct {
	PipelineName string
	Status       ExecutionStatus
	JobStatus    []JobStatus
}

type StatusCode

type StatusCode int
const (
	Created   StatusCode = 0
	Scheduled StatusCode = 1
	Failed    StatusCode = 2
	Succeeded StatusCode = 3
)

func (StatusCode) String

func (s StatusCode) String() string

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

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