ceph/src/jaegertracing/jaeger-client-cpp/src/jaegertracing/reporters/InMemoryReporter.h

   1 /*
   2  * Copyright (c) 2017 Uber Technologies, Inc.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #ifndef JAEGERTRACING_REPORTERS_INMEMORYREPORTER_H
  18 #define JAEGERTRACING_REPORTERS_INMEMORYREPORTER_H
  19
  20 #include <mutex>
  21 #include <vector>
  22
  23 #include "jaegertracing/Span.h"
  24 #include "jaegertracing/reporters/Reporter.h"
  25
  26 namespace jaegertracing {
  27 namespace reporters {
  28
  29 class InMemoryReporter : public Reporter {
  30   public:
  31     InMemoryReporter()
  32         : _spans()
  33         , _mutex()
  34     {
  35         constexpr auto kInitialCapacity = 10;
  36         _spans.reserve(kInitialCapacity);
  37     }
  38
  39     void report(const Span& span) noexcept override
  40     {
  41         std::lock_guard<std::mutex> lock(_mutex);
  42         _spans.push_back(span);
  43     }
  44
  45     void close() noexcept override {}
  46
  47     int spansSubmitted() const noexcept
  48     {
  49         std::lock_guard<std::mutex> lock(_mutex);
  50         return _spans.size();
  51     }
  52
  53     std::vector<Span> spans() const noexcept
  54     {
  55         std::lock_guard<std::mutex> lock(_mutex);
  56         return _spans;
  57     }
  58
  59     void reset() noexcept
  60     {
  61         std::lock_guard<std::mutex> lock(_mutex);
  62         _spans.clear();
  63     }
  64
  65   private:
  66     std::vector<Span> _spans;
  67     mutable std::mutex _mutex;
  68 };
  69
  70 }  // namespace reporters
  71 }  // namespace jaegertracing
  72
  73 #endif  // JAEGERTRACING_REPORTERS_INMEMORYREPORTER_H