Package | Description |
---|---|
com.couchbase.client.core.retry.reactor |
Modifier and Type | Class and Description |
---|---|
class |
DefaultRepeat<T> |
Modifier and Type | Method and Description |
---|---|
Repeat<T> |
Repeat.backoff(Backoff backoff)
Returns a repeat function with backoff delay.
|
Repeat<T> |
DefaultRepeat.backoff(Backoff backoff) |
static <T> Repeat<T> |
Repeat.create(Predicate<? super RepeatContext<T>> predicate,
long n)
Repeat function that repeats n times, only if the predicate returns true.
|
Repeat<T> |
Repeat.doOnRepeat(Consumer<? super RepeatContext<T>> onRepeat)
Returns a repeat function that invokes the provided onRepeat
callback before every repeat.
|
Repeat<T> |
DefaultRepeat.doOnRepeat(Consumer<? super RepeatContext<T>> onRepeat) |
default Repeat<T> |
Repeat.exponentialBackoff(Duration firstBackoff,
Duration maxBackoff)
Returns a repeat function with exponential backoff delay.
|
default Repeat<T> |
Repeat.exponentialBackoffWithJitter(Duration firstBackoff,
Duration maxBackoff)
Returns a repeat function with full jitter backoff strategy.
|
default Repeat<T> |
Repeat.fixedBackoff(Duration backoffInterval)
Returns a repeat function with fixed backoff delay.
|
Repeat<T> |
Repeat.jitter(Jitter jitter)
Returns a repeat function that applies jitter to the backoff delay.
|
Repeat<T> |
DefaultRepeat.jitter(Jitter jitter) |
default Repeat<T> |
Repeat.noBackoff()
Returns a repeat function with no backoff delay.
|
static <T> Repeat<T> |
Repeat.once()
Repeat function that repeats once.
|
static <T> Repeat<T> |
Repeat.onlyIf(Predicate<? super RepeatContext<T>> predicate)
Repeat function that repeats only if the predicate returns true.
|
default Repeat<T> |
Repeat.randomBackoff(Duration firstBackoff,
Duration maxBackoff)
Returns a repeat function with random de-correlated jitter backoff strategy.
|
Repeat<T> |
Repeat.repeatMax(long maxRepeats)
Returns a repeat function that repeats at most n times.
|
Repeat<T> |
DefaultRepeat.repeatMax(long maxRepeats) |
Repeat<T> |
Repeat.timeout(Duration timeout)
Returns a repeat function with timeout.
|
Repeat<T> |
DefaultRepeat.timeout(Duration timeout) |
static <T> Repeat<T> |
Repeat.times(long n)
Repeat function that repeats n times.
|
Repeat<T> |
Repeat.withApplicationContext(T applicationContext)
Returns a repeat function with an application context that may be
used to perform any rollbacks before a repeat.
|
Repeat<T> |
DefaultRepeat.withApplicationContext(T applicationContext) |
Repeat<T> |
Repeat.withBackoffScheduler(Scheduler scheduler)
Returns a repeat function that uses the scheduler provided for
backoff delays.
|
Repeat<T> |
DefaultRepeat.withBackoffScheduler(Scheduler scheduler) |
Copyright © 2020 Couchbase, Inc.. All rights reserved.