Skip to content

Commit 729e8d9

Browse files
committed
Updated the plugin names for the OTLP sources for consistency.
Signed-off-by: David Venable <dlv@amazon.com>
1 parent 8d569c3 commit 729e8d9

3 files changed

Lines changed: 11 additions & 6 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: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,11 @@
3636
import java.util.Collections;
3737
import java.util.concurrent.ExecutionException;
3838

39-
@DataPrepperPlugin(name = "otel_logs_source", pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class)
39+
@DataPrepperPlugin(name = "otlp_logs",
40+
deprecatedName = "otel_logs_source",
41+
pluginType = Source.class, pluginConfigurationType = OTelLogsSourceConfig.class)
4042
public class OTelLogsSource implements Source<Record<Object>> {
41-
private static final String PLUGIN_NAME = "otel_logs_source";
43+
private static final String PLUGIN_NAME = "otlp_logs";
4244
private static final Logger LOG = LoggerFactory.getLogger(OTelLogsSource.class);
4345
static final String SERVER_CONNECTIONS = "serverConnections";
4446

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)