Skip to content

Commit db75470

Browse files
authored
Updated the plugin names for the OTLP sources for consistency. (#6530)
Signed-off-by: David Venable <dlv@amazon.com>
1 parent a4f0c9b commit db75470

3 files changed

Lines changed: 10 additions & 5 deletions

File tree

  • data-prepper-plugins
    • otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs
    • otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics
    • otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace

data-prepper-plugins/otel-logs-source/src/main/java/org/opensearch/dataprepper/plugins/source/otellogs/OTelLogsSource.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,9 @@
6262
import java.util.concurrent.ExecutionException;
6363
import java.util.concurrent.ScheduledThreadPoolExecutor;
6464

65-
@DataPrepperPlugin(name = "otel_logs_source", pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class)
65+
@DataPrepperPlugin(name = "otlp_logs",
66+
deprecatedName = "otel_logs_source",
67+
pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class)
6668
public class OTelLogsSource implements Source<Record<Object>> {
6769
private static final Logger LOG = LoggerFactory.getLogger(OTelLogsSource.class);
6870
static final String SERVER_CONNECTIONS = "serverConnections";

data-prepper-plugins/otel-metrics-source/src/main/java/org/opensearch/dataprepper/plugins/source/otelmetrics/OTelMetricsSource.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,9 +37,11 @@
3737
import java.util.Collections;
3838
import java.util.concurrent.ExecutionException;
3939

40-
@DataPrepperPlugin(name = "otel_metrics_source", pluginType = Source.class, pluginConfigurationType = OTelMetricsSourceConfig.class)
40+
@DataPrepperPlugin(name = "otlp_metrics",
41+
deprecatedName = "otel_metrics_source",
42+
pluginType = Source.class, pluginConfigurationType = OTelMetricsSourceConfig.class)
4143
public class OTelMetricsSource implements Source<Record<? extends Metric>> {
42-
private static final String PLUGIN_NAME = "otel_metrics_source";
44+
private static final String PLUGIN_NAME = "otlp_metrics";
4345
private static final Logger LOG = LoggerFactory.getLogger(OTelMetricsSource.class);
4446
static final String SERVER_CONNECTIONS = "serverConnections";
4547

data-prepper-plugins/otel-trace-source/src/main/java/org/opensearch/dataprepper/plugins/source/oteltrace/OTelTraceSource.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,10 @@
3939
import java.nio.charset.StandardCharsets;
4040
import java.util.concurrent.ExecutionException;
4141

42-
@DataPrepperPlugin(name = "otel_trace_source", pluginType = Source.class, pluginConfigurationType = OTelTraceSourceConfig.class)
42+
@DataPrepperPlugin(name = "otlp_traces",
43+
deprecatedName = "otel_trace_source",
44+
pluginType = Source.class, pluginConfigurationType = OTelTraceSourceConfig.class)
4345
public class OTelTraceSource implements Source<Record<Object>> {
44-
private static final String PLUGIN_NAME = "otel_trace_source";
4546
private static final Logger LOG = LoggerFactory.getLogger(OTelTraceSource.class);
4647

4748

0 commit comments

Comments
 (0)