Package app.ductape.sdk.jobs

Class JobsService

java.lang.Object

app.ductape.sdk.jobs.JobsService

public class JobsService
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	JobsService.JobQueueAdapter

Constructor Summary

Constructors

Constructor	Description
JobsService(RequestContext auth)
JobsService(RequestContext auth, io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection)
JobsService(RequestContext auth, io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection, JobsService.JobQueueAdapter queueAdapter)
JobsService(RequestContext auth, io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection, org.redisson.api.RedissonClient redissonClient)

Method Summary

Modifier and Type	Method	Description
RequestContext	auth()
Map<String,Object>	cancel(String jobId, Map<String,Object> options)
Map<String,Object>	cancelMany(Map<String,Object> filter)
Map<String,Object>	createJob(Map<String,Object> data)
boolean	delete(String jobId)
Map<String,Object>	deleteMany(Map<String,Object> filter)
void	enqueueForProcessor(String jobId, String processorJobType, Map<String,Object> jobData, Map<String,Object> queueOptions)	Enqueue work for ProcessorService.runJobs(java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, java.lang.Object>) (TS processJob).
Map<String,Object>	get(String jobId)
Map<String,Object>	getHistory(String jobId, Map<String,Object> options)
Map<String,Object>	getStats(Map<String,Object> options)
Map<String,Object>	getWebhook()
Map<String,Object>	list(Map<String,Object> options)
Map<String,Object>	markCompleted(String jobId, Map<String,Object> result)
Map<String,Object>	markFailed(String jobId, String error, String errorCode)
Map<String,Object>	markStarted(String jobId)
Map<String,Object>	pause(String jobId)
Map<String,Object>	pauseMany(Map<String,Object> filter)
void	removeWebhook()
Map<String,Object>	reschedule(String jobId, Map<String,Object> options)
Map<String,Object>	resume(String jobId)
Map<String,Object>	resumeMany(Map<String,Object> filter)
Map<String,Object>	retry(String jobId, Map<String,Object> options)
Map<String,Object>	retryMany(Map<String,Object> filter)
void	setWebhook(Map<String,Object> config)

Methods inherited from class java.lang.Object

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

Constructor Details

JobsService

public JobsService(RequestContext auth)

JobsService

public JobsService(RequestContext auth,
 io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection)

JobsService

public JobsService(RequestContext auth,
 io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection,
 JobsService.JobQueueAdapter queueAdapter)

JobsService

public JobsService(RequestContext auth,
 io.lettuce.core.api.StatefulRedisConnection<String,String> redisConnection,
 org.redisson.api.RedissonClient redissonClient)

Method Details

auth

public RequestContext auth()

enqueueForProcessor

public void enqueueForProcessor(String jobId,
 String processorJobType,
 Map<String,Object> jobData,
 Map<String,Object> queueOptions)

Enqueue work for ProcessorService.runJobs(java.util.Map<java.lang.String, java.lang.Object>, java.util.Map<java.lang.String, java.lang.Object>) (TS processJob).

get

public Map<String,Object> get(String jobId)

list

public Map<String,Object> list(Map<String,Object> options)

cancel

public Map<String,Object> cancel(String jobId,
 Map<String,Object> options)

cancelMany

public Map<String,Object> cancelMany(Map<String,Object> filter)

pause

public Map<String,Object> pause(String jobId)

pauseMany

public Map<String,Object> pauseMany(Map<String,Object> filter)

resume

public Map<String,Object> resume(String jobId)

resumeMany

public Map<String,Object> resumeMany(Map<String,Object> filter)

reschedule

public Map<String,Object> reschedule(String jobId,
 Map<String,Object> options)

retry

public Map<String,Object> retry(String jobId,
 Map<String,Object> options)

retryMany

public Map<String,Object> retryMany(Map<String,Object> filter)

delete

public boolean delete(String jobId)

deleteMany

public Map<String,Object> deleteMany(Map<String,Object> filter)

getHistory

public Map<String,Object> getHistory(String jobId,
 Map<String,Object> options)

getStats

public Map<String,Object> getStats(Map<String,Object> options)

setWebhook

public void setWebhook(Map<String,Object> config)

getWebhook

public Map<String,Object> getWebhook()

removeWebhook

public void removeWebhook()

markStarted

public Map<String,Object> markStarted(String jobId)

markCompleted

public Map<String,Object> markCompleted(String jobId,
 Map<String,Object> result)

markFailed

public Map<String,Object> markFailed(String jobId,
 String error,
 String errorCode)

createJob

public Map<String,Object> createJob(Map<String,Object> data)