Add: trace peerforwarder config (opensearch-project#4992)

* ADD: trace peerforwarder config Signed-off-by: George Chen <[email protected]> --------- Signed-off-by: George Chen <[email protected]>
kkondaka · Oct 1, 2024 · ccd0e24 · ccd0e24
1 parent 54ede84
commit ccd0e24
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 2 deletions.
diff --git a/...ins/common/src/main/java/org/opensearch/dataprepper/plugins/processor/DelayProcessor.java b/...ins/common/src/main/java/org/opensearch/dataprepper/plugins/processor/DelayProcessor.java
@@ -7,6 +7,7 @@
 
 import com.fasterxml.jackson.annotation.JsonClassDescription;
 import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyDescription;
 import com.fasterxml.jackson.annotation.JsonPropertyOrder;
 import static org.opensearch.dataprepper.logging.DataPrepperMarkers.NOISY;
 import org.opensearch.dataprepper.model.annotations.DataPrepperPlugin;

diff --git a/data-prepper-plugins/trace-peer-forwarder-processor/build.gradle b/data-prepper-plugins/trace-peer-forwarder-processor/build.gradle
@@ -9,4 +9,6 @@ plugins {
 
 dependencies {
     implementation project(':data-prepper-api')
+    implementation 'com.fasterxml.jackson.core:jackson-core'
+    implementation 'com.fasterxml.jackson.core:jackson-databind'
 }
diff --git a/...c/main/java/org/opensearch/dataprepper/plugins/processor/TracePeerForwarderProcessor.java b/...c/main/java/org/opensearch/dataprepper/plugins/processor/TracePeerForwarderProcessor.java
@@ -17,11 +17,12 @@
 import java.util.Collection;
 import java.util.Collections;
 
-@DataPrepperPlugin(name = "trace_peer_forwarder", pluginType = Processor.class)
+@DataPrepperPlugin(name = "trace_peer_forwarder", pluginType = Processor.class,
+        pluginConfigurationType = TracePeerForwarderProcessorConfig.class)
 public class TracePeerForwarderProcessor extends AbstractProcessor<Record<Event>, Record<Event>> implements RequiresPeerForwarding {
 
     @DataPrepperPluginConstructor
-    public TracePeerForwarderProcessor(PluginMetrics pluginMetrics) {
+    public TracePeerForwarderProcessor(final PluginMetrics pluginMetrics) {
         super(pluginMetrics);
     }
 

diff --git a/.../java/org/opensearch/dataprepper/plugins/processor/TracePeerForwarderProcessorConfig.java b/.../java/org/opensearch/dataprepper/plugins/processor/TracePeerForwarderProcessorConfig.java
@@ -0,0 +1,8 @@
+package org.opensearch.dataprepper.plugins.processor;
+
+import com.fasterxml.jackson.annotation.JsonClassDescription;
+
+@JsonClassDescription("The <code>trace_peer_forwarder</code> processor is used with peer forwarder to reduce by half " +
+        "the number of events forwarded in a <a href=\"https://opensearch.org/docs/latest/data-prepper/common-use-cases/trace-analytics/\">Trace Analytics</a> pipeline. ")
+public class TracePeerForwarderProcessorConfig {
+}