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

Class Http2$

java.lang.Object
org.apache.pekko.http.impl.engine.http2.Http2$
All Implemented Interfaces:
org.apache.pekko.actor.ExtensionId<Http2Ext>, org.apache.pekko.actor.ExtensionIdProvider
public class Http2$ extends Object implements org.apache.pekko.actor.ExtensionId<Http2Ext>, org.apache.pekko.actor.ExtensionIdProvider
INTERNAL API

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final Http2$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    Http2$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Http2Ext
    apply(org.apache.pekko.actor.ActorSystem system)
     
    Http2Ext
    apply(org.apache.pekko.actor.ClassicActorSystemProvider system)
     
    Http2Ext
    createExtension(org.apache.pekko.actor.ExtendedActorSystem system)
     
    Http2Ext
    get(org.apache.pekko.actor.ActorSystem system)
     
    Http2Ext
    get(org.apache.pekko.actor.ClassicActorSystemProvider system)
     
    org.apache.pekko.actor.ExtensionId<? extends org.apache.pekko.actor.Extension>
    lookup()
     
    org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,scala.concurrent.Future<ServerTerminator>>
    priorKnowledge(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)
     
    AttributeKey<Object>
    streamId()
    Opentelemetry Java Instrumentation relies on this attribute key so avoid changing it.

    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.ExtensionId

    equals, hashCode

  • Field Details

    • MODULE$

      public static final Http2$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • Http2$

      public Http2$()

  • Method Details

    • streamId

      public AttributeKey<Object> streamId()

      Opentelemetry Java Instrumentation relies on this attribute key so avoid changing it. The agent uses it to recognise a request that was replayed through the HTTP/2 stack after an h2c upgrade. See https://github.com/apache/pekko-http/issues/1241

      Returns:
      (undocumented)

    • get

      public Http2Ext get(org.apache.pekko.actor.ActorSystem system)
      Specified by:
      get in interface org.apache.pekko.actor.ExtensionId<Http2Ext>

    • get

      public Http2Ext get(org.apache.pekko.actor.ClassicActorSystemProvider system)
      Specified by:
      get in interface org.apache.pekko.actor.ExtensionId<Http2Ext>

    • apply

      public Http2Ext apply(org.apache.pekko.actor.ClassicActorSystemProvider system)
      Specified by:
      apply in interface org.apache.pekko.actor.ExtensionId<Http2Ext>

    • apply

      public Http2Ext apply(org.apache.pekko.actor.ActorSystem system)
      Specified by:
      apply in interface org.apache.pekko.actor.ExtensionId<Http2Ext>

    • lookup

      public org.apache.pekko.actor.ExtensionId<? extends org.apache.pekko.actor.Extension> lookup()
      Specified by:
      lookup in interface org.apache.pekko.actor.ExtensionIdProvider

    • createExtension

      public Http2Ext createExtension(org.apache.pekko.actor.ExtendedActorSystem system)
      Specified by:
      createExtension in interface org.apache.pekko.actor.ExtensionId<Http2Ext>

    • priorKnowledge

      public org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,scala.concurrent.Future<ServerTerminator>> priorKnowledge(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)