public final class Http2Ext
extends java.lang.Object
implements org.apache.pekko.actor.Extension
Internal entry points for Http/2 server
Constructor and Description |
---|
Http2Ext(org.apache.pekko.actor.ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<Http.ServerBinding> |
bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler,
java.lang.String interface_,
int port,
ConnectionContext connectionContext,
ServerSettings settings,
org.apache.pekko.event.LoggingAdapter log,
org.apache.pekko.stream.Materializer fm) |
Connection |
ConnectionUpgradeHeader() |
HttpExt |
http() |
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,scala.concurrent.Future<ServerTerminator>> |
httpsWithAlpn(HttpsConnectionContext httpsContext,
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http1,
org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http2) |
org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> |
outgoingConnection(java.lang.String host,
int port,
HttpsConnectionContext connectionContext,
ClientConnectionSettings clientConnectionSettings,
org.apache.pekko.event.LoggingAdapter log) |
org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> |
outgoingConnectionPriorKnowledge(java.lang.String host,
int port,
ClientConnectionSettings clientConnectionSettings,
org.apache.pekko.event.LoggingAdapter log) |
org.apache.pekko.actor.ActorSystem |
system() |
TelemetrySpi |
telemetry() |
Upgrade |
UpgradeHeader() |
public Connection ConnectionUpgradeHeader()
public Upgrade UpgradeHeader()
public scala.concurrent.Future<Http.ServerBinding> bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler, java.lang.String interface_, int port, ConnectionContext connectionContext, ServerSettings settings, org.apache.pekko.event.LoggingAdapter log, org.apache.pekko.stream.Materializer fm)
public HttpExt http()
public org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,scala.concurrent.Future<ServerTerminator>> httpsWithAlpn(HttpsConnectionContext httpsContext, org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http1, org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.TLSProtocol.SslTlsInbound,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,ServerTerminator> http2)
public org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnection(java.lang.String host, int port, HttpsConnectionContext connectionContext, ClientConnectionSettings clientConnectionSettings, org.apache.pekko.event.LoggingAdapter log)
public org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnectionPriorKnowledge(java.lang.String host, int port, ClientConnectionSettings clientConnectionSettings, org.apache.pekko.event.LoggingAdapter log)
public org.apache.pekko.actor.ActorSystem system()
public TelemetrySpi telemetry()