public class ZooKeeperContainerRepository extends java.lang.Object implements ContainerRepository, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>
PathChildrenCache to cache container
info from ZooKeeper. The cache is used for all reads, whereas
all writes are written directly to ZooKeeper. This means
that a read that immediately follows a write may return
null if the cache has not been updated yet.| Constructor and Description |
|---|
ZooKeeperContainerRepository(ZooKeeperConnection zkConnection,
ZooKeeperModuleMetadataRepository moduleMetadataRepository)
Construct a
ZooKeeperContainerRepository. |
| Modifier and Type | Method and Description |
|---|---|
long |
count() |
void |
delete(Container entity) |
void |
delete(java.lang.Iterable<? extends Container> entities) |
void |
delete(java.lang.String id) |
void |
deleteAll() |
boolean |
exists(java.lang.String id) |
java.util.List<Container> |
findAll() |
java.lang.Iterable<Container> |
findAll(java.lang.Iterable<java.lang.String> ids) |
org.springframework.data.domain.Page<Container> |
findAll(org.springframework.data.domain.Pageable pageable) |
java.lang.Iterable<Container> |
findAll(org.springframework.data.domain.Sort sort) |
java.lang.Iterable<Container> |
findAllInRange(java.lang.String from,
boolean fromInclusive,
java.lang.String to,
boolean toInclusive)
Return entities whose ids range between
from and to. |
org.springframework.data.domain.Page<DetailedContainer> |
findAllRuntimeContainers(org.springframework.data.domain.Pageable pageable)
Find all the
DetailedContainers in the XD cluster. |
Container |
findOne(java.lang.String id) |
void |
onApplicationEvent(org.springframework.context.ApplicationEvent event) |
<S extends Container> |
save(java.lang.Iterable<S> entities) |
<S extends Container> |
save(S entity) |
void |
update(Container entity)
Update the container attributes.
|
@Autowired public ZooKeeperContainerRepository(ZooKeeperConnection zkConnection, ZooKeeperModuleMetadataRepository moduleMetadataRepository)
ZooKeeperContainerRepository.zkConnection - the ZooKeeper connectionmoduleMetadataRepository - the module metadata repositorypublic void onApplicationEvent(org.springframework.context.ApplicationEvent event)
onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>public java.lang.Iterable<Container> findAll(org.springframework.data.domain.Sort sort)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Container,java.lang.String>public org.springframework.data.domain.Page<Container> findAll(org.springframework.data.domain.Pageable pageable)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Container,java.lang.String>public <S extends Container> S save(S entity)
save in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public void update(Container entity)
update in interface ContainerRepositoryentity - the container entitypublic <S extends Container> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)
save in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public Container findOne(java.lang.String id)
findOne in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public boolean exists(java.lang.String id)
exists in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public java.util.List<Container> findAll()
findAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public java.lang.Iterable<Container> findAll(java.lang.Iterable<java.lang.String> ids)
findAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public org.springframework.data.domain.Page<DetailedContainer> findAllRuntimeContainers(org.springframework.data.domain.Pageable pageable)
DetailedContainers in the XD cluster.findAllRuntimeContainers in interface ContainerRepositorypageable - the pagination infoDetailedContainerspublic long count()
count in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public void delete(java.lang.String id)
delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public void delete(Container entity)
delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public void delete(java.lang.Iterable<? extends Container> entities)
delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public void deleteAll()
deleteAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>public java.lang.Iterable<Container> findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive)
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<Container,java.lang.String>