Package io.confluent.parallelconsumer.internal

Class RateLimiter

java.lang.Object

io.confluent.parallelconsumer.internal.RateLimiter

public class RateLimiter
extends Object

Constructor Summary

Constructors

Constructor	Description
RateLimiter()
RateLimiter(int seconds)

Method Summary

Modifier and Type	Method	Description
boolean	couldPerform()
Duration	getElapsedDuration()
Duration	getRate()
void	performIfNotLimited(Runnable action)

Methods inherited from class java.lang.Object

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

Constructor Details

RateLimiter

public RateLimiter()

RateLimiter

public RateLimiter(int seconds)

Method Details

performIfNotLimited

public void performIfNotLimited(Runnable action)

couldPerform

public boolean couldPerform()

getElapsedDuration

public Duration getElapsedDuration()

getRate

public Duration getRate()