Packages

class ActorRatelimiter extends RecipientRatelimiter

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ActorRatelimiter
  2. RecipientRatelimiter
  3. Ratelimiter
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ActorRatelimiter(ref: ActorRef[Command], parallelism: Int)(implicit system: ActorSystem[Nothing], timeout: Timeout)

Value Members

  1. def queryRemainingRequests(route: RequestRoute): Future[Either[Duration, Int]]
    Definition Classes
    RecipientRatelimiterRatelimiter
  2. def ratelimitRequests[A, Ctx]: FlowWithContext[Request[A], Ctx, Either[RequestDropped, Request[A]], Ctx, NotUsed]
    Definition Classes
    RecipientRatelimiterRatelimiter
  3. def reportRatelimits[A]: Sink[RequestAnswer[A], NotUsed]
    Definition Classes
    RecipientRatelimiterRatelimiter