@RestController @RequestMapping(value="/streams/deployments") @ExposesResourceFor(value=org.springframework.cloud.dataflow.rest.resource.StreamDeploymentResource.class) public class StreamDeploymentController extends Object
StreamDefinition
s. Support for stream update, rollback, and
update history by delegating to StreamService
.Constructor and Description |
---|
StreamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService)
Construct a new UpdatableStreamDeploymentController, given a
StreamDeploymentController and StreamService |
Modifier and Type | Method and Description |
---|---|
org.springframework.http.ResponseEntity<Void> |
deploy(String name,
Map<String,String> properties)
Request deployment of an existing stream definition.
|
Collection<org.springframework.cloud.skipper.domain.Release> |
history(String releaseName) |
StreamDeploymentResource |
info(String name)
Request deployment of an existing stream definition.
|
org.springframework.http.ResponseEntity<String> |
manifest(String name,
Integer version) |
Collection<org.springframework.cloud.skipper.domain.Deployer> |
platformList() |
org.springframework.http.ResponseEntity<Void> |
rollback(String name,
Integer version) |
org.springframework.http.ResponseEntity<Void> |
undeploy(String name)
Request un-deployment of an existing stream.
|
org.springframework.http.ResponseEntity<Void> |
undeployAll()
Request un-deployment of all streams.
|
org.springframework.http.ResponseEntity<Void> |
update(String name,
UpdateStreamRequest updateStreamRequest) |
public StreamDeploymentController(StreamDefinitionRepository repository, StreamService streamService)
StreamDeploymentController
and StreamService
repository
- the repository this controller will use for stream CRUD operationsstreamService
- the underlying UpdatableStreamService to deploy the stream@RequestMapping(value="/update/{name}", method=POST) public org.springframework.http.ResponseEntity<Void> update(@PathVariable(value="name") String name, @RequestBody UpdateStreamRequest updateStreamRequest)
@RequestMapping(value="/rollback/{name}/{version}", method=POST) public org.springframework.http.ResponseEntity<Void> rollback(@PathVariable(value="name") String name, @PathVariable(value="version") Integer version)
@RequestMapping(value="/manifest/{name}/{version}", method=GET) public org.springframework.http.ResponseEntity<String> manifest(@PathVariable(value="name") String name, @PathVariable(value="version") Integer version)
@RequestMapping(path="/history/{name}", method=GET) @ResponseStatus(value=OK) public Collection<org.springframework.cloud.skipper.domain.Release> history(@PathVariable(value="name") String releaseName)
@RequestMapping(path="/platform/list", method=GET) @ResponseStatus(value=OK) public Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()
@RequestMapping(value="/{name}", method=DELETE) public org.springframework.http.ResponseEntity<Void> undeploy(@PathVariable(value="name") String name)
name
- the name of an existing stream (required)@RequestMapping(value="", method=DELETE) public org.springframework.http.ResponseEntity<Void> undeployAll()
ResponseEntity
@RequestMapping(value="/{name}", method=GET) @ResponseStatus(value=CREATED) public StreamDeploymentResource info(@PathVariable(value="name") String name)
name
- the name of an existing stream definition (required)@RequestMapping(value="/{name}", method=POST) public org.springframework.http.ResponseEntity<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 © 2019 Pivotal Software, Inc.. All rights reserved.