Package com.intuit.karate.job
Class JobManager<T>
- java.lang.Object
-
- com.intuit.karate.job.JobManager<T>
-
- All Implemented Interfaces:
ServerHandler
public class JobManager<T> extends Object implements ServerHandler
- Author:
- pthomas3
-
-
Constructor Summary
Constructors Constructor Description JobManager(JobConfig config)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> CompletableFuture<T>addChunk(T value)protected voiddumpLog(JobMessage jm)Responsehandle(Request request)voidstart()static JobMessagetoJobMessage(String value)voidwaitForCompletion()
-
-
-
Field Detail
-
logger
protected static final org.slf4j.Logger logger
-
KARATE_JOB_HEADER
public static final String KARATE_JOB_HEADER
- See Also:
- Constant Field Values
-
jobId
public final String jobId
-
jobUrl
public final String jobUrl
-
server
public final HttpServer server
-
-
Constructor Detail
-
JobManager
public JobManager(JobConfig config)
-
-
Method Detail
-
addChunk
public <T> CompletableFuture<T> addChunk(T value)
-
waitForCompletion
public void waitForCompletion()
-
start
public void start()
-
handle
public Response handle(Request request)
- Specified by:
handlein interfaceServerHandler
-
toJobMessage
public static JobMessage toJobMessage(String value)
-
dumpLog
protected void dumpLog(JobMessage jm)
-
-