com.marklogic.hub.job

Class JobDocManager

java.lang.Object

com.marklogic.client.impl.ResourceManagerImplementation

com.marklogic.client.extensions.ResourceManager

com.marklogic.hub.job.JobDocManager

public class JobDocManager
extends com.marklogic.client.extensions.ResourceManager

Constructor Summary

Constructors

Constructor and Description
JobDocManager(com.marklogic.client.DatabaseClient client)

Method Summary

Modifier and Type	Method and Description
void	createJob(java.lang.String jobId, java.lang.String flow)
com.fasterxml.jackson.databind.JsonNode	getJobDocs(JobStatus status)
com.fasterxml.jackson.databind.JsonNode	getJobDocument(java.lang.String jobId)
com.fasterxml.jackson.databind.JsonNode	getJobDocument(java.lang.String jobId, java.lang.String flowName)
com.fasterxml.jackson.databind.JsonNode	getJobDocumentsForFlow(java.lang.String flowName)
com.fasterxml.jackson.databind.JsonNode	getJobDocumentsForFlows(java.util.List<java.lang.String> flowNames)
com.fasterxml.jackson.databind.JsonNode	getLatestJobDocumentForFlow(java.lang.String flowName)
com.fasterxml.jackson.databind.JsonNode	getLatestJobDocumentForFlows(java.util.List<java.lang.String> flowNames)
com.fasterxml.jackson.databind.JsonNode	postJobs(java.lang.String jobId, java.lang.String status, java.lang.String flowName, java.lang.String step, java.lang.String lastCompleted, RunStepResponse stepResponse)
void	updateJobStatus(java.lang.String jobId, JobStatus status)

Methods inherited from class com.marklogic.client.extensions.ResourceManager

getName, startLogging, stopLogging

Methods inherited from class com.marklogic.client.impl.ResourceManagerImplementation

getServices

Methods inherited from class java.lang.Object

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

Constructor Detail

JobDocManager

public JobDocManager(com.marklogic.client.DatabaseClient client)

Method Detail

updateJobStatus

public void updateJobStatus(java.lang.String jobId,
                            JobStatus status)

postJobs

public com.fasterxml.jackson.databind.JsonNode postJobs(java.lang.String jobId,
                                                        java.lang.String status,
                                                        java.lang.String flowName,
                                                        java.lang.String step,
                                                        java.lang.String lastCompleted,
                                                        RunStepResponse stepResponse)

createJob

public void createJob(java.lang.String jobId,
                      java.lang.String flow)

getJobDocument

public com.fasterxml.jackson.databind.JsonNode getJobDocument(java.lang.String jobId)

getJobDocument

public com.fasterxml.jackson.databind.JsonNode getJobDocument(java.lang.String jobId,
                                                              java.lang.String flowName)

getJobDocs

public com.fasterxml.jackson.databind.JsonNode getJobDocs(JobStatus status)

getJobDocumentsForFlow

public com.fasterxml.jackson.databind.JsonNode getJobDocumentsForFlow(java.lang.String flowName)

getJobDocumentsForFlows

public com.fasterxml.jackson.databind.JsonNode getJobDocumentsForFlows(java.util.List<java.lang.String> flowNames)

getLatestJobDocumentForFlow

public com.fasterxml.jackson.databind.JsonNode getLatestJobDocumentForFlow(java.lang.String flowName)

getLatestJobDocumentForFlows

public com.fasterxml.jackson.databind.JsonNode getLatestJobDocumentForFlows(java.util.List<java.lang.String> flowNames)