org.springframework.xd.dirt.stream.zookeeper

Class ZooKeeperStreamRepository

java.lang.Object

org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamRepository

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, org.springframework.data.repository.CrudRepository<Stream,java.lang.String>, org.springframework.data.repository.PagingAndSortingRepository<Stream,java.lang.String>, org.springframework.data.repository.Repository<Stream,java.lang.String>, DeploymentStatusRepository<Stream,java.lang.String>, StreamRepository, DomainRepository<Stream,java.lang.String>, RangeCapableRepository<Stream,java.lang.String>

public class ZooKeeperStreamRepository
extends java.lang.Object
implements StreamRepository, org.springframework.beans.factory.InitializingBean

Stream instance repository. It should only return values for Streams that are deployed.

Author:

Mark Fisher

Constructor Summary

Constructors

Constructor and Description
ZooKeeperStreamRepository(ZooKeeperConnection zkConnection)

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
long	count()
void	delete(java.lang.Iterable<? extends Stream> entities)
void	delete(Stream entity)
void	delete(java.lang.String id)
void	deleteAll()
boolean	exists(java.lang.String id)
java.util.List<Stream>	findAll()
java.util.List<Stream>	findAll(java.lang.Iterable<java.lang.String> ids)
org.springframework.data.domain.Page<Stream>	findAll(org.springframework.data.domain.Pageable pageable)
java.lang.Iterable<Stream>	findAll(org.springframework.data.domain.Sort sort)
java.lang.Iterable<Stream>	findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive) Return entities whose ids range between from and to.
Stream	findOne(java.lang.String id)
DeploymentUnitStatus	getDeploymentStatus(java.lang.String id) For the given deployment unit id, return the deployment status.
<S extends Stream> java.lang.Iterable<S>	save(java.lang.Iterable<S> entities)
<S extends Stream> S	save(S entity)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperStreamRepository

@Autowired
public ZooKeeperStreamRepository(ZooKeeperConnection zkConnection)

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

findAll

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

Specified by:

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

findAll

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

Specified by:

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

save

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

Specified by:

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

save

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

Specified by:

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

findOne

public Stream findOne(java.lang.String id)

Specified by:

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

exists

public boolean exists(java.lang.String id)

Specified by:

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

findAll

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

Specified by:

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

findAll

public java.util.List<Stream> findAll(java.lang.Iterable<java.lang.String> ids)

Specified by:

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

count

public long count()

Specified by:

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

delete

public void delete(java.lang.String id)

Specified by:

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

delete

public void delete(Stream entity)

Specified by:

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

delete

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

Specified by:

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

deleteAll

public void deleteAll()

Specified by:

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

findAllInRange

public java.lang.Iterable<Stream> findAllInRange(java.lang.String from,
                                        boolean fromInclusive,
                                        java.lang.String 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<Stream,java.lang.String>

getDeploymentStatus

public DeploymentUnitStatus getDeploymentStatus(java.lang.String id)

Description copied from interface: DeploymentStatusRepository

For the given deployment unit id, return the deployment status.

Specified by:

getDeploymentStatus in interface DeploymentStatusRepository<Stream,java.lang.String>

Parameters:

id - id for deployment unit

Returns:

deployment status