org.jclouds.predicates

Class Retryables

java.lang.Object

org.jclouds.predicates.Retryables

@Beta
public class Retryables
extends Object

convenience methods to retry application of a predicate, and optionally (reducing quite a bit of boilerplate) get the final result or throw assertion error

Author:

alex heneveld

Constructor Summary

Constructors

Constructor and Description
Retryables()

Method Summary

Methods

Modifier and Type	Method and Description
static <Input> void	assertEventually(com.google.common.base.Predicate<Input> predicate, Input input, long maxWaitMillis, String failureMessage)
static <Input> boolean	retry(com.google.common.base.Predicate<Input> predicate, Input input, long maxWaitMillis)
static <Input> boolean	retry(com.google.common.base.Predicate<Input> predicate, Input input, long maxWait, long period, TimeUnit unit)
static <Input,Result> Result	retryGettingResultOrFailing(PredicateWithResult<Input,Result> predicate, Input input, long maxWait, long period, TimeUnit unit, String failureMessage)
static <Input,Result> Result	retryGettingResultOrFailing(PredicateWithResult<Input,Result> predicate, Input input, long maxWaitMillis, String failureMessage)
static <Input> boolean	retryNumTimes(com.google.common.base.Predicate<Input> predicate, Input input, int maxAttempts)
static <Input> boolean	retryNumTimes(com.google.common.base.Predicate<Input> predicate, Input input, int maxAttempts, long period, long maxPeriod, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Detail

Retryables

public Retryables()

Method Detail

retry

public static <Input> boolean retry(com.google.common.base.Predicate<Input> predicate,
                    Input input,
                    long maxWaitMillis)

retry

public static <Input> boolean retry(com.google.common.base.Predicate<Input> predicate,
                    Input input,
                    long maxWait,
                    long period,
                    TimeUnit unit)

retryNumTimes

public static <Input> boolean retryNumTimes(com.google.common.base.Predicate<Input> predicate,
                            Input input,
                            int maxAttempts)

retryNumTimes

public static <Input> boolean retryNumTimes(com.google.common.base.Predicate<Input> predicate,
                            Input input,
                            int maxAttempts,
                            long period,
                            long maxPeriod,
                            TimeUnit unit)

assertEventually

public static <Input> void assertEventually(com.google.common.base.Predicate<Input> predicate,
                            Input input,
                            long maxWaitMillis,
                            String failureMessage)

retryGettingResultOrFailing

public static <Input,Result> Result retryGettingResultOrFailing(PredicateWithResult<Input,Result> predicate,
                                                Input input,
                                                long maxWaitMillis,
                                                String failureMessage)

retryGettingResultOrFailing

public static <Input,Result> Result retryGettingResultOrFailing(PredicateWithResult<Input,Result> predicate,
                                                Input input,
                                                long maxWait,
                                                long period,
                                                TimeUnit unit,
                                                String failureMessage)