job

Documentation

Index

• type EnvVar
  • func (e EnvVar) String() string
• type Environment
  • func (e Environment) Stringify() []string
• type Job
  • func (j Job) CurrentStep() *JobStep
  • func (j Job) CurrentStepEnvironment() Environment
• type JobLog
• type JobManager
  • func NewJobManager(r JobRepository, e JobStepExecutor) JobManager
• type JobRepository
  • func NewJobRepository(host string) JobRepository
• type JobStep
  • func (js JobStep) FilePipePath() string
  • func (js JobStep) UsesDelimitedOutput() bool
  • func (js JobStep) UsesFilePipe() bool
  • func (js JobStep) UsesStdErrPipe() bool
  • func (js JobStep) UsesStdOutPipe() bool
• type JobStepExecutor
  • func NewExecutor(dockerEndpoint string) JobStepExecutor
• type NotFoundError
  • func (s NotFoundError) Error() string

Types

type EnvVar

type EnvVar struct {
	Variable string `json:"variable"`
	Value    string `json:"value"`
}

func (EnvVar) String

func (e EnvVar) String() string

type Environment

type Environment []EnvVar

func (Environment) Stringify

func (e Environment) Stringify() []string

type Job

type Job struct {
	ID             string      `json:"id,omitempty"`
	Name           string      `json:"name,omitempty"`
	Steps          []JobStep   `json:"steps,omitempty"`
	Environment    Environment `json:"environment,omitempty"`
	StepsCompleted int         `json:"stepsCompleted,omitempty"`
	Status         string      `json:"status,omitempty"`
}

func (Job) CurrentStep

func (j Job) CurrentStep() *JobStep

func (Job) CurrentStepEnvironment

func (j Job) CurrentStepEnvironment() Environment

type JobLog

type JobLog struct {
	Index int      `json:"index,omitempty"`
	Lines []string `json:"lines"`
}

type JobManager

type JobManager interface {
	ListAll() ([]Job, error)
	GetByID(string) (*Job, error)
	Create(*Job) error
	Execute(*Job) error
	GetLog(*Job, int) (*JobLog, error)
	Delete(*Job) error
}

func NewJobManager

func NewJobManager(r JobRepository, e JobStepExecutor) JobManager

type JobRepository

type JobRepository interface {
	All() ([]Job, error)
	Get(jobID string) (*Job, error)
	Create(job *Job) error
	Delete(jobID string) error
	Update(jobID, attr, value string) error
	GetJobLog(jobID string, index int) (*JobLog, error)
	AppendLogLine(jobID, logLine string) error
}

func NewJobRepository

func NewJobRepository(host string) JobRepository

type JobStep

type JobStep struct {
	Name           string      `json:"name,omitempty"`
	Source         string      `json:"source,omitempty"`
	Environment    Environment `json:"environment,omitempty"`
	Output         string      `json:"output,omitempty"`
	BeginDelimiter string      `json:"beginDelimiter,omitempty"`
	EndDelimiter   string      `json:"endDelimiter,omitempty"`
	Refresh        bool        `json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func (JobStep) FilePipePath

func (js JobStep) FilePipePath() string

func (JobStep) UsesDelimitedOutput

func (js JobStep) UsesDelimitedOutput() bool

func (JobStep) UsesFilePipe

func (js JobStep) UsesFilePipe() bool

func (JobStep) UsesStdErrPipe

func (js JobStep) UsesStdErrPipe() bool

func (JobStep) UsesStdOutPipe

func (js JobStep) UsesStdOutPipe() bool

type JobStepExecutor

type JobStepExecutor interface {
	Start(js *Job, stdIn io.Reader, stdOut, stdErr io.WriteCloser) error
	Inspect(js *Job) error
	CleanUp(js *Job) error
}

func NewExecutor

func NewExecutor(dockerEndpoint string) JobStepExecutor

type NotFoundError

type NotFoundError string

func (NotFoundError) Error

func (s NotFoundError) Error() string