public class RdbmsStreamDeploymentRepository extends Object implements StreamDeploymentRepository
StreamDeploymentRepository
.Constructor and Description |
---|
RdbmsStreamDeploymentRepository(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
void |
delete(String streamName)
Delete a Stream deployment identified by the given stream name.
|
Iterable<StreamDeployment> |
findAll()
Get all Stream deployment entries
|
StreamDeployment |
findOne(String streamName)
Find a specific StreamDeployment by stream name.
|
StreamDeployment |
save(StreamDeployment streamDeployment)
Store Stream deployment entry.
|
public RdbmsStreamDeploymentRepository(DataSource dataSource)
public StreamDeployment save(StreamDeployment streamDeployment)
StreamDeploymentRepository
save
in interface StreamDeploymentRepository
streamDeployment
- the stream deployment to savepublic StreamDeployment findOne(String streamName)
StreamDeploymentRepository
findOne
in interface StreamDeploymentRepository
streamName
- the stream name corresponding to the stream deploymentpublic Iterable<StreamDeployment> findAll()
StreamDeploymentRepository
findAll
in interface StreamDeploymentRepository
public void delete(String streamName)
StreamDeploymentRepository
delete
in interface StreamDeploymentRepository
streamName
- the stream name corresponding to the stream deploymentCopyright © 2018 Pivotal Software, Inc.. All rights reserved.