add base2 expo histo test with sync storage collect

Author: ethandmd

sdk/test/metrics/sync_metric_storage_histogram_test.cc

@@ -388,8 +388,11 @@ TEST_P(WritableMetricStorageHistogramTestFixture, Base2ExponentialDoubleHistogra
             EXPECT_EQ(data.count_, 2);
             EXPECT_EQ(data.min_, 10);
             EXPECT_EQ(data.max_, 20);
-            EXPECT_EQ(data.positive_buckets_.Empty(), false);
             EXPECT_EQ(data.negative_buckets_.Empty(), true);
+            auto start_index = data.positive_buckets_.StartIndex();
+            auto end_index   = data.positive_buckets_.EndIndex();
+            EXPECT_EQ(data.positive_buckets_.Get(start_index), 1);
+            EXPECT_EQ(data.positive_buckets_.Get(end_index), 1);
             count_attributes++;
           }
           else if (opentelemetry::nostd::get<std::string>(
@@ -399,7 +402,10 @@ TEST_P(WritableMetricStorageHistogramTestFixture, Base2ExponentialDoubleHistogra
             EXPECT_EQ(data.count_, 2);
             EXPECT_EQ(data.min_, 30);
             EXPECT_EQ(data.max_, 40);
-            EXPECT_EQ(data.positive_buckets_.Empty(), false);
+            auto start_index = data.positive_buckets_.StartIndex();
+            auto end_index   = data.positive_buckets_.EndIndex();
+            EXPECT_EQ(data.positive_buckets_.Get(start_index), 1);
+            EXPECT_EQ(data.positive_buckets_.Get(end_index), 1);
             EXPECT_EQ(data.negative_buckets_.Empty(), true);
             count_attributes++;
           }
@@ -464,25 +470,68 @@ TEST_P(WritableMetricStorageHistogramTestFixture, Base2ExponentialDoubleHistogra
       collector.get(), collectors, sdk_start_ts, collection_ts, [&](const MetricData &metric_data) {
         for (const auto &data_attr : metric_data.point_data_attr_)
         {
-          const auto &data =
+          auto &data =
               opentelemetry::nostd::get<Base2ExponentialHistogramPointData>(data_attr.point_data);
           if (opentelemetry::nostd::get<std::string>(
                   data_attr.attributes.find("RequestType")->second) == "GET")
           {
             EXPECT_EQ(data.sum_, expected_total_get_requests);
             count_attributes++;
+            auto start_index = data.positive_buckets_.StartIndex();
+            auto end_index   = data.positive_buckets_.EndIndex();
+            if (temporality == AggregationTemporality::kCumulative)
+            {
+              EXPECT_EQ(data.count_, 3);
+              EXPECT_EQ(data.min_, 10);
+              EXPECT_EQ(data.max_, 50);
+              auto count = 0;
+              for (int i = start_index; i <= end_index; ++i) {
+                count += data.positive_buckets_.Get(i);
+              }
+              EXPECT_EQ(count, 3);
+            }
+            if (temporality == AggregationTemporality::kDelta)
+            {
+              EXPECT_EQ(data.count_, 1);
+              EXPECT_EQ(data.min_, 50);
+              EXPECT_EQ(data.max_, 50);
+              EXPECT_EQ(data.positive_buckets_.Get(start_index), 1);
+              EXPECT_EQ(end_index, start_index);
+            }
           }
           else if (opentelemetry::nostd::get<std::string>(
                        data_attr.attributes.find("RequestType")->second) == "PUT")
           {
             EXPECT_EQ(data.sum_, expected_total_put_requests);
             count_attributes++;
+            auto start_index = data.positive_buckets_.StartIndex();
+            auto end_index   = data.positive_buckets_.EndIndex();
+            if (temporality == AggregationTemporality::kCumulative)
+            {
+              EXPECT_EQ(data.count_, 3);
+              EXPECT_EQ(data.min_, 30);
+              EXPECT_EQ(data.max_, 40);
+              auto count = 0;
+              for (int i = start_index; i <= end_index; ++i) {
+                count += data.positive_buckets_.Get(i);
+              }
+              EXPECT_EQ(count, 3);
+            }
+            if (temporality == AggregationTemporality::kDelta)
+            {
+              EXPECT_EQ(data.count_, 1);
+              EXPECT_EQ(data.min_, 40);
+              EXPECT_EQ(data.max_, 40);
+              EXPECT_EQ(data.positive_buckets_.Get(start_index), 1);
+              EXPECT_EQ(end_index, start_index);}
           }
         }
         return true;
       });
+
   EXPECT_EQ(count_attributes, 2);  // GET and PUT
 }
+
 INSTANTIATE_TEST_SUITE_P(WritableMetricStorageHistogramTestBase2ExponentialDouble,
                          WritableMetricStorageHistogramTestFixture,
                          ::testing::Values(AggregationTemporality::kCumulative,