Package org.apache.cassandra.transport

Class QueueBackpressure.Impl

java.lang.Object

org.apache.cassandra.transport.QueueBackpressure.Impl

Enclosing interface:

QueueBackpressure

public static class QueueBackpressure.Impl
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Impl(java.util.function.LongSupplier minDelayNanos, java.util.function.LongSupplier maxDelayNanos, long appliedAt, int severityLevel, int appliedTimes)

Method Summary

Modifier and Type	Method	Description
long	appliedAt()
long	delay(java.util.concurrent.TimeUnit timeUnit)
QueueBackpressure.Impl	mark()
QueueBackpressure.Impl	mark(long now)
long	maxDelayNanos()
long	minDelayNanos()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

Impl

public Impl(java.util.function.LongSupplier minDelayNanos,
            java.util.function.LongSupplier maxDelayNanos,
            long appliedAt,
            int severityLevel,
            int appliedTimes)

Method Detail

mark

public QueueBackpressure.Impl mark()

mark

public QueueBackpressure.Impl mark(long now)

appliedAt

public long appliedAt()

delay

public long delay(java.util.concurrent.TimeUnit timeUnit)

minDelayNanos

public long minDelayNanos()

maxDelayNanos

public long maxDelayNanos()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object