public class ZooKeeperStreamDefinitionRepository extends java.lang.Object implements StreamDefinitionRepository, org.springframework.beans.factory.InitializingBean
| Constructor and Description |
|---|
ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection,
ModuleDependencyRepository moduleDependencyRepository) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
long |
count() |
void |
delete(java.lang.Iterable<? extends StreamDefinition> entities) |
void |
delete(StreamDefinition entity) |
void |
delete(java.lang.String id) |
void |
deleteAll() |
boolean |
exists(java.lang.String id) |
java.util.List<StreamDefinition> |
findAll() |
java.util.List<StreamDefinition> |
findAll(java.lang.Iterable<java.lang.String> ids) |
org.springframework.data.domain.Page<StreamDefinition> |
findAll(org.springframework.data.domain.Pageable pageable) |
java.lang.Iterable<StreamDefinition> |
findAll(org.springframework.data.domain.Sort sort) |
java.lang.Iterable<StreamDefinition> |
findAllInRange(java.lang.String from,
boolean fromInclusive,
java.lang.String to,
boolean toInclusive)
Return entities whose ids range between
from and to. |
StreamDefinition |
findOne(java.lang.String id) |
<S extends StreamDefinition> |
save(java.lang.Iterable<S> entities) |
<S extends StreamDefinition> |
save(S entity) |
@Autowired public ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection, ModuleDependencyRepository moduleDependencyRepository)
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exceptionpublic java.lang.Iterable<StreamDefinition> findAll(org.springframework.data.domain.Sort sort)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>public org.springframework.data.domain.Page<StreamDefinition> findAll(org.springframework.data.domain.Pageable pageable)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>public <S extends StreamDefinition> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)
save in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public <S extends StreamDefinition> S save(S entity)
save in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public StreamDefinition findOne(java.lang.String id)
findOne in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public boolean exists(java.lang.String id)
exists in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public java.util.List<StreamDefinition> findAll()
findAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public java.util.List<StreamDefinition> findAll(java.lang.Iterable<java.lang.String> ids)
findAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public long count()
count in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public void delete(java.lang.String id)
delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public void delete(StreamDefinition entity)
delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public void delete(java.lang.Iterable<? extends StreamDefinition> entities)
delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public void deleteAll()
deleteAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>public java.lang.Iterable<StreamDefinition> findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive)
RangeCapableRepositoryfrom and to. Note that it is possible that entities with
those exact ids do not exist. If they do exist, the two boolean parameters control whether to include those
results or not. A query from x to x returns an empty result, unless both fromInclusive
and toInclusive are true.findAllInRange in interface RangeCapableRepository<StreamDefinition,java.lang.String>