public class JobTemplate extends java.lang.Object implements JobOperations
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<java.lang.String,java.net.URI> |
resources
Holds discovered URLs of the API.
|
protected org.springframework.web.client.RestTemplate |
restTemplate
A template used for http interaction.
|
Modifier and Type | Method and Description |
---|---|
JobDefinitionResource |
createJob(java.lang.String name,
java.lang.String definition,
java.lang.Boolean deploy)
Create a new Job, optionally deploying it.
|
void |
deployJob(java.lang.String name)
Deploy an already created stream.
|
void |
destroyJob(java.lang.String name)
Destroy an existing stream.
|
JobDefinitionResource.Page |
list()
List streams known to the system.
|
java.lang.String |
toString() |
void |
undeployJob(java.lang.String name)
Undeploy a deployed stream, retaining its definition.
|
protected org.springframework.web.client.RestTemplate restTemplate
protected java.util.Map<java.lang.String,java.net.URI> resources
public JobDefinitionResource createJob(java.lang.String name, java.lang.String definition, java.lang.Boolean deploy)
JobOperations
createJob
in interface JobOperations
public void destroyJob(java.lang.String name)
JobOperations
destroyJob
in interface JobOperations
public void deployJob(java.lang.String name)
JobOperations
deployJob
in interface JobOperations
public void undeployJob(java.lang.String name)
JobOperations
undeployJob
in interface JobOperations
public JobDefinitionResource.Page list()
JobOperations
list
in interface JobOperations
public java.lang.String toString()
toString
in class java.lang.Object