Packages

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

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TokenBucket
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. ThrottleMode
  7. NoSerializationVerificationNeeded
  8. AnyRef
  9. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

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 timeToAvailable(currentNanoTime: Long, tokens: Int): FiniteDuration
    Definition Classes
    TokenBucketThrottleMode
  5. val tokensPerSecond: Double
  6. def tryConsumeTokens(nanoTimeOfSend: Long, tokens: Int): (ThrottleMode, Boolean)
    Definition Classes
    TokenBucketThrottleMode