service

type APIConfig struct {
	HTTP     api.Config     `toml:"http"`
	Security SecurityConfig `toml:"security"`
}

type Config struct {
	API    APIConfig
	Store  StoreConfig
	Jobs   JobsConfig
	Logger logger.Config
}

type JobAPIType string

type JobService interface {
	Init(cfg job.ServiceConfig) error
	CreateJob(cfg job.Config, onStopCb job.StopCb) (job.Job, error)
	DeleteJob(jobID string) error
	GetJobLogs(jobID string, stdout, stderr io.Writer) error
	Shutdown() error
}

type JobsConfig struct {
	APIType                 JobAPIType                  `toml:"api_type"`
	MaxConcurrentJobs       int                         `toml:"max_concurrent_jobs"`
	FailedJobsRetentionTime RetentionTime               `toml:"failed_jobs_retention_time" ignored:"true"`
	ImageRegistry           string                      `toml:"image_registry"`
	Kubernetes              kubernetes.JobServiceConfig `toml:"kubernetes"`
	Docker                  docker.JobServiceConfig     `toml:"docker"`
}

type RetentionTime time.Duration

type SecurityConfig struct {
	// Whether or not to enable admin API access.
	EnableAdmin bool `toml:"enable_admin"`
	// The secret key used to authenticate admin requests.
	AdminSecretKey string `toml:"admin_secret_key"`
	// Whether or not to allow clients to self-register.
	AllowSelfRegistration bool                    `toml:"allow_self_registration"`
	SessionCache          auth.SessionCacheConfig `toml:"session_cache"`
}

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

type StoreConfig struct {
	DataSource string `toml:"data_source"`
}