Interface TelemetrySpi

All Known Implementing Classes:
NoOpTelemetry$

public interface TelemetrySpi
INTERNAL API
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,HttpRequest,HttpResponse,HttpResponse,org.apache.pekko.NotUsed>
    Flow to intercept server connections.
    org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.scaladsl.Tcp.IncomingConnection,org.apache.pekko.stream.scaladsl.Tcp.IncomingConnection,org.apache.pekko.NotUsed>
    Flow to intercept server binding.
    org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,org.apache.pekko.NotUsed>
    Flow to intercept server connections.
  • Method Details

    • client

      org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,HttpRequest,HttpResponse,HttpResponse,org.apache.pekko.NotUsed> client()
      Flow to intercept server connections. When run the flow will have the ClientMeta attribute set.
      Returns:
      (undocumented)
    • serverBinding

      org.apache.pekko.stream.scaladsl.Flow<org.apache.pekko.stream.scaladsl.Tcp.IncomingConnection,org.apache.pekko.stream.scaladsl.Tcp.IncomingConnection,org.apache.pekko.NotUsed> serverBinding()
      Flow to intercept server binding.
      Returns:
      (undocumented)
    • serverConnection

      org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,org.apache.pekko.NotUsed> serverConnection()
      Flow to intercept server connections.
      Returns:
      (undocumented)