Class JobService

java.lang.Object

com.bluebell.greenhouse.radicle.services.AbstractGenericEntityService<Job, JobRepository>

com.bluebell.greenhouse.radicle.services.job.JobService

@Service
@Transactional(readOnly=true)
public class JobService
extends AbstractGenericEntityService<Job, JobRepository>

Read and retention service for durable Job attempts. Execution belongs to the durable lifecycle services; nothing here runs work.

Version:

3.0.6

Author:

Stephen Prizio

Constructor Summary

Constructors

Constructor	Description
JobService(JobRepository jobRepository)	Creates the service.

Method Summary

Modifier and Type	Method	Description
int	deleteOldJobs()	Deletes terminal attempts older than the configured lookback period.
int	deleteStaleRunningJobs()	Deletes attempts that are still marked as running a week after they started.
Optional<Job>	findJobByJobId(String jobId)	Finds a Job by its job id.
org.springframework.data.domain.Page<Job>	searchJobs(JobFilter filter, int page, int pageSize, org.springframework.data.domain.Sort sort)	Returns a paginated Page of Jobs matching the given filter.

Methods inherited from class AbstractGenericEntityService

refreshEntity, resolveEntity, resolveEntity, resolveEntity

Methods inherited from class Object

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

Constructor Details

JobService

public JobService(JobRepository jobRepository)

Creates the service.

Parameters:

jobRepository - JobRepository

Method Details

deleteStaleRunningJobs

@Transactional
public int deleteStaleRunningJobs()

Deletes attempts that are still marked as running a week after they started. Lease recovery moves abandoned work to a terminal state within minutes, so anything still running after a week is residue rather than work in flight.

Returns:

count of deleted attempts

deleteOldJobs

@Transactional
public int deleteOldJobs()

Deletes terminal attempts older than the configured lookback period.

Returns:

count of deleted attempts

findJobByJobId

public Optional<Job> findJobByJobId(String jobId)

Finds a Job by its job id.

Parameters:

jobId - job id

Returns:

Optional Job

searchJobs

public org.springframework.data.domain.Page<Job> searchJobs(JobFilter filter,
 int page,
 int pageSize,
 org.springframework.data.domain.Sort sort)

Returns a paginated Page of Jobs matching the given filter.

Parameters:

filter - JobFilter

page - current page

pageSize - page size

sort - Sort

Returns:

Page of Job