…thod for others to leverage.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Most of this is just playing, but making the StreamManager implement AutoCloseable gives a place to end spans to show how long a serializer/connection factory was relevant for.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…to the collector to prometheus, zipkin, etc

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…e config hierarchy.

This was broken from the merge https://github.com/opensearch-project/opensearch-migrations/pull/376/files#diff-430f89dc33402ecf692b9a8372f66e585bb2f9215596433216580efc2a56795c.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…lotted within the same graph in prometheus.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…ics into an optional.

Dropping the optionals makes the code simpler and if we don't want to do logging, we can just not fill in the configuration for the SDK.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…troduce some more typesafe wrappers for contexts.

Lots more to come.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…explicitly passing strongly typed context objects.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Make sure that the context is using the right requestKey, which also will have the appropriate indices as per the test context.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…ayerRequestContext to the replayer

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Don't bother showing the Kakfa offloader just buffering (was called recordStream).  Now the offloader span is a child span of the connection span from the handler, so we can see the handler gathering the request/response (or waiting for the response).

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

That makes it a separate state for the logging handler superclass.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…rocessor.

Prometheus metrics already have an export_name that is unique, the processors weren't doing anything useful, & the namespace was appending EVERYTHING from one of the two services.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

…d (less so for now) metrics can be exported across more of the lifetime of a request/connection.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

… a test bug.

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>

# Conflicts:
#	TrafficCapture/nettyWireLogging/src/main/java/org/opensearch/migrations/trafficcapture/netty/ConditionallyReliableLoggingHttpRequestHandler.java
#	TrafficCapture/nettyWireLogging/src/main/java/org/opensearch/migrations/trafficcapture/netty/LoggingHttpRequestHandler.java
#	TrafficCapture/nettyWireLogging/src/test/java/org/opensearch/migrations/trafficcapture/netty/ConditionallyReliableLoggingHttpRequestHandlerTest.java
#	TrafficCapture/trafficCaptureProxyServer/src/main/java/org/opensearch/migrations/trafficcapture/proxyserver/netty/ProxyChannelInitializer.java
#	TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/Accumulation.java
#	TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/CapturedTrafficToHttpTransactionAccumulator.java
#	TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/RequestResponsePacketPair.java
#	TrafficCapture/trafficReplayer/src/main/java/org/opensearch/migrations/replay/RequestSenderOrchestrator.java
#	TrafficCapture/trafficReplayer/src/test/java/org/opensearch/migrations/replay/SimpleCapturedTrafficToHttpTransactionAccumulatorTest.java

Signed-off-by: Greg Schohn <greg.schohn@gmail.com>