Package ch.so.agi.gretl.control.server.run

Class RunService

java.lang.Object

ch.so.agi.gretl.control.server.run.RunService

@Service
public class RunService
extends Object

Constructor Summary

Constructors

Constructor	Description
RunService(ManifestCatalog catalog, RunRepository runRepository, SecretService secretService, LogService logService, NotificationService notificationService)

Method Summary

Modifier and Type	Method	Description
void	appendLog(String runId, ch.so.agi.gretl.control.api.RunLogAppendRequest request)
ch.so.agi.gretl.control.api.RunClaimResponse	claim(ch.so.agi.gretl.control.api.RunClaimRequest request)
RunRecord	enqueueManual(String jobId, Map<String,Object> parameters, String triggeredBy)
RunRecord	enqueueScheduled(String jobId)
boolean	isCancelRequested(String runId)
String	readLog(String runId)
List<RunRecord>	recentRuns(int limit)
List<RunRecord>	recentRunsForJob(String jobId, int limit)
void	requestCancel(String runId)
RunRecord	requireRun(String runId)
RunRecord	retry(String runId, String triggeredBy)
List<String>	skipQueuedRunsWithoutRunnableJob(String message)
void	updateStatus(String runId, ch.so.agi.gretl.control.api.RunStatusUpdateRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

RunService

public RunService(ManifestCatalog catalog,
 RunRepository runRepository,
 SecretService secretService,
 LogService logService,
 NotificationService notificationService)

Method Details

enqueueManual

@Transactional
public RunRecord enqueueManual(String jobId,
 Map<String,Object> parameters,
 String triggeredBy)

enqueueScheduled

@Transactional
public RunRecord enqueueScheduled(String jobId)

retry

@Transactional
public RunRecord retry(String runId,
 String triggeredBy)

recentRuns

public List<RunRecord> recentRuns(int limit)

recentRunsForJob

public List<RunRecord> recentRunsForJob(String jobId,
 int limit)

requireRun

public RunRecord requireRun(String runId)

requestCancel

@Transactional
public void requestCancel(String runId)

isCancelRequested

public boolean isCancelRequested(String runId)

claim

@Transactional
public ch.so.agi.gretl.control.api.RunClaimResponse claim(ch.so.agi.gretl.control.api.RunClaimRequest request)

updateStatus

@Transactional
public void updateStatus(String runId,
 ch.so.agi.gretl.control.api.RunStatusUpdateRequest request)

appendLog

public void appendLog(String runId,
 ch.so.agi.gretl.control.api.RunLogAppendRequest request)

readLog

public String readLog(String runId)

skipQueuedRunsWithoutRunnableJob

@Transactional
public List<String> skipQueuedRunsWithoutRunnableJob(String message)