org.hawkular.metrics.tasks.impl

Class LeaseService

java.lang.Object

org.hawkular.metrics.tasks.impl.LeaseService

public class LeaseService
extends Object

Author:

jsanda

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_LEASE_TTL
static int	DEFAULT_RENEWAL_RATE

Constructor Summary

Constructors

Constructor and Description
LeaseService(RxSession session, Queries queries)

Method Summary

Modifier and Type	Method and Description
rx.Observable<Boolean>	acquire(org.hawkular.metrics.tasks.impl.Lease lease)
rx.Observable<Boolean>	acquire(org.hawkular.metrics.tasks.impl.Lease lease, int ttl)
void	autoRenew(org.hawkular.metrics.tasks.impl.Lease lease) Schedules the lease to be automatically renewed every DEFAULT_RENEWAL_RATE seconds in a background thread.
rx.Observable<Void>	deleteLeases(org.joda.time.DateTime timeSlice)
rx.Observable<org.hawkular.metrics.tasks.impl.Lease>	findUnfinishedLeases(org.joda.time.DateTime timeSlice)
rx.Observable<Boolean>	finish(org.hawkular.metrics.tasks.impl.Lease lease)
rx.Observable<? extends List<org.hawkular.metrics.tasks.impl.Lease>>	loadLeases(org.joda.time.DateTime timeSlice)
rx.Observable<Boolean>	renew(org.hawkular.metrics.tasks.impl.Lease lease)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LEASE_TTL

public static final int DEFAULT_LEASE_TTL

See Also:

Constant Field Values

DEFAULT_RENEWAL_RATE

public static final int DEFAULT_RENEWAL_RATE

See Also:

Constant Field Values

Constructor Detail

LeaseService

public LeaseService(RxSession session,
                    Queries queries)

Method Detail

shutdown

public void shutdown()

loadLeases

public rx.Observable<? extends List<org.hawkular.metrics.tasks.impl.Lease>> loadLeases(org.joda.time.DateTime timeSlice)

findUnfinishedLeases

public rx.Observable<org.hawkular.metrics.tasks.impl.Lease> findUnfinishedLeases(org.joda.time.DateTime timeSlice)

acquire

public rx.Observable<Boolean> acquire(org.hawkular.metrics.tasks.impl.Lease lease)

acquire

public rx.Observable<Boolean> acquire(org.hawkular.metrics.tasks.impl.Lease lease,
                                      int ttl)

renew

public rx.Observable<Boolean> renew(org.hawkular.metrics.tasks.impl.Lease lease)

autoRenew

public void autoRenew(org.hawkular.metrics.tasks.impl.Lease lease)

Schedules the lease to be automatically renewed every DEFAULT_RENEWAL_RATE seconds in a background thread. Renewals will stop once the lease is set to finished. If the lease cannot be renewed, then the lease owner, i.e., the calling thread, will be interrupted. It therefore important for lease owners to handle InterruptedExceptions appropriately.

finish

public rx.Observable<Boolean> finish(org.hawkular.metrics.tasks.impl.Lease lease)

deleteLeases

public rx.Observable<Void> deleteLeases(org.joda.time.DateTime timeSlice)