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
Java API: get the singleton instance
tryConsumeTokens
scala.Tuple2<ThrottlerTransportAdapter.ThrottleMode,java.lang.Object> tryConsumeTokens(long nanoTimeOfSend,
int tokens)
timeToAvailable
scala.concurrent.duration.FiniteDuration timeToAvailable(long currentNanoTime,
int tokens)