Class MockTracingContextPropagator

java.lang.Object

org.opensearch.test.telemetry.tracing.MockTracingContextPropagator

All Implemented Interfaces:

org.opensearch.telemetry.tracing.TracingContextPropagator

public class MockTracingContextPropagator
extends Object
implements org.opensearch.telemetry.tracing.TracingContextPropagator

Mock TracingContextPropagator to persist the span for internode communication.

Constructor Summary

Constructors

Constructor	Description
MockTracingContextPropagator(SpanProcessor spanProcessor)	Constructor

Method Summary

Modifier and Type	Method	Description
Optional<org.opensearch.telemetry.tracing.Span>	extract(Map<String,String> props)
Optional<org.opensearch.telemetry.tracing.Span>	extractFromHeaders(Map<String, Collection<String>> headers)
void	inject(org.opensearch.telemetry.tracing.Span currentSpan, BiConsumer<String,String> setter)

Methods inherited from class java.lang.Object

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

Constructor Details

MockTracingContextPropagator

public MockTracingContextPropagator(SpanProcessor spanProcessor)

Constructor

Parameters:

spanProcessor - span processor.

Method Details

extract

public Optional<org.opensearch.telemetry.tracing.Span> extract(Map<String,String> props)

Specified by:

extract in interface org.opensearch.telemetry.tracing.TracingContextPropagator

extractFromHeaders

public Optional<org.opensearch.telemetry.tracing.Span> extractFromHeaders(Map<String, Collection<String>> headers)

Specified by:

extractFromHeaders in interface org.opensearch.telemetry.tracing.TracingContextPropagator

inject

public void inject(org.opensearch.telemetry.tracing.Span currentSpan,
 BiConsumer<String,String> setter)

Specified by:

inject in interface org.opensearch.telemetry.tracing.TracingContextPropagator