Add the Exponential Histogram Aggregator.

sdk/metric/aggregation/aggregation.go

@@ -164,3 +164,65 @@ func (h ExplicitBucketHistogram) Copy() Aggregation {
 		NoMinMax:   h.NoMinMax,
 	}
 }
+
+// ExponentialHistogram is an aggregation that summarizes a set of
+// measurements as an histogram with buckets widths that grow exponentially.
+type ExponentialHistogram struct {
+	// MaxSize is the maximum number of buckets to use for the histogram.
+	MaxSize int
+	// MaxScale is the maximum resolution scale to use for the histogram.
+	MaxScale int
+	// ZeroThreshold sets the minimum value blow which will be recorded as zero.
+	ZeroThreshold float64
+
+	// NoMinMax indicates whether to not record the min and max of the
+	// distribution. By default, these extrema are recorded.
+	//
+	// Recording these extrema for cumulative data is expected to have little
+	// value, they will represent the entire life of the instrument instead of
+	// just the current collection cycle. It is recommended to set this to true
+	// for that type of data to avoid computing the low-value extrema.
+	NoMinMax bool
+}
+
+// DefaultExponentialHistogram returns the default Exponential Histogram aggregation used by the SDK.
+func DefaultExponentialHistogram() ExponentialHistogram {
+	return ExponentialHistogram{
+		MaxSize:       160,
+		MaxScale:      20,
+		ZeroThreshold: 0.0,
+	}
+}
+
+var _ Aggregation = ExponentialHistogram{}
+
+// private attempts to ensure no user-defined Aggregation are allowed. The
+// OTel specification does not allow user-defined Aggregation currently.
+func (e ExponentialHistogram) private() {}
+
+// Copy returns a deep copy of the Aggregation.
+func (e ExponentialHistogram) Copy() Aggregation {
+	return e
+}
+
+const (
+	expoMaxScale = 20
+	expoMinScale = -10
+)
+
+// errExpoHist is returned by misconfigured ExplicitBucketHistograms.
+var errExpoHist = fmt.Errorf("%w: explicit bucket histogram", errAgg)
+
+// Err returns an error for any misconfigured Aggregation.
+func (e ExponentialHistogram) Err() error {
+	if e.MaxScale < expoMinScale {
+		return fmt.Errorf("%w: max size %d is less than minimum scale %d", errExpoHist, e.MaxSize, expoMinScale)
+	}
+	if e.MaxScale > expoMaxScale {
+		return fmt.Errorf("%w: max size %d is greater than maximum scale %d", errExpoHist, e.MaxSize, expoMaxScale)
+	}
+	if e.MaxSize <= 0 {
+		return fmt.Errorf("%w: max size %d is less than or equal to zero", errExpoHist, e.MaxSize)
+	}
+	return nil
+}

sdk/metric/aggregation/aggregation_test.go

@@ -55,6 +55,36 @@ func TestAggregationErr(t *testing.T) {
 			Boundaries: []float64{0, 1, 2, 1, 3, 4},
 		}.Err(), errAgg)
 	})
+
+	t.Run("ExponentialHistogramOperation", func(t *testing.T) {
+		assert.NoError(t, DefaultExponentialHistogram().Err())
+
+		assert.NoError(t, ExponentialHistogram{
+			MaxSize:  1,
+			NoMinMax: true,
+		}.Err())
+
+		assert.NoError(t, ExponentialHistogram{
+			MaxSize:       1024,
+			MaxScale:      -3,
+			ZeroThreshold: 1.0,
+		}.Err())
+	})
+
+	t.Run("InvalidExponentialHistogramOperation", func(t *testing.T) {
+		// MazSize must be greater than 0
+		assert.ErrorIs(t, ExponentialHistogram{}.Err(), errAgg)
+
+		// MaxScale Must be <=20 and >= -10
+		assert.ErrorIs(t, ExponentialHistogram{
+			MaxSize:  1,
+			MaxScale: 30,
+		}.Err(), errAgg)
+		assert.ErrorIs(t, ExponentialHistogram{
+			MaxSize:  1,
+			MaxScale: -20,
+		}.Err(), errAgg)
+	})
 }
 
 func TestExplicitBucketHistogramDeepCopy(t *testing.T) {