observer_result_test.cc 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. // Copyright The OpenTelemetry Authors
  2. // SPDX-License-Identifier: Apache-2.0
  3. #include <gtest/gtest.h>
  4. #include <cstdint>
  5. #include <map>
  6. #include <string>
  7. #include <unordered_map>
  8. #include "opentelemetry/common/key_value_iterable_view.h"
  9. #include "opentelemetry/sdk/metrics/observer_result.h"
  10. #include "opentelemetry/sdk/metrics/view/attributes_processor.h"
  11. using namespace opentelemetry::sdk::metrics;
  12. TEST(ObserverResult, BasicTests)
  13. {
  14. const AttributesProcessor *attributes_processor = new DefaultAttributesProcessor();
  15. ObserverResultT<int64_t> observer_result(attributes_processor);
  16. observer_result.Observe(10);
  17. observer_result.Observe(20);
  18. EXPECT_EQ(observer_result.GetMeasurements().size(), 1);
  19. std::map<std::string, int64_t> m1 = {{"k2", 12}};
  20. observer_result.Observe(
  21. 30, opentelemetry::common::KeyValueIterableView<std::map<std::string, int64_t>>(m1));
  22. EXPECT_EQ(observer_result.GetMeasurements().size(), 2);
  23. observer_result.Observe(
  24. 40, opentelemetry::common::KeyValueIterableView<std::map<std::string, int64_t>>(m1));
  25. EXPECT_EQ(observer_result.GetMeasurements().size(), 2);
  26. std::map<std::string, int64_t> m2 = {{"k2", 12}, {"k4", 12}};
  27. observer_result.Observe(
  28. 40, opentelemetry::common::KeyValueIterableView<std::map<std::string, int64_t>>(m2));
  29. EXPECT_EQ(observer_result.GetMeasurements().size(), 3);
  30. delete attributes_processor;
  31. }