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.InitializingBean
java.lang.Exception
public 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)
RangeCapableRepository
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.findAllInRange
in interface RangeCapableRepository<Job,java.lang.String>
public DeploymentUnitStatus getDeploymentStatus(java.lang.String s)
DeploymentStatusRepository
getDeploymentStatus
in interface DeploymentStatusRepository<Job,java.lang.String>
s
- id for deployment unit