org.apache.pekko.http.impl.engine.client

Class PoolMasterActor

java.lang.Object

org.apache.pekko.http.impl.engine.client.PoolMasterActor

All Implemented Interfaces:

org.apache.pekko.actor.Actor, org.apache.pekko.actor.ActorLogging

public final class PoolMasterActor
extends java.lang.Object
implements org.apache.pekko.actor.Actor, org.apache.pekko.actor.ActorLogging

INTERNAL API

Manages access to a host connection pool or rather: a sequence of pool incarnations.

A host connection pool for a given HostConnectionPoolSetup is a running stream, whose outside interface is provided by its PoolInterface actor. The actor accepts PoolInterface.PoolRequest messages and completes their responsePromise whenever the respective response has been received (or an error occurred).

The PoolMasterActor provides a layer of indirection between a PoolId, which represents a pool, and the PoolInterface instances which are created on-demand and stopped after an idle-timeout.

Several PoolId objects may be mapped to the same pool if they have the same HostConnectionPoolSetup and are marked as being shared. This is the case for example for gateways obtained through HttpExt.cachedHostConnectionPool. Some other gateways are not shared, such as those obtained through HttpExt.newHostConnectionPool, and will have their dedicated restartable pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PoolMasterActor.HasBeenShutdown
static class	PoolMasterActor.HasBeenShutdown$
static class	PoolMasterActor.PoolInterfaceRunning
static class	PoolMasterActor.PoolInterfaceRunning$
static class	PoolMasterActor.PoolInterfaceShuttingDown
static class	PoolMasterActor.PoolInterfaceShuttingDown$
static interface	PoolMasterActor.PoolInterfaceStatus
static class	PoolMasterActor.PoolSize
static class	PoolMasterActor.PoolSize$
static class	PoolMasterActor.PoolStatus
static class	PoolMasterActor.PoolStatus$
static class	PoolMasterActor.SendRequest
static class	PoolMasterActor.SendRequest$
static class	PoolMasterActor.Shutdown
static class	PoolMasterActor.Shutdown$
static class	PoolMasterActor.ShutdownAll
static class	PoolMasterActor.ShutdownAll$
static class	PoolMasterActor.StartPool
static class	PoolMasterActor.StartPool$

Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

org.apache.pekko.actor.Actor.emptyBehavior$, org.apache.pekko.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
PoolMasterActor()

Method Summary

Modifier and Type	Method and Description
org.apache.pekko.actor.ActorContext	context()
static org.apache.pekko.actor.Props	props()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
org.apache.pekko.actor.ActorRef	self()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.pekko.actor.Actor

$init$, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, noSender, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface org.apache.pekko.actor.ActorLogging

$init$, log, org$apache$pekko$actor$ActorLogging$$_log_$eq, org$apache$pekko$actor$ActorLogging$$_log

Constructor Detail

PoolMasterActor

public PoolMasterActor()

Method Detail

props

public static org.apache.pekko.actor.Props props()

context

public org.apache.pekko.actor.ActorContext context()

Specified by:

context in interface org.apache.pekko.actor.Actor

self

public final org.apache.pekko.actor.ActorRef self()

Specified by:

self in interface org.apache.pekko.actor.Actor

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Specified by:

receive in interface org.apache.pekko.actor.Actor