co.cask.cdap.runtime.spi.provisioner

Class PollingStrategies

java.lang.Object

co.cask.cdap.runtime.spi.provisioner.PollingStrategies

public class PollingStrategies
extends Object

Some common PollingStrategies

Constructor Summary

Constructors

Constructor and Description
PollingStrategies()

Method Summary

Modifier and Type	Method and Description
static PollingStrategy	fixedInterval(long duration, TimeUnit timeUnit) Return a PollingStrategy that polls at a fixed interval.
static PollingStrategy	initialDelay(PollingStrategy strategy, long baseDuration, long jitterDuration, TimeUnit timeUnit) A PollingStrategy that will wait for a specified base amount of time plus some random jitter time before performing the first poll.
static PollingStrategy	initialDelay(PollingStrategy strategy, long duration, TimeUnit timeUnit) A PollingStrategy that will wait for a specified amount of time before performing the first poll.

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingStrategies

public PollingStrategies()

Method Detail

fixedInterval

public static PollingStrategy fixedInterval(long duration,
                                            TimeUnit timeUnit)

Return a PollingStrategy that polls at a fixed interval.

Parameters:

duration - time to wait in between polls

timeUnit - time unit of the wait

Returns:

fixed interval polling strategy

initialDelay

public static PollingStrategy initialDelay(PollingStrategy strategy,
                                           long duration,
                                           TimeUnit timeUnit)

A PollingStrategy that will wait for a specified amount of time before performing the first poll. Every subsequent poll will be determined by the specified polling strategy.

Parameters:

strategy - polling strategy to use after the first poll

duration - time to wait before the first poll

timeUnit - time unit of the wait

Returns:

a polling strategy that has an initial delay added in

initialDelay

public static PollingStrategy initialDelay(PollingStrategy strategy,
                                           long baseDuration,
                                           long jitterDuration,
                                           TimeUnit timeUnit)

A PollingStrategy that will wait for a specified base amount of time plus some random jitter time before performing the first poll. Every subsequent poll will be determined by the specified polling strategy.

Parameters:

strategy - polling strategy to use after the first poll

baseDuration - wait at least this amount of time before the first poll

jitterDuration - maximum jitter time to add to the base duration

timeUnit - time unit of the wait

Returns:

a polling strategy that has a random amount of initial delay added in