Add redis obfuscation

Author: paullegranddc

Cargo.lock

@@ -22,4 +22,5 @@ ddcommon = { path = "../ddcommon" }
 datadog-trace-protobuf = { path = "../trace-protobuf" }
 datadog-trace-utils = { path = "../trace-utils" }
 datadog-trace-normalization = { path = "../trace-normalization" }
+datadog-trace-obfuscation = { path = "../trace-obfuscation" }
 datadog-ddsketch = { path = "../ddsketch" }

data-pipeline/Cargo.toml

@@ -126,7 +126,7 @@ impl StatsExporter {
 
     pub fn insert(&self, mut span_stat: SpanStats) {
         normalize_span_stat(&mut span_stat);
-        // todo obfuscation
+        obfuscate_span_stat(&mut span_stat);
 
         let mut buckets = self.buckets.lock().unwrap();
         let bucket = buckets
@@ -194,6 +194,19 @@ fn normalize_span_stat(span: &mut SpanStats) {
     normalize_utils::normalize_resource(&mut span.resource_name, &span.operation_name);
 }
 
+fn obfuscate_span_stat(span: &mut SpanStats) {
+    match &*span.span_type {
+        "redis" => {
+            span.resource_name =
+                datadog_trace_obfuscation::redis::obfuscate_redis_string(&span.resource_name);
+        }
+        "sql" | "cassandra" => {
+            // TODO integrate SQL obfuscation
+        }
+        _ => {}
+    };
+}
+
 fn encode_bucket(key: BucketKey, bucket: Bucket) -> pb::ClientGroupedStats {
     pb::ClientGroupedStats {
         service: key.service_name,