org.springframework.xd.dirt.module.store

Class ZooKeeperModuleMetadataRepository

java.lang.Object

org.springframework.xd.dirt.module.store.ZooKeeperModuleMetadataRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>, org.springframework.data.repository.PagingAndSortingRepository<ModuleMetadata,ModuleMetadata.Id>, org.springframework.data.repository.Repository<ModuleMetadata,ModuleMetadata.Id>, ModuleMetadataRepository, DomainRepository<ModuleMetadata,ModuleMetadata.Id>, RangeCapableRepository<ModuleMetadata,ModuleMetadata.Id>

public class ZooKeeperModuleMetadataRepository
extends java.lang.Object
implements ModuleMetadataRepository

ZooKeeper backed repository for runtime info about deployed modules.

Author:

Ilayaperumal Gopinathan, David Turanski, Gary Russell

Constructor Summary

Constructors

Constructor and Description
ZooKeeperModuleMetadataRepository(ZooKeeperConnection zkConnection, StreamRepository streamRepository, JobRepository jobRepository)

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
void	delete(java.lang.Iterable<? extends ModuleMetadata> entities)
void	delete(ModuleMetadata.Id id)
void	delete(ModuleMetadata entity)
void	deleteAll()
boolean	exists(ModuleMetadata.Id id)
java.util.List<ModuleMetadata>	findAll()
java.lang.Iterable<ModuleMetadata>	findAll(java.lang.Iterable<ModuleMetadata.Id> ids)
org.springframework.data.domain.Page<ModuleMetadata>	findAll(org.springframework.data.domain.Pageable pageable)
java.lang.Iterable<ModuleMetadata>	findAll(org.springframework.data.domain.Sort sort)
org.springframework.data.domain.Page<ModuleMetadata>	findAllByContainerId(org.springframework.data.domain.Pageable pageable, java.lang.String containerId) Find paged ModuleMetadata for all the modules deployed into the given container.
java.util.List<ModuleMetadata>	findAllByContainerId(java.lang.String containerId) Find all the modules that are deployed into this container.
org.springframework.data.domain.Page<ModuleMetadata>	findAllByModuleId(org.springframework.data.domain.Pageable pageable, java.lang.String moduleId) Find paged ModuleMetadata for the modules of given moduleId.
java.lang.Iterable<ModuleMetadata>	findAllInRange(ModuleMetadata.Id from, boolean fromInclusive, ModuleMetadata.Id to, boolean toInclusive) Return entities whose ids range between from and to.
ModuleMetadata	findOne(ModuleMetadata.Id id)
ModuleMetadata	findOne(java.lang.String containerId, java.lang.String moduleId) Find ModuleMetadata for the module that has the given module id and deployed into given container.
<S extends ModuleMetadata> java.lang.Iterable<S>	save(java.lang.Iterable<S> entities)
<S extends ModuleMetadata> S	save(S entity)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperModuleMetadataRepository

@Autowired
public ZooKeeperModuleMetadataRepository(ZooKeeperConnection zkConnection,
                                           StreamRepository streamRepository,
                                           JobRepository jobRepository)

Method Detail

findAll

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

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<ModuleMetadata,ModuleMetadata.Id>

findAll

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

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<ModuleMetadata,ModuleMetadata.Id>

findOne

public ModuleMetadata findOne(java.lang.String containerId,
                     java.lang.String moduleId)

Find ModuleMetadata for the module that has the given module id and deployed into given container.

Specified by:

findOne in interface ModuleMetadataRepository

Parameters:

containerId - the container Id

moduleId - the moduleId

Returns:

the corresponding ModuleMetadata

findAllByContainerId

public org.springframework.data.domain.Page<ModuleMetadata> findAllByContainerId(org.springframework.data.domain.Pageable pageable,
                                                                        java.lang.String containerId)

Find paged ModuleMetadata for all the modules deployed into the given container.

Specified by:

findAllByContainerId in interface ModuleMetadataRepository

Parameters:

pageable - the pageable metadata

containerId - the container Id

Returns:

Paged the ModuleMetadata

findAllByModuleId

public org.springframework.data.domain.Page<ModuleMetadata> findAllByModuleId(org.springframework.data.domain.Pageable pageable,
                                                                     java.lang.String moduleId)

Find paged ModuleMetadata for the modules of given moduleId.

Specified by:

findAllByModuleId in interface ModuleMetadataRepository

Parameters:

pageable - the pageable metadata

moduleId - the module Id

Returns:

Paged the ModuleMetadata

findOne

public ModuleMetadata findOne(ModuleMetadata.Id id)

Find the module metadata for the modules that are deployed into the given container and module metadata id.

Specified by:

findOne in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

Parameters:

id - unique id for module deployment

Returns:

ModuleMetadata of the module.

exists

public boolean exists(ModuleMetadata.Id id)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

findAll

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

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

findAllByContainerId

public java.util.List<ModuleMetadata> findAllByContainerId(java.lang.String containerId)

Find all the modules that are deployed into this container.

Specified by:

findAllByContainerId in interface ModuleMetadataRepository

Parameters:

containerId - the containerId

Returns:

ModuleMetadata of the modules deployed into this container.

findAll

public java.lang.Iterable<ModuleMetadata> findAll(java.lang.Iterable<ModuleMetadata.Id> ids)

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

findAllInRange

public java.lang.Iterable<ModuleMetadata> findAllInRange(ModuleMetadata.Id from,
                                                boolean fromInclusive,
                                                ModuleMetadata.Id to,
                                                boolean toInclusive)

Description copied from interface: RangeCapableRepository

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<ModuleMetadata,ModuleMetadata.Id>

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

save

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

Specified by:

save in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

save

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

Specified by:

save in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

delete

public void delete(ModuleMetadata.Id id)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

delete

public void delete(ModuleMetadata entity)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

delete

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

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<ModuleMetadata,ModuleMetadata.Id>