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
DetailedContainer s 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 ContainerRepository
entity
- 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)
DetailedContainer
s in the XD cluster.findAllRuntimeContainers
in interface ContainerRepository
pageable
- the pagination infoDetailedContainer
spublic 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>