kubernetes

Dec 17, 2024

Changes in this version

type JobServiceConfig

+ NodeSysctls string

+ PersistentVolumeClaimName string

Jan 22, 2024

Changes in this version

type JobServiceConfig

+ ImageRegistry string

+ JobsResourceRequirements JobsResourceRequirements

+ func (c JobServiceConfig) IsValid() error

+ type JobsResourceRequirements map[job.Type]corev1.ResourceRequirements

+ func (r *JobsResourceRequirements) Decode(data string) error

+ func (r *JobsResourceRequirements) UnmarshalTOML(data interface{}) error

Nov 21, 2023

Changes in this version

+ type Mapper interface

+ ToMap func() map[string]any

Oct 5, 2023

Changes in this version

type JobServiceConfig

+ FailedJobsRetentionTime time.Duration

Jul 28, 2023

Changes in this version

+ type JobService struct

+ func NewJobService(log mlog.LoggerIFace, cfg JobServiceConfig) (*JobService, error)

+ 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, _, stderr io.Writer) error

+ func (s *JobService) Init(_ job.ServiceConfig) error

+ func (s *JobService) Shutdown() error

+ type JobServiceConfig struct

+ MaxConcurrentJobs int