c

akka.remote.testkit

TokenBucket

final case class TokenBucket(capacity: Int, tokensPerSecond: Double, nanoTimeOfLastSend: Long, availableTokens: Int) extends ThrottleMode with Product with Serializable

Annotations
@SerialVersionUID()
Source
TestTransportCommands.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TokenBucket
  2. Serializable
  3. Product
  4. Equals
  5. ThrottleMode
  6. NoSerializationVerificationNeeded
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TokenBucket(capacity: Int, tokensPerSecond: Double, nanoTimeOfLastSend: Long, availableTokens: Int)

Value Members

  1. val availableTokens: Int
  2. val capacity: Int
  3. val nanoTimeOfLastSend: Long
  4. def productElementNames: Iterator[String]
    Definition Classes
    Product
  5. def timeToAvailable(currentNanoTime: Long, tokens: Int): FiniteDuration
    Definition Classes
    TokenBucketThrottleMode
  6. val tokensPerSecond: Double
  7. def tryConsumeTokens(nanoTimeOfSend: Long, tokens: Int): (ThrottleMode, Boolean)
    Definition Classes
    TokenBucketThrottleMode