jobs

type Clusters struct {
	ClusterStore   blobstore.BlobStore
	Config         *viper.Viper
	DeployerClient *clients.DeployerClient

	MaxClusters int
	Deployments []*cluster
	// contains filtered or unexported fields
}

type DeploymentFiles interface {
	DownloadDeployment(fileName string) (*deployer.Deployment, error)
}

type FailedJobs struct {
	Jobs []Job
	// contains filtered or unexported fields
}

type Job interface {
	GetId() string
	GetApplicationConfig() *models.ApplicationConfig
	GetJobDeploymentConfig() JobDeploymentConfig
	GetLog() *log.FileLog
	Run(deploymentId string) error
	GetState() string
	SetState(state string)
	GetSummary() JobSummary
	SetFailed(error string)
	GetResults() <-chan *JobResults
	IsSkipUnreserveOnFailure() bool
	IsDirectJob() bool
}

type JobDeploymentConfig struct {
	Nodes []deployer.ClusterNode
}

type JobManager struct {
	Queue      chan Job
	Jobs       map[string]Job
	Workers    []*Worker
	FailedJobs *FailedJobs
	// contains filtered or unexported fields
}

type JobResults struct {
	Error string
	Data  interface{}
}

type JobSummary struct {
	DeploymentId string    `json:"deploymentId"`
	RunId        string    `json:"runId"`
	Status       string    `json:"status"`
	Create       time.Time `json:"create"`
}

type ReserveResult struct {
	DeploymentId string
	Err          string
}

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

type UnreserveResult struct {
	RunId string
	Err   string
}

type Worker struct {
	Id               int
	Jobs             <-chan Job
	FailedJobs       *FailedJobs
	RetryReservation bool
	Config           *viper.Viper
	Clusters         *Clusters
}