@RestController @RequestMapping(value="/streams/deployments") @ExposesResourceFor(value=org.springframework.cloud.dataflow.rest.resource.StreamDeploymentResource.class) public class StreamDeploymentController extends Object
StreamDefinition
.Constructor and Description |
---|
StreamDeploymentController(StreamDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
AppRegistry registry,
org.springframework.cloud.deployer.spi.app.AppDeployer deployer,
ApplicationConfigurationMetadataResolver metadataResolver,
CommonApplicationProperties commonProperties)
Create a
StreamDeploymentController that delegates
CRUD operations to the provided StreamDefinitionRepository
app retrieval to the provided AppRegistry
deployment operations to the provided AppDeployer
|
Modifier and Type | Method and Description |
---|---|
void |
deploy(String name,
Map<String,String> properties)
Request deployment of an existing stream definition.
|
void |
undeploy(String name)
Request un-deployment of an existing stream.
|
void |
undeployAll()
Request un-deployment of all streams.
|
public StreamDeploymentController(StreamDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, AppRegistry registry, org.springframework.cloud.deployer.spi.app.AppDeployer deployer, ApplicationConfigurationMetadataResolver metadataResolver, CommonApplicationProperties commonProperties)
StreamDeploymentController
that delegates
StreamDefinitionRepository
AppRegistry
AppDeployer
repository
- the repository this controller will use for stream CRUD
operationsdeploymentIdRepository
- the repository this controller will use for
deployment IDsregistry
- the registry this controller will use to lookup appsdeployer
- the deployer this controller will use to deploy stream appsmetadataResolver
- the application metadata resolvercommonProperties
- common set of application properties@RequestMapping(value="/{name}", method=DELETE) @ResponseStatus(value=OK) public void undeploy(@PathVariable(value="name") String name)
name
- the name of an existing stream (required)@RequestMapping(value="", method=DELETE) @ResponseStatus(value=OK) public void undeployAll()
@RequestMapping(value="/{name}", method=POST) @ResponseStatus(value=CREATED) public void deploy(@PathVariable(value="name") String name, @RequestBody(required=false) Map<String,String> properties)
name
- the name of an existing stream definition (required)properties
- the deployment properties for the stream as a comma-delimited
list of key=value pairsCopyright © 2017 Pivotal Software, Inc.. All rights reserved.