Package org.apache.pekko.http.impl.engine.http2

Class Http2Ext

java.lang.Object

org.apache.pekko.http.impl.engine.http2.Http2Ext

All Implemented Interfaces:

org.apache.pekko.actor.Extension

public final class Http2Ext
extends Object
implements org.apache.pekko.actor.Extension

INTERNAL API

Internal entry points for Http/2 server

Constructor Summary

Constructors

Constructor	Description
Http2Ext(org.apache.pekko.actor.ActorSystem system)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<Http.ServerBinding>	bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler, 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(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(String host, int port, ClientConnectionSettings clientConnectionSettings, org.apache.pekko.event.LoggingAdapter log)
org.apache.pekko.actor.ActorSystem	system()
TelemetrySpi	telemetry()
Upgrade	UpgradeHeader()

Methods inherited from class java.lang.Object

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

Constructor Details

Http2Ext

public Http2Ext(org.apache.pekko.actor.ActorSystem system)

Method Details

ConnectionUpgradeHeader

public Connection ConnectionUpgradeHeader()

UpgradeHeader

public Upgrade UpgradeHeader()

bindAndHandleAsync

public scala.concurrent.Future<Http.ServerBinding> bindAndHandleAsync(scala.Function1<HttpRequest,scala.concurrent.Future<HttpResponse>> handler,
 String interface_,
 int port,
 ConnectionContext connectionContext,
 ServerSettings settings,
 org.apache.pekko.event.LoggingAdapter log,
 org.apache.pekko.stream.Materializer fm)

http

public HttpExt http()

httpsWithAlpn

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)

outgoingConnection

public org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnection(String host,
 int port,
 HttpsConnectionContext connectionContext,
 ClientConnectionSettings clientConnectionSettings,
 org.apache.pekko.event.LoggingAdapter log)

outgoingConnectionPriorKnowledge

public org.apache.pekko.stream.scaladsl.Flow<HttpRequest,HttpResponse,scala.concurrent.Future<Http.OutgoingConnection>> outgoingConnectionPriorKnowledge(String host,
 int port,
 ClientConnectionSettings clientConnectionSettings,
 org.apache.pekko.event.LoggingAdapter log)

system

public org.apache.pekko.actor.ActorSystem system()

telemetry

public TelemetrySpi telemetry()