fix incorrect code removal

DataDog · Sep 30, 2024 · b652631 · b652631
1 parent 00d1355
commit b652631
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/packages/dd-trace/src/datastreams/processor.js b/packages/dd-trace/src/datastreams/processor.js
@@ -47,6 +47,26 @@ class StatsPoint {
   }
 }
 
+class Backlog {
+  constructor ({ offset, ...tags }) {
+    this._tags = Object.keys(tags).sort().map(key => `${key}:${tags[key]}`)
+    this._hash = this._tags.join(',')
+    this._offset = offset
+  }
+
+  get hash () { return this._hash }
+
+  get offset () { return this._offset }
+
+  get tags () { return this._tags }
+
+  encode () {
+    return {
+      Tags: this.tags,
+      Value: this.offset
+    }
+  }
+}
 
 class StatsBucket {
   constructor () {