public class ZooKeeperJobRepository extends java.lang.Object implements JobRepository, org.springframework.beans.factory.InitializingBean
| Constructor and Description |
|---|
ZooKeeperJobRepository(ZooKeeperConnection zkConnection) |
| 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> |
save(java.lang.Iterable<S> entities) |
<S extends Job> |
save(S entity) |
@Autowired public ZooKeeperJobRepository(ZooKeeperConnection zkConnection)
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exceptionpublic java.lang.Iterable<Job> findAll(org.springframework.data.domain.Sort sort)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Job,java.lang.String>public org.springframework.data.domain.Page<Job> findAll(org.springframework.data.domain.Pageable pageable)
findAll in interface org.springframework.data.repository.PagingAndSortingRepository<Job,java.lang.String>public <S extends Job> S save(S entity)
save in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public <S extends Job> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)
save in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public Job findOne(java.lang.String id)
findOne in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public boolean exists(java.lang.String id)
exists in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public java.util.List<Job> findAll()
findAll in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public java.util.List<Job> findAll(java.lang.Iterable<java.lang.String> ids)
findAll in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public long count()
count in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public void delete(java.lang.String id)
delete in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public void delete(Job entity)
delete in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public void delete(java.lang.Iterable<? extends Job> entities)
delete in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public void deleteAll()
deleteAll in interface org.springframework.data.repository.CrudRepository<Job,java.lang.String>public java.lang.Iterable<Job> findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive)
RangeCapableRepositoryfrom 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<Job,java.lang.String>public DeploymentUnitStatus getDeploymentStatus(java.lang.String s)
DeploymentStatusRepositorygetDeploymentStatus in interface DeploymentStatusRepository<Job,java.lang.String>s - id for deployment unit