services

type DefinitionService interface {
	Create(definition *state.Definition) (state.Definition, error)
	Get(definitionID string) (state.Definition, error)
	GetByAlias(alias string) (state.Definition, error)
	List(limit int, offset int, sortBy string,
		order string, filters map[string][]string,
		envFilters map[string]string) (state.DefinitionList, error)
	Update(definitionID string, updates state.Definition) (state.Definition, error)
	Delete(definitionID string) error

	// Metadata oriented
	ListGroups(limit int, offset int, name *string) (state.GroupsList, error)
	ListTags(limit int, offset int, name *string) (state.TagsList, error)
}

type ExecutionService interface {
	CreateDefinitionRunByDefinitionID(definitionID string, req *state.DefinitionExecutionRequest) (state.Run, error)
	CreateDefinitionRunByAlias(alias string, req *state.DefinitionExecutionRequest) (state.Run, error)
	List(
		limit int,
		offset int,
		sortOrder string,
		sortField string,
		filters map[string][]string,
		envFilters map[string]string) (state.RunList, error)
	Get(runID string) (state.Run, error)
	UpdateStatus(runID string, status string, exitCode *int64, runExceptions *state.RunExceptions, exitReason *string) error
	Terminate(runID string, userInfo state.UserInfo) error
	ReservedVariables() []string
	ListClusters() ([]string, error)
	GetDefaultCluster() string
	GetEvents(run state.Run) (state.PodEventList, error)
	CreateTemplateRunByTemplateID(templateID string, req *state.TemplateExecutionRequest) (state.Run, error)
	CreateTemplateRunByTemplateName(templateName string, templateVersion string, req *state.TemplateExecutionRequest) (state.Run, error)
}

type LogService interface {
	Logs(runID string, lastSeen *string, role *string, facility *string) (string, *string, error)
	LogsText(runID string, w http.ResponseWriter) error
}

type TemplateService interface {
	GetByID(id string) (state.Template, error)
	GetLatestByName(templateName string) (bool, state.Template, error)
	List(limit int, offset int, sortBy string, order string) (state.TemplateList, error)
	ListLatestOnly(limit int, offset int, sortBy string, order string) (state.TemplateList, error)
	Create(tpl *state.CreateTemplateRequest) (state.CreateTemplateResponse, error)
}

type WorkerService interface {
	List(engine string) (state.WorkersList, error)
	Get(workerType string, engine string) (state.Worker, error)
	Update(workerType string, updates state.Worker) (state.Worker, error)
	BatchUpdate(updates []state.Worker) (state.WorkersList, error)
}