docker

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, stdout, stderr io.Writer) error
  • func (s *JobService) Init(cfg job.ServiceConfig) error
  • func (s *JobService) Shutdown() error
• type JobServiceConfig
  • func (c JobServiceConfig) IsValid() 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, 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

func (c JobServiceConfig) IsValid() error