public class StreamTemplate extends Object implements StreamOperations
StreamOperations
.Modifier and Type | Field and Description |
---|---|
static String |
DEFINITIONS_REL |
Modifier and Type | Method and Description |
---|---|
StreamDefinitionResource |
createStream(String name,
String definition,
boolean deploy)
Create a new stream, optionally deploying it.
|
void |
deploy(String name,
Map<String,String> properties)
Deploy an already created stream.
|
void |
destroy(String name)
Destroy an existing stream.
|
void |
destroyAll()
Destroy all streams known to the system.
|
StreamDefinitionResource.Page |
list() |
void |
undeploy(String name)
Undeploy a deployed stream, retaining its definition.
|
void |
undeployAll()
Undeploy all currently deployed streams.
|
public static final String DEFINITIONS_REL
public StreamDefinitionResource.Page list()
list
in interface StreamOperations
public StreamDefinitionResource createStream(String name, String definition, boolean deploy)
StreamOperations
createStream
in interface StreamOperations
name
- the name of the streamdefinition
- the stream definition DSLdeploy
- whether to deploy the stream after creating its definitionpublic void deploy(String name, Map<String,String> properties)
StreamOperations
deploy
in interface StreamOperations
name
- the name of the streamproperties
- the deployment propertiespublic void undeploy(String name)
StreamOperations
undeploy
in interface StreamOperations
name
- the name of the streampublic void undeployAll()
StreamOperations
undeployAll
in interface StreamOperations
public void destroy(String name)
StreamOperations
destroy
in interface StreamOperations
name
- the name of the streampublic void destroyAll()
StreamOperations
destroyAll
in interface StreamOperations
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.