job

Documentation

Index

• Constants
• Variables
• func CreateTask(quit chan bool, context *JobContext) error
• func DeleteEnvironment(quit chan bool, context *JobContext) error
• func DeleteEnvironmentLoadBalancers(quit chan bool, context *JobContext) error
• func DeleteEnvironmentServices(quit chan bool, context *JobContext) error
• func DeleteEnvironmentTasks(quit chan bool, context *JobContext) error
• func DeleteLoadBalancer(quit chan bool, context *JobContext) error
• func DeleteService(quit chan bool, context *JobContext) error
• func DeleteTask(quit chan bool, context *JobContext) error
• type Action
  • func Fold(actions ...Action) Action
• type JobContext
  • func NewJobContext(jobID string, lgc *logic.Logic, request string) *JobContext
  • func (j *JobContext) AddJobMeta(key, val string) error
  • func (j *JobContext) CreateCopyWithNewRequest(request string) *JobContext
  • func (j *JobContext) Request() string
  • func (j *JobContext) SetJobMeta(meta map[string]string) error
• type JobRunner
  • func NewJobRunner(logic *logic.Logic, jobID string) *JobRunner
  • func (j *JobRunner) Load() error
  • func (j *JobRunner) MarkStatus(status types.JobStatus) error
  • func (j *JobRunner) Run() error
• type Step

Constants

const (
	JOB_LOAD_ATTEMPTS       = 10
	JOB_LOAD_SLEEP_INTERVAL = time.Second * 5
)

Variables

var CreateTaskSteps = []Step{
	{
		Name:    "Create Task",
		Timeout: time.Hour * 24,
		Action:  CreateTask,
	},
}

var DeleteEnvironmentSteps = []Step{
	{
		Name:    "Delete Dependencies",
		Timeout: time.Minute * 15,
		Action:  Fold(DeleteEnvironmentLoadBalancers, DeleteEnvironmentServices, DeleteEnvironmentTasks),
	},
	{
		Name:    "Delete Environment",
		Timeout: time.Minute * 10,
		Action:  DeleteEnvironment,
	},
}

var DeleteLoadBalancerSteps = []Step{
	{
		Name:    "Delete Load Balancer",
		Timeout: time.Minute * 10,
		Action:  DeleteLoadBalancer,
	},
}

var DeleteServiceSteps = []Step{
	{
		Name:    "Delete Service",
		Timeout: time.Minute * 10,
		Action:  DeleteService,
	},
}

var DeleteTaskSteps = []Step{
	{
		Name:    "Delete Task",
		Timeout: time.Minute * 10,
		Action:  DeleteTask,
	},
}

Functions

func CreateTask

func CreateTask(quit chan bool, context *JobContext) error

func DeleteEnvironment

func DeleteEnvironment(quit chan bool, context *JobContext) error

func DeleteEnvironmentLoadBalancers

func DeleteEnvironmentLoadBalancers(quit chan bool, context *JobContext) error

func DeleteEnvironmentServices

func DeleteEnvironmentServices(quit chan bool, context *JobContext) error

func DeleteEnvironmentTasks

func DeleteEnvironmentTasks(quit chan bool, context *JobContext) error

func DeleteLoadBalancer

func DeleteLoadBalancer(quit chan bool, context *JobContext) error

func DeleteService

func DeleteService(quit chan bool, context *JobContext) error

func DeleteTask

func DeleteTask(quit chan bool, context *JobContext) error

Types

type Action

type Action func(chan bool, *JobContext) error

func Fold

func Fold(actions ...Action) Action

Fold takes a slice of Actions and runs them async

type JobContext

type JobContext struct {
	Logic             *logic.Logic
	LoadBalancerLogic logic.LoadBalancerLogic
	ServiceLogic      logic.ServiceLogic
	TaskLogic         logic.TaskLogic
	EnvironmentLogic  logic.EnvironmentLogic
	// contains filtered or unexported fields
}

func NewJobContext

func NewJobContext(jobID string, lgc *logic.Logic, request string) *JobContext

func (*JobContext) AddJobMeta

func (j *JobContext) AddJobMeta(key, val string) error

func (*JobContext) CreateCopyWithNewRequest

func (j *JobContext) CreateCopyWithNewRequest(request string) *JobContext

func (*JobContext) Request

func (j *JobContext) Request() string

func (*JobContext) SetJobMeta

func (j *JobContext) SetJobMeta(meta map[string]string) error

type JobRunner

type JobRunner struct {
	Logic   *logic.Logic
	Context *JobContext
	Steps   []Step
	// contains filtered or unexported fields
}

func NewJobRunner

func NewJobRunner(logic *logic.Logic, jobID string) *JobRunner

func (*JobRunner) Load

func (j *JobRunner) Load() error

func (*JobRunner) MarkStatus

func (j *JobRunner) MarkStatus(status types.JobStatus) error

func (*JobRunner) Run

func (j *JobRunner) Run() error

type Step

type Step struct {
	Name    string
	Timeout time.Duration
	Action  Action
}