Documentation
¶
Index ¶
- type JobService
- func (s *JobService) CreateJob(cfg job.Config, onStopCb job.StopCb) (job.Job, error)
- func (s *JobService) DeleteJob(jobID string) error
- func (s *JobService) GetJobLogs(jobID string, stdout, stderr io.Writer) error
- func (s *JobService) Init(cfg job.ServiceConfig) error
- func (s *JobService) Shutdown() error
- type JobServiceConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobService ¶
type JobService struct {
// contains filtered or unexported fields
}
func NewJobService ¶
func NewJobService(log mlog.LoggerIFace, cfg JobServiceConfig) (*JobService, error)
func (*JobService) DeleteJob ¶
func (s *JobService) DeleteJob(jobID string) error
func (*JobService) GetJobLogs ¶
func (s *JobService) GetJobLogs(jobID string, stdout, stderr io.Writer) error
func (*JobService) Init ¶
func (s *JobService) Init(cfg job.ServiceConfig) error
func (*JobService) Shutdown ¶
func (s *JobService) Shutdown() error
type JobServiceConfig ¶
type JobServiceConfig struct {
MaxConcurrentJobs int
FailedJobsRetentionTime time.Duration
ImageRegistry string
}
func (JobServiceConfig) IsValid ¶ added in v0.6.0
func (c JobServiceConfig) IsValid() error
Source Files
Click to show internal directories.
Click to hide internal directories.