Class Backoff.Jitter
- java.lang.Object
-
- org.apache.bookkeeper.common.util.Backoff.Jitter
-
- All Implemented Interfaces:
Backoff.Policy
- Enclosing class:
- Backoff
public static class Backoff.Jitter extends java.lang.Object implements Backoff.Policy
A Jittered backoff policy.It is an implementation of {@link http://www.awsarchitectureblog.com/2015/03/backoff.html}
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Backoff.Jitter.Type
Jitter type.
-
Field Summary
-
Fields inherited from interface org.apache.bookkeeper.common.util.Backoff.Policy
NONE
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
canEqual(java.lang.Object other)
boolean
equals(java.lang.Object o)
long
getLimit()
long
getMaxMs()
long
getStartMs()
Backoff.Jitter.Type
getType()
int
hashCode()
static Backoff.Jitter
of(Backoff.Jitter.Type type, long startMs, long maxMs)
Create infinite jittered backoff stream.static Backoff.Jitter
of(Backoff.Jitter.Type type, long startMs, long maxMs, long limit)
java.util.stream.Stream<java.lang.Long>
toBackoffs()
Convert the policy into a series of backoff values.java.lang.String
toString()
-
-
-
Method Detail
-
of
public static Backoff.Jitter of(Backoff.Jitter.Type type, long startMs, long maxMs)
Create infinite jittered backoff stream.It is the infinite version of
of(Type, long, long, long)
.- Parameters:
type
- jittered backoff typestartMs
- the start backoff time in milliseconds.maxMs
- the max backoff time in milliseconds.- Returns:
- jittered backoff policy.
-
toBackoffs
public java.util.stream.Stream<java.lang.Long> toBackoffs()
Description copied from interface:Backoff.Policy
Convert the policy into a series of backoff values.- Specified by:
toBackoffs
in interfaceBackoff.Policy
- Returns:
- a series of backoff values.
-
of
public static Backoff.Jitter of(Backoff.Jitter.Type type, long startMs, long maxMs, long limit)
-
getType
public Backoff.Jitter.Type getType()
-
getStartMs
public long getStartMs()
-
getMaxMs
public long getMaxMs()
-
getLimit
public long getLimit()
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
canEqual
protected boolean canEqual(java.lang.Object other)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-