org.springframework.xd.dirt.container.store

Class ZooKeeperContainerRepository

java.lang.Object

org.springframework.xd.dirt.container.store.ZooKeeperContainerRepository

All Implemented Interfaces:

java.util.EventListener, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>, org.springframework.data.repository.CrudRepository<Container,java.lang.String>, org.springframework.data.repository.PagingAndSortingRepository<Container,java.lang.String>, org.springframework.data.repository.Repository<Container,java.lang.String>, ContainerRepository, DomainRepository<Container,java.lang.String>, RangeCapableRepository<Container,java.lang.String>

public class ZooKeeperContainerRepository
extends java.lang.Object
implements ContainerRepository, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

ZooKeeper backed repository for runtime info about Containers. This implementation uses 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.

Author:

Mark Fisher, David Turanski, Ilayaperumal Gopinathan, Patrick Peralta

Constructor Summary

Constructors

Constructor and Description
ZooKeeperContainerRepository(ZooKeeperConnection zkConnection, ZooKeeperModuleMetadataRepository moduleMetadataRepository) Construct a ZooKeeperContainerRepository.

Method Summary

Methods

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, boolean maskSensitiveProperties) Find all the DetailedContainers in the XD cluster.
Container	findOne(java.lang.String id)
void	onApplicationEvent(org.springframework.context.ApplicationEvent event)
<S extends Container> java.lang.Iterable<S>	save(java.lang.Iterable<S> entities)
<S extends Container> S	save(S entity)
void	update(Container entity) Update the container attributes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZooKeeperContainerRepository

@Autowired
public ZooKeeperContainerRepository(ZooKeeperConnection zkConnection,
                                      ZooKeeperModuleMetadataRepository moduleMetadataRepository)

Construct a ZooKeeperContainerRepository.

Parameters:

zkConnection - the ZooKeeper connection

moduleMetadataRepository - the module metadata repository

Method Detail

onApplicationEvent

public void onApplicationEvent(org.springframework.context.ApplicationEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>

findAll

public java.lang.Iterable<Container> findAll(org.springframework.data.domain.Sort sort)

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Container,java.lang.String>

findAll

public org.springframework.data.domain.Page<Container> findAll(org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Container,java.lang.String>

save

public <S extends Container> S save(S entity)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

update

public void update(Container entity)

Update the container attributes.

Specified by:

update in interface ContainerRepository

Parameters:

entity - the container entity

save

public <S extends Container> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

findOne

public Container findOne(java.lang.String id)

Specified by:

findOne in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

exists

public boolean exists(java.lang.String id)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

findAll

public java.util.List<Container> findAll()

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

findAll

public java.lang.Iterable<Container> findAll(java.lang.Iterable<java.lang.String> ids)

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

findAllRuntimeContainers

public org.springframework.data.domain.Page<DetailedContainer> findAllRuntimeContainers(org.springframework.data.domain.Pageable pageable,
                                                                               boolean maskSensitiveProperties)

Find all the DetailedContainers in the XD cluster.

Specified by:

findAllRuntimeContainers in interface ContainerRepository

Parameters:

pageable - the pagination info

maskSensitiveProperties - Shall sensitive data such as passwords be masked?

Returns:

the paged list of DetailedContainers

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

delete

public void delete(java.lang.String id)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

delete

public void delete(Container entity)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

delete

public void delete(java.lang.Iterable<? extends Container> entities)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<Container,java.lang.String>

findAllInRange

public 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. 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.

Specified by:

findAllInRange in interface RangeCapableRepository<Container,java.lang.String>