[chore] Remove experimental dead code related to streams and staleness

Signed-off-by: Bogdan Drutu <[email protected]>

internal/exp/metrics/identity/metric.go

@@ -10,8 +10,6 @@ import (
 	"go.opentelemetry.io/collector/pdata/pmetric"
 )
 
-type metric = Metric
-
 type Metric struct {
 	scope
 

internal/exp/metrics/identity/stream.go

@@ -12,8 +12,8 @@ import (
 )
 
 type Stream struct {
-	metric
-	attrs [16]byte
+	metric Metric
+	attrs  [16]byte
 }
 
 func (i Stream) Hash() hash.Hash64 {

internal/exp/metrics/metrics.go

@@ -4,10 +4,10 @@
 package metrics // import "github.com/open-telemetry/opentelemetry-collector-contrib/internal/exp/metrics"
 
 import (
+	"go.opentelemetry.io/collector/pdata/pcommon"
 	"go.opentelemetry.io/collector/pdata/pmetric"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/exp/metrics/identity"
-	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/exp/metrics/streams"
 )
 
 // Merge will merge the metrics data in mdB into mdA, then return mdA.
@@ -111,7 +111,7 @@ outer:
 	return smA
 }
 
-func mergeDataPoints[DPS streams.DataPointSlice[DP], DP streams.DataPoint[DP]](dataPointsA DPS, dataPointsB DPS) DPS {
+func mergeDataPoints[DPS dataPointSlice[DP], DP dataPoint[DP]](dataPointsA DPS, dataPointsB DPS) DPS {
 	// Append all the datapoints from B to A
 	for i := 0; i < dataPointsB.Len(); i++ {
 		dpB := dataPointsB.At(i)
@@ -122,3 +122,15 @@ func mergeDataPoints[DPS streams.DataPointSlice[DP], DP streams.DataPoint[DP]](d
 
 	return dataPointsA
 }
+
+type dataPointSlice[DP dataPoint[DP]] interface {
+	Len() int
+	At(i int) DP
+	AppendEmpty() DP
+}
+
+type dataPoint[Self any] interface {
+	Timestamp() pcommon.Timestamp
+	Attributes() pcommon.Map
+	CopyTo(dest Self)
+}

internal/exp/metrics/staleness/tracker.go

@@ -0,0 +1,40 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package staleness // import "github.com/open-telemetry/opentelemetry-collector-contrib/internal/exp/metrics/staleness"
+
+import (
+	"time"
+
+	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/exp/metrics/identity"
+)
+
+type Tracker struct {
+	pq PriorityQueue
+}
+
+func NewTracker() Tracker {
+	return Tracker{pq: NewPriorityQueue()}
+}
+
+func (tr Tracker) Refresh(ts time.Time, ids ...identity.Stream) {
+	for _, id := range ids {
+		tr.pq.Update(id, ts)
+	}
+}
+
+func (tr Tracker) Collect(maxDuration time.Duration) []identity.Stream {
+	now := time.Now()
+
+	var ids []identity.Stream
+	for tr.pq.Len() > 0 {
+		_, ts := tr.pq.Peek()
+		if now.Sub(ts) < maxDuration {
+			break
+		}
+		id, _ := tr.pq.Pop()
+		ids = append(ids, id)
+	}
+
+	return ids
+}