Skip to content

Commit

Permalink
Moved the telemetry plugin package
Browse files Browse the repository at this point in the history
Signed-off-by: Gagan Juneja <[email protected]>
  • Loading branch information
Gagan Juneja committed Jul 4, 2023
1 parent 9fac245 commit a927c64
Show file tree
Hide file tree
Showing 11 changed files with 26 additions and 21 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@
import org.opensearch.test.disruption.ServiceDisruptionScheme;
import org.opensearch.test.store.MockFSIndexStore;
import org.opensearch.test.transport.MockTransportService;
import org.opensearch.telemetry.MockTelemetryPlugin;
import org.opensearch.test.telemetry.MockTelemetryPlugin;
import org.opensearch.transport.TransportInterceptor;
import org.opensearch.transport.TransportRequest;
import org.opensearch.transport.TransportRequestHandler;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@
import org.opensearch.script.MockScriptService;
import org.opensearch.search.internal.SearchContext;
import org.opensearch.telemetry.TelemetrySettings;
import org.opensearch.telemetry.MockTelemetryPlugin;
import org.opensearch.test.telemetry.MockTelemetryPlugin;
import org.opensearch.transport.TransportSettings;
import org.junit.AfterClass;
import org.junit.BeforeClass;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,12 @@
* compatible open source license.
*/

package org.opensearch.telemetry;
package org.opensearch.test.telemetry;

import org.opensearch.telemetry.Telemetry;
import org.opensearch.telemetry.TelemetrySettings;
import org.opensearch.telemetry.metrics.MetricsTelemetry;
import org.opensearch.telemetry.tracing.MockTracingTelemetry;
import org.opensearch.test.telemetry.tracing.MockTracingTelemetry;
import org.opensearch.telemetry.tracing.TracingTelemetry;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,13 @@
* compatible open source license.
*/

package org.opensearch.telemetry;
package org.opensearch.test.telemetry;

import java.util.Optional;
import org.opensearch.plugins.Plugin;
import org.opensearch.plugins.TelemetryPlugin;
import org.opensearch.telemetry.Telemetry;
import org.opensearch.telemetry.TelemetrySettings;

/**
* Mock {@link TelemetryPlugin} implementation for testing.
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -6,13 +6,15 @@
* compatible open source license.
*/

package org.opensearch.telemetry.tracing;
package org.opensearch.test.telemetry.tracing;

import java.util.HashMap;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.ThreadLocalRandom;
import java.util.function.Supplier;
import org.opensearch.telemetry.tracing.AbstractSpan;
import org.opensearch.telemetry.tracing.Span;

/**
* MockSpan for testing and strict check validations. Not to be used for production cases.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,13 @@
* compatible open source license.
*/

package org.opensearch.telemetry.tracing;
package org.opensearch.test.telemetry.tracing;

import java.util.Locale;
import java.util.Map;
import java.util.function.BiConsumer;
import org.opensearch.telemetry.tracing.Span;
import org.opensearch.telemetry.tracing.TracingContextPropagator;

/**
* Mock {@link TracingContextPropagator} to persist the span for internode communication.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,11 @@
* compatible open source license.
*/

package org.opensearch.telemetry.tracing;
package org.opensearch.test.telemetry.tracing;

import org.opensearch.telemetry.tracing.Span;
import org.opensearch.telemetry.tracing.TracingContextPropagator;
import org.opensearch.telemetry.tracing.TracingTelemetry;

/**
* Mock {@link TracingTelemetry} implementation for testing.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,9 @@
* compatible open source license.
*/

package org.opensearch.telemetry.tracing;
package org.opensearch.test.telemetry.tracing;

import org.opensearch.telemetry.tracing.Span;

/**
* Processes the span and can perform any action on the span start and end.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,13 @@
* compatible open source license.
*/

package org.opensearch.telemetry.tracing;
package org.opensearch.test.telemetry.tracing;

import java.util.Arrays;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.opensearch.telemetry.tracing.Span;

/**
* Strict check span processor to validate the spans.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,4 +7,4 @@
*/

/** Base opensearch package. */
package org.opensearch.telemetry;
package org.opensearch.test.telemetry.tracing;

0 comments on commit a927c64

Please sign in to comment.