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.InitializingBean
java.lang.Exception
public 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)
RangeCapableRepository
from
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>