Class JobOrchestrator

java.lang.Object

com.bluebell.greenhouse.planter.orchestrators.job.JobOrchestrator

All Implemented Interfaces:

GenericOrchestrator

@Service
@Transactional
public class JobOrchestrator
extends Object
implements GenericOrchestrator

Owns the unit of work for the Job endpoints.

Version:

3.0.6

Author:

Stephen Prizio

Constructor Summary

Constructors

Constructor	Description
JobOrchestrator()

Method Summary

Modifier and Type	Method	Description
JobCommandResultDTO	cancelAttempt(String jobId)	Requests cancellation and returns the resulting lifecycle state.
ArtifactDownload	downloadArtifact(String artifactId)	Resolves an authorized artifact download inside the job orchestration boundary.
JobAttemptDetailDTO	getAttempt(String jobId)	Resolves durable attempt detail by public UUID.
PaginatedActionEventDTO	getEvents(String executionId, String severity, int page, int pageSize)	Returns a page of action-execution events.
JobSubmissionDTO	retryAttempt(String jobId, String reason)	Creates a linked retry and returns its public identity.
PaginatedJobSummaryDTO	searchJobSummaries(JobSearchRequest searchRequest)	Searches bounded durable job summaries.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JobOrchestrator

public JobOrchestrator()

Method Details

searchJobSummaries

@Transactional(readOnly=true)
public PaginatedJobSummaryDTO searchJobSummaries(JobSearchRequest searchRequest)

Searches bounded durable job summaries.

Parameters:

searchRequest - operator search request

Returns:

summary page

getAttempt

@Transactional(readOnly=true)
public JobAttemptDetailDTO getAttempt(String jobId)

Resolves durable attempt detail by public UUID.

Parameters:

jobId - public job identifier

Returns:

attempt detail

getEvents

@Transactional(readOnly=true)
public PaginatedActionEventDTO getEvents(String executionId,
 String severity,
 int page,
 int pageSize)

Returns a page of action-execution events.

Parameters:

executionId - public execution identifier

severity - optional severity code

page - page number

pageSize - page size

Returns:

event page

downloadArtifact

@Transactional(readOnly=true)
public ArtifactDownload downloadArtifact(String artifactId)

Resolves an authorized artifact download inside the job orchestration boundary.

Parameters:

artifactId - public artifact identifier

Returns:

artifact download metadata and resource

retryAttempt

public JobSubmissionDTO retryAttempt(String jobId,
 String reason)

Creates a linked retry and returns its public identity.

Parameters:

jobId - public selected attempt identifier

reason - operator reason

Returns:

new attempt submission

cancelAttempt

public JobCommandResultDTO cancelAttempt(String jobId)

Requests cancellation and returns the resulting lifecycle state.

Parameters:

jobId - public job identifier

Returns:

command result