Documentation
¶
Index ¶
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, _, stderr io.Writer) error
func (*JobService) Init ¶
func (s *JobService) Init(_ job.ServiceConfig) error
func (*JobService) Shutdown ¶
func (s *JobService) Shutdown() error
type JobServiceConfig ¶
type JobServiceConfig struct {
MaxConcurrentJobs int
FailedJobsRetentionTime time.Duration
ImageRegistry string
JobsResourceRequirements JobsResourceRequirements `toml:"jobs_resource_requirements"`
}
func (JobServiceConfig) IsValid ¶ added in v0.6.0
func (c JobServiceConfig) IsValid() error
type JobsResourceRequirements ¶ added in v0.6.0
type JobsResourceRequirements map[job.Type]corev1.ResourceRequirements
func (*JobsResourceRequirements) Decode ¶ added in v0.6.0
func (r *JobsResourceRequirements) Decode(data string) error
func (*JobsResourceRequirements) UnmarshalTOML ¶ added in v0.6.0
func (r *JobsResourceRequirements) UnmarshalTOML(data interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.