public interface TelemetrySpi
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,HttpRequest,HttpResponse,HttpResponse,org.apache.pekko.NotUsed> |
client()
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> |
serverBinding()
Flow to intercept server binding.
|
org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,org.apache.pekko.NotUsed> |
serverConnection()
Flow to intercept server connections.
|
org.apache.pekko.stream.scaladsl.BidiFlow<HttpRequest,HttpRequest,HttpResponse,HttpResponse,org.apache.pekko.NotUsed> client()
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()
org.apache.pekko.stream.scaladsl.BidiFlow<HttpResponse,HttpResponse,HttpRequest,HttpRequest,org.apache.pekko.NotUsed> serverConnection()