public interface StreamOperations
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.
|
org.springframework.hateoas.PagedResources<StreamDefinitionResource> |
list() |
void |
undeploy(String name)
Undeploy a deployed stream, retaining its definition.
|
void |
undeployAll()
Undeploy all currently deployed streams.
|
org.springframework.hateoas.PagedResources<StreamDefinitionResource> list()
StreamDefinitionResource createStream(String name, String definition, boolean deploy)
name
- the name of the streamdefinition
- the stream definition DSLdeploy
- whether to deploy the stream after creating its definitionvoid deploy(String name, Map<String,String> properties)
name
- the name of the streamproperties
- the deployment propertiesvoid undeploy(String name)
name
- the name of the streamvoid undeployAll()
void destroy(String name)
name
- the name of the streamvoid destroyAll()
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.