public class RedisStreamDefinitionRepository extends Object implements StreamDefinitionRepository
StreamDefinitionRepository
, storing each
definition as a name:dsl mapping in a Redis hash.Constructor and Description |
---|
RedisStreamDefinitionRepository(String hashKey,
org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory)
Construct a new StreamDefinitionRepository backed by Redis, storing definitions
under the key specified by
'hashKey '. |
Modifier and Type | Method and Description |
---|---|
long |
count() |
void |
delete(Iterable<? extends org.springframework.cloud.dataflow.core.StreamDefinition> entities) |
void |
delete(org.springframework.cloud.dataflow.core.StreamDefinition entity) |
void |
delete(String s) |
void |
deleteAll() |
boolean |
exists(String s) |
Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> |
findAll() |
Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> |
findAll(Iterable<String> strings) |
org.springframework.data.domain.Page<org.springframework.cloud.dataflow.core.StreamDefinition> |
findAll(org.springframework.data.domain.Pageable pageable) |
Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> |
findAll(org.springframework.data.domain.Sort sort) |
org.springframework.cloud.dataflow.core.StreamDefinition |
findOne(String s) |
<S extends org.springframework.cloud.dataflow.core.StreamDefinition> |
save(Iterable<S> entities) |
<S extends org.springframework.cloud.dataflow.core.StreamDefinition> |
save(S entity) |
public RedisStreamDefinitionRepository(String hashKey, org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory)
'hashKey
'.hashKey
- key for stream definition hashredisConnectionFactory
- connection factory for Redispublic Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> findAll(org.springframework.data.domain.Sort sort)
findAll
in interface org.springframework.data.repository.PagingAndSortingRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public org.springframework.data.domain.Page<org.springframework.cloud.dataflow.core.StreamDefinition> findAll(org.springframework.data.domain.Pageable pageable)
findAll
in interface org.springframework.data.repository.PagingAndSortingRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public <S extends org.springframework.cloud.dataflow.core.StreamDefinition> S save(S entity)
save
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public <S extends org.springframework.cloud.dataflow.core.StreamDefinition> Iterable<S> save(Iterable<S> entities)
save
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public org.springframework.cloud.dataflow.core.StreamDefinition findOne(String s)
findOne
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public boolean exists(String s)
exists
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> findAll()
findAll
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public Iterable<org.springframework.cloud.dataflow.core.StreamDefinition> findAll(Iterable<String> strings)
findAll
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public long count()
count
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public void delete(String s)
delete
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public void delete(org.springframework.cloud.dataflow.core.StreamDefinition entity)
delete
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public void delete(Iterable<? extends org.springframework.cloud.dataflow.core.StreamDefinition> entities)
delete
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
public void deleteAll()
deleteAll
in interface org.springframework.data.repository.CrudRepository<org.springframework.cloud.dataflow.core.StreamDefinition,String>
Copyright © 2015 Pivotal Software, Inc.. All rights reserved.