Apache Pekko 2.0.0-M3+222-b197663b-SNAPSHOT - org.apache.pekko.remote.transport.ThrottlerTransportAdapter.TokenBucket
Apache Pekko2.0.0-M3+222-b197663b-SNAPSHOT < Back

Packages
  package root
Definition Classesroot
  package org
Definition Classesroot
  package apache
Definition Classesorg
  package pekko
Definition Classesapache
  package remote
Definition Classespekko
  package transport
Definition Classesremote
  object ThrottlerTransportAdapter
Definition Classestransport
Blackhole
Direction
ForceDisassociate
ForceDisassociateAck
ForceDisassociateExplicitly
SetThrottle
SetThrottleAck
ThrottleMode
TokenBucket
Unthrottled
c
org.apache.pekko.remote.transport.ThrottlerTransportAdapterTokenBucketfinal  case class TokenBucket(capacity: Int, tokensPerSecond: Double, nanoTimeOfLastSend: Long, availableTokens: Int) extends ThrottleMode with Product with Serializable
Annotations@SerialVersionUID() SourceThrottlerTransportAdapter.scala
Linear Supertypes
Serializable, Product, Equals, ThrottleMode, NoSerializationVerificationNeeded, AnyRef, Any
Type Hierarchy

Ordering
Alphabetic
By Inheritance
Inherited
TokenBucket
Serializable
Product
Equals
ThrottleMode
NoSerializationVerificationNeeded
AnyRef
Any
Implicitly
by any2stringadd
by StringFormat
by Ensuring
by ArrowAssoc
Hide All
Show All
Visibility
Public
Protected
Instance Constructors
  new TokenBucket(capacity: Int, tokensPerSecond: Double, nanoTimeOfLastSend: Long, availableTokens: Int)
Value Members
 final  def !=(arg0: Any): Boolean
Definition ClassesAnyRef → Any
 final  def ##: Int
Definition ClassesAnyRef → Any
  def +(other: String): String
ImplicitThis member is added by an implicit conversion from TokenBucket toany2stringadd[TokenBucket] performed by method any2stringadd in scala.Predef.Definition Classesany2stringadd
  def ->[B](y: B): (TokenBucket, B)
ImplicitThis member is added by an implicit conversion from TokenBucket toArrowAssoc[TokenBucket] performed by method ArrowAssoc in scala.Predef.Definition ClassesArrowAssocAnnotations@inline()
 final  def ==(arg0: Any): Boolean
Definition ClassesAnyRef → Any
 final  def asInstanceOf[T0]: T0
Definition ClassesAny
  val availableTokens: Int
  val capacity: Int
  def clone(): AnyRef
Attributesprotected[lang] Definition ClassesAnyRefAnnotations@throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  def ensuring(cond: (TokenBucket) => Boolean, msg: => Any): TokenBucket
ImplicitThis member is added by an implicit conversion from TokenBucket toEnsuring[TokenBucket] performed by method Ensuring in scala.Predef.Definition ClassesEnsuring
  def ensuring(cond: (TokenBucket) => Boolean): TokenBucket
ImplicitThis member is added by an implicit conversion from TokenBucket toEnsuring[TokenBucket] performed by method Ensuring in scala.Predef.Definition ClassesEnsuring
  def ensuring(cond: Boolean, msg: => Any): TokenBucket
ImplicitThis member is added by an implicit conversion from TokenBucket toEnsuring[TokenBucket] performed by method Ensuring in scala.Predef.Definition ClassesEnsuring
  def ensuring(cond: Boolean): TokenBucket
ImplicitThis member is added by an implicit conversion from TokenBucket toEnsuring[TokenBucket] performed by method Ensuring in scala.Predef.Definition ClassesEnsuring
 final  def eq(arg0: AnyRef): Boolean
Definition ClassesAnyRef
 final  def getClass(): Class[_ <: AnyRef]
Definition ClassesAnyRef → AnyAnnotations@IntrinsicCandidate() @native()
 final  def isInstanceOf[T0]: Boolean
Definition ClassesAny
  val nanoTimeOfLastSend: Long
 final  def ne(arg0: AnyRef): Boolean
Definition ClassesAnyRef
 final  def notify(): Unit
Definition ClassesAnyRefAnnotations@IntrinsicCandidate() @native()
 final  def notifyAll(): Unit
Definition ClassesAnyRefAnnotations@IntrinsicCandidate() @native()
  def productElementNames: Iterator[String]
Definition ClassesProduct
 final  def synchronized[T0](arg0: => T0): T0
Definition ClassesAnyRef
  def timeToAvailable(currentNanoTime: Long, tokens: Int): FiniteDuration
Definition ClassesTokenBucket → ThrottleMode
  val tokensPerSecond: Double
  def tryConsumeTokens(nanoTimeOfSend: Long, tokens: Int): (ThrottleMode, Boolean)
Definition ClassesTokenBucket → ThrottleMode
 final  def wait(arg0: Long, arg1: Int): Unit
Definition ClassesAnyRefAnnotations@throws(classOf[java.lang.InterruptedException])
 final  def wait(arg0: Long): Unit
Definition ClassesAnyRefAnnotations@throws(classOf[java.lang.InterruptedException]) @native()
 final  def wait(): Unit
Definition ClassesAnyRefAnnotations@throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
  def finalize(): Unit
Attributesprotected[lang] Definition ClassesAnyRefAnnotations@throws(classOf[java.lang.Throwable]) @Deprecated Deprecated
(Since version 9)
  def formatted(fmtstr: String): String
ImplicitThis member is added by an implicit conversion from TokenBucket toStringFormat[TokenBucket] performed by method StringFormat in scala.Predef.Definition ClassesStringFormatAnnotations@deprecated @inline() Deprecated
(Since version 2.12.16) Use formatString.format(value) instead of value.formatted(formatString),
or use the f"" string interpolator. In Java 15 and later, formatted resolves to the new method in String which has reversed parameters.
  def →[B](y: B): (TokenBucket, B)
ImplicitThis member is added by an implicit conversion from TokenBucket toArrowAssoc[TokenBucket] performed by method ArrowAssoc in scala.Predef.Definition ClassesArrowAssocAnnotations@deprecated Deprecated
(Since version 2.13.0) Use -> instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.
Inherited from Serializable
Inherited from Product
Inherited from Equals
Inherited from ThrottleMode
Inherited from NoSerializationVerificationNeeded
Inherited from AnyRef
Inherited from Any
Inherited by implicit conversion any2stringadd fromTokenBucket to any2stringadd[TokenBucket]
Inherited by implicit conversion StringFormat fromTokenBucket to StringFormat[TokenBucket]
Inherited by implicit conversion Ensuring fromTokenBucket to Ensuring[TokenBucket]
Inherited by implicit conversion ArrowAssoc fromTokenBucket to ArrowAssoc[TokenBucket]
Ungrouped