akka.remote.transport

Interface ThrottlerTransportAdapter.ThrottleMode

All Superinterfaces:

NoSerializationVerificationNeeded

All Known Implementing Classes:

ThrottlerTransportAdapter.Blackhole$, ThrottlerTransportAdapter.TokenBucket, ThrottlerTransportAdapter.Unthrottled$

Enclosing class:

ThrottlerTransportAdapter

public static interface ThrottlerTransportAdapter.ThrottleMode
extends NoSerializationVerificationNeeded

Method Summary

Modifier and Type	Method and Description
scala.concurrent.duration.FiniteDuration	timeToAvailable(long currentNanoTime, int tokens)
scala.Tuple2<ThrottlerTransportAdapter.ThrottleMode,java.lang.Object>	tryConsumeTokens(long nanoTimeOfSend, int tokens)

Method Detail

tryConsumeTokens

scala.Tuple2<ThrottlerTransportAdapter.ThrottleMode,java.lang.Object> tryConsumeTokens(long nanoTimeOfSend,
                                                                                       int tokens)

timeToAvailable

scala.concurrent.duration.FiniteDuration timeToAvailable(long currentNanoTime,
                                                         int tokens)