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

Class SlotState

java.lang.Object

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

All Implemented Interfaces:

scala.Equals, scala.Product

Direct Known Subclasses:

SlotState.ConnectedState, SlotState.Embargoed, SlotState.OutOfEmbargo$, SlotState.ShouldCloseConnectionState, SlotState.Unconnected$

public abstract class SlotState
extends java.lang.Object
implements scala.Product

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SlotState.BusyState
static interface	SlotState.BusyWithResultAlreadyDetermined
static class	SlotState.ConnectedState
static class	SlotState.Connecting
static class	SlotState.Connecting$
static class	SlotState.Embargoed
static class	SlotState.Embargoed$
static class	SlotState.Failed
static class	SlotState.Failed$
static class	SlotState.Idle
static class	SlotState.Idle$
static interface	SlotState.IdleState
static class	SlotState.OutOfEmbargo$
static class	SlotState.PreConnecting$
static class	SlotState.PushingRequestToConnection
static class	SlotState.PushingRequestToConnection$
static class	SlotState.ShouldCloseConnectionState
static class	SlotState.ToBeClosed$
static class	SlotState.Unconnected$
static interface	SlotState.UnconnectedState
static class	SlotState.WaitingForEndOfRequestEntity$
static class	SlotState.WaitingForEndOfResponseEntity
static class	SlotState.WaitingForEndOfResponseEntity$
static class	SlotState.WaitingForResponse
static class	SlotState.WaitingForResponse$
static class	SlotState.WaitingForResponseDispatch
static class	SlotState.WaitingForResponseDispatch$
static class	SlotState.WaitingForResponseEntitySubscription
static class	SlotState.WaitingForResponseEntitySubscription$

Constructor Summary

Constructors

Constructor and Description
SlotState()

Method Summary

Modifier and Type	Method and Description
SlotState	idle(SlotContext ctx)
protected SlotState	illegalState(SlotContext ctx, java.lang.String what)
abstract boolean	isConnected()
abstract boolean	isIdle()
java.lang.String	name()
SlotState	onConnectionAttemptFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onConnectionAttemptSucceeded(SlotContext ctx, Http.OutgoingConnection outgoingConnection)
SlotState	onConnectionCompleted(SlotContext ctx)
SlotState	onConnectionFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onNewConnectionEmbargo(SlotContext ctx, scala.concurrent.duration.FiniteDuration embargoDuration)
SlotState	onNewRequest(SlotContext ctx, PoolFlow.RequestContext requestContext)
SlotState	onPreConnect(SlotContext ctx)
SlotState	onRequestDispatched(SlotContext ctx)
SlotState	onRequestEntityCompleted(SlotContext ctx) Will be called either immediately if the request entity is strict or otherwise later
SlotState	onRequestEntityFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onResponseDispatchable(SlotContext ctx) Called when the response out port is ready to receive a further response (successful or failed)
SlotState	onResponseEntityCompleted(SlotContext ctx) Will be called either immediately if the response entity is strict or otherwise later
SlotState	onResponseEntityFailed(SlotContext ctx, java.lang.Throwable cause)
SlotState	onResponseEntitySubscribed(SlotContext ctx)
SlotState	onResponseReceived(SlotContext ctx, HttpResponse response)
void	onShutdown(SlotContext ctx)
SlotState	onTimeout(SlotContext ctx)
scala.concurrent.duration.Duration	stateTimeout() A slot can define a timeout for that state after which onTimeout will be called.

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

SlotState

public SlotState()

Method Detail

isIdle

public abstract boolean isIdle()

isConnected

public abstract boolean isConnected()

idle

public SlotState idle(SlotContext ctx)

onPreConnect

public SlotState onPreConnect(SlotContext ctx)

onConnectionAttemptSucceeded

public SlotState onConnectionAttemptSucceeded(SlotContext ctx,
                                              Http.OutgoingConnection outgoingConnection)

onConnectionAttemptFailed

public SlotState onConnectionAttemptFailed(SlotContext ctx,
                                           java.lang.Throwable cause)

onNewConnectionEmbargo

public SlotState onNewConnectionEmbargo(SlotContext ctx,
                                        scala.concurrent.duration.FiniteDuration embargoDuration)

onNewRequest

public SlotState onNewRequest(SlotContext ctx,
                              PoolFlow.RequestContext requestContext)

onRequestDispatched

public SlotState onRequestDispatched(SlotContext ctx)

onRequestEntityCompleted

public SlotState onRequestEntityCompleted(SlotContext ctx)

Will be called either immediately if the request entity is strict or otherwise later

onRequestEntityFailed

public SlotState onRequestEntityFailed(SlotContext ctx,
                                       java.lang.Throwable cause)

onResponseReceived

public SlotState onResponseReceived(SlotContext ctx,
                                    HttpResponse response)

onResponseDispatchable

public SlotState onResponseDispatchable(SlotContext ctx)

Called when the response out port is ready to receive a further response (successful or failed)

onResponseEntitySubscribed

public SlotState onResponseEntitySubscribed(SlotContext ctx)

onResponseEntityCompleted

public SlotState onResponseEntityCompleted(SlotContext ctx)

Will be called either immediately if the response entity is strict or otherwise later

onResponseEntityFailed

public SlotState onResponseEntityFailed(SlotContext ctx,
                                        java.lang.Throwable cause)

onConnectionCompleted

public SlotState onConnectionCompleted(SlotContext ctx)

onConnectionFailed

public SlotState onConnectionFailed(SlotContext ctx,
                                    java.lang.Throwable cause)

onTimeout

public SlotState onTimeout(SlotContext ctx)

onShutdown

public void onShutdown(SlotContext ctx)

stateTimeout

public scala.concurrent.duration.Duration stateTimeout()

A slot can define a timeout for that state after which onTimeout will be called.

illegalState

protected SlotState illegalState(SlotContext ctx,
                                 java.lang.String what)

name

public java.lang.String name()