org.springframework.xd.dirt.stream.zookeeper

Class ZooKeeperJobRepository

java.lang.Object

org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobRepository

All Implemented Interfaces:

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

public class ZooKeeperJobRepository
extends java.lang.Object
implements JobRepository, org.springframework.beans.factory.InitializingBean

Job instance repository. It should only return values for Jobs that are deployed.

Author:

Mark Fisher, David Turanski

Constructor Summary

Constructors

Constructor and Description
ZooKeeperJobRepository(ZooKeeperConnection zkConnection)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperJobRepository

@Autowired
public ZooKeeperJobRepository(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<Job> findAll(org.springframework.data.domain.Sort sort)

Specified by:

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

findAll

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

Specified by:

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

save

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

Specified by:

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

save

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

Specified by:

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

findOne

public Job findOne(java.lang.String id)

Specified by:

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

exists

public boolean exists(java.lang.String id)

Specified by:

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

findAll

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

Specified by:

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

findAll

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

Specified by:

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

count

public long count()

Specified by:

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

delete

public void delete(java.lang.String id)

Specified by:

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

delete

public void delete(Job entity)

Specified by:

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

delete

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

Specified by:

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

deleteAll

public void deleteAll()

Specified by:

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

findAllInRange

public java.lang.Iterable<Job> 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<Job,java.lang.String>

getDeploymentStatus

public DeploymentUnitStatus getDeploymentStatus(java.lang.String s)

Description copied from interface: DeploymentStatusRepository

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

Specified by:

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

Parameters:

s - id for deployment unit

Returns:

deployment status