kubernetes

Documentation

Index

• type JobService
  • 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
  • func (c JobServiceConfig) IsValid() error
• type JobsResourceRequirements
  • func (r *JobsResourceRequirements) Decode(data string) error
  • func (r *JobsResourceRequirements) UnmarshalTOML(data interface{}) error

Types

type JobService

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

func NewJobService

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

func (*JobService) CreateJob

func (s *JobService) CreateJob(cfg job.Config, onStopCb job.StopCb) (job.Job, 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"`
	PersistentVolumeClaimName string                   `toml:"persistent_volume_claim_name"`
	NodeSysctls               string                   `toml:"node_sysctls"`
}

func (JobServiceConfig) IsValid

func (c JobServiceConfig) IsValid() error

type JobsResourceRequirements

type JobsResourceRequirements map[job.Type]corev1.ResourceRequirements

func (*JobsResourceRequirements) Decode

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

func (*JobsResourceRequirements) UnmarshalTOML

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