org.springframework.cloud.dataflow.server.controller

Class SkipperStreamDeploymentController

java.lang.Object

org.springframework.cloud.dataflow.server.controller.StreamDeploymentController

org.springframework.cloud.dataflow.server.controller.SkipperStreamDeploymentController

@RestController
 @RequestMapping(value="/streams/deployments")
 @ExposesResourceFor(value=StreamDeploymentResource.class)
public class SkipperStreamDeploymentController
extends StreamDeploymentController

Controller for deployment operations on StreamDefinitions. Extends the StreamDeploymentController adding support for stream update, rollback, and update history by delegating to SkipperStreamService.

Author:

Eric Bottard, Mark Fisher, Patrick Peralta, Ilayaperumal Gopinathan, Marius Bogoevici, Janne Valkealahti, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
SkipperStreamDeploymentController(StreamDefinitionRepository repository, SkipperStreamService skipperStreamService) Construct a new UpdatableStreamDeploymentController, given a StreamDeploymentController and SkipperStreamService

Method Summary

Modifier and Type	Method and Description
Collection<org.springframework.cloud.skipper.domain.Release>	history(String releaseName)
String	manifest(String name, int version)
Collection<org.springframework.cloud.skipper.domain.Deployer>	platformList()
void	rollback(String name, int version)
void	update(String name, UpdateStreamRequest updateStreamRequest)

Methods inherited from class org.springframework.cloud.dataflow.server.controller.StreamDeploymentController

deploy, info, undeploy, undeployAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SkipperStreamDeploymentController

public SkipperStreamDeploymentController(StreamDefinitionRepository repository,
                                         SkipperStreamService skipperStreamService)

Construct a new UpdatableStreamDeploymentController, given a StreamDeploymentController and SkipperStreamService

Parameters:

repository - the repository this controller will use for stream CRUD operations

skipperStreamService - the underlying UpdatableStreamService to deploy the stream

Method Detail

update

@RequestMapping(value="/update/{name}",
                method=POST)
 @ResponseStatus(value=CREATED)
public void update(@PathVariable(value="name")
                                                                                                                        String name,
                                                                                                                        @RequestBody
                                                                                                                        UpdateStreamRequest updateStreamRequest)

rollback

@RequestMapping(value="/rollback/{name}/{version}",
                method=POST)
 @ResponseStatus(value=CREATED)
public void rollback(@PathVariable(value="name")
                                                                                                                                      String name,
                                                                                                                                      @PathVariable(value="version")
                                                                                                                                      int version)

manifest

@RequestMapping(value="/manifest/{name}/{version}",
                method=GET)
 @ResponseStatus(value=OK)
public String manifest(@PathVariable(value="name")
                                                                                                                                  String name,
                                                                                                                                  @PathVariable(value="version")
                                                                                                                                  int version)

history

@RequestMapping(path="/history/{name}",
                method=GET)
 @ResponseStatus(value=OK)
public Collection<org.springframework.cloud.skipper.domain.Release> history(@PathVariable(value="name")
                                                                                                                                                                           String releaseName)

platformList

@RequestMapping(path="/platform/list",
                method=GET)
 @ResponseStatus(value=OK)
public Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()