diff --git a/.clang-format b/.clang-format deleted file mode 100644 index a85545463..000000000 --- a/.clang-format +++ /dev/null @@ -1,51 +0,0 @@ -BasedOnStyle: Google -AccessModifierOffset: -1 -AlignEscapedNewlinesLeft: true -AlignTrailingComments: true -AllowAllParametersOfDeclarationOnNextLine: false -AllowShortFunctionsOnASingleLine: true -AllowShortIfStatementsOnASingleLine: false -AllowShortLoopsOnASingleLine: false -#AlwaysBreakBeforeMultilineStrings: true -AlwaysBreakTemplateDeclarations: true -BinPackParameters: true -BreakBeforeBinaryOperators: false -BreakBeforeBraces: Linux -BreakBeforeTernaryOperators: true -BreakConstructorInitializersBeforeComma: false -ColumnLimit: 0 -CommentPragmas: '^ IWYU pragma:' -ConstructorInitializerAllOnOneLineOrOnePerLine: true -ConstructorInitializerIndentWidth: 2 -ContinuationIndentWidth: 2 -Cpp11BracedListStyle: true -DerivePointerBinding: false -ExperimentalAutoDetectBinPacking: false -IndentCaseLabels: true -IndentFunctionDeclarationAfterType: true -IndentWidth: 2 -# It is broken on windows. Breaks all #include "header.h" -Language: Cpp -MaxEmptyLinesToKeep: 1 -KeepEmptyLinesAtTheStartOfBlocks: true -NamespaceIndentation: None -ObjCSpaceAfterProperty: false -ObjCSpaceBeforeProtocolList: false -PenaltyBreakBeforeFirstCallParameter: 1 -PenaltyBreakComment: 300 -PenaltyBreakFirstLessLess: 120 -PenaltyBreakString: 1000 -PenaltyExcessCharacter: 1000000 -PenaltyReturnTypeOnItsOwnLine: 200 -SortIncludes: false -SpaceBeforeAssignmentOperators: true -SpaceBeforeParens: ControlStatements -SpaceInEmptyParentheses: false -SpacesBeforeTrailingComments: 1 -SpacesInAngles: false -SpacesInContainerLiterals: true -SpacesInCStyleCastParentheses: false -SpacesInParentheses: false -Standard: Cpp11 -TabWidth: 2 -UseTab: Never diff --git a/.codecov.yml b/.codecov.yml deleted file mode 100644 index 2e3fe02be..000000000 --- a/.codecov.yml +++ /dev/null @@ -1,20 +0,0 @@ -codecov: - notify: - after_n_builds: 1 - -coverage: - precision: 2 - round: nearest - range: 60...90 - status: - project: true - patch: true - changes: false - -ignore: - - docs/* - - test/* - - src/Transports/* - - examples/* - -comment: false diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml deleted file mode 100644 index b2730031e..000000000 --- a/.github/workflows/build.yml +++ /dev/null @@ -1,73 +0,0 @@ -name: Build and test - -on: [pull_request] - -jobs: - ubuntu: - runs-on: ubuntu-latest - steps: - - uses: actions/checkout@v2 - - name: Install boost, curl and lcov - run: | - sudo apt-get update - sudo apt-get install -yq libcurl4-openssl-dev libboost-system1.74-dev libboost-test1.74-dev libboost-program-options1.74-dev lcov - - name: Run CMake - run: mkdir build && cd build && cmake .. -DCMAKE_BUILD_TYPE=Debug - - name: Build project - run: cd build && make -j - - name: Test - run: cd build && ctest --output-on-failure - - name: Generate codecov report - run: | - cd build - set -x - lcov --directory . --capture --output-file coverage.info - lcov --remove coverage.info '/opt/*' '/usr/*' --output-file coverage.info - lcov --list coverage.info - - uses: codecov/codecov-action@v1 - with: - token: ${{ secrets.CODECOV_TOKEN }} - file: build/coverage.info - fail_ci_if_error: true - macos: - runs-on: macos-latest - steps: - - uses: actions/checkout@v2 - - name: Install boost - run: brew install boost - - name: Run CMake - run: mkdir build && cd build && cmake .. - - name: Build project - run: cd build && make -j - - name: Test - run: cd build && ctest --output-on-failure - alma9: - runs-on: [self-hosted, alma9] - steps: - - uses: actions/checkout@v2 - - name: CMake - run: mkdir build && cd build && source /opt/rh/gcc-toolset-12/enable && cmake .. - - name: Build - run: cd build && make -j 2 - - name: Test - run: cd build && ctest --output-on-failure - cs8: - runs-on: [self-hosted, cs8] - steps: - - uses: actions/checkout@v2 - - name: CMake - run: mkdir build && cd build && source /opt/rh/gcc-toolset-12/enable && cmake .. - - name: Build - run: cd build && make -j 2 - - name: Test - run: cd build && ctest --output-on-failure - cc7: - runs-on: [self-hosted, cc7] - steps: - - uses: actions/checkout@v2 - - name: CMake - run: mkdir build && cd build && source /opt/rh/devtoolset-9/enable && cmake3 .. - - name: Build - run: cd build && make -j 2 - - name: Test - run: cd build && ctest3 --output-on-failure diff --git a/.github/workflows/format.yml b/.github/workflows/format.yml deleted file mode 100644 index 5892d25c8..000000000 --- a/.github/workflows/format.yml +++ /dev/null @@ -1,33 +0,0 @@ -name: Clang format - -on: [pull_request] - -jobs: - clang-format: - runs-on: ubuntu-latest - steps: - - uses: actions/checkout@v2 - with: - ref: ${{ github.event.pull_request.head.sha }} - - - name: Install prerequisites - run: | - sudo update-alternatives --install /usr/bin/clang-format clang-format /usr/bin/clang-format-11 100 - sudo update-alternatives --install /usr/bin/git-clang-format git-clang-format /usr/bin/git-clang-format-11 100 - - - name: Run clang-format on changed files - run: | - set -x - git fetch origin ${{ github.event.pull_request.base.ref }} - base_commit=$(git rev-parse ${{ github.event.pull_request.base.sha }}) - result_output=$(git diff --diff-filter d --name-only "$base_commit" | - xargs -d '\n' git-clang-format --commit "$base_commit" --diff --style file) - if [ "$result_output" = 'no modified files to format' ] || - [ "$result_output" = 'clang-format did not modify any files' ] - then - exit 0 - else - git-clang-format --commit "$base_commit" --diff --style file - echo "$result_output" - exit 1 - fi diff --git a/.github/workflows/release.yml b/.github/workflows/release.yml deleted file mode 100644 index 214a3cae9..000000000 --- a/.github/workflows/release.yml +++ /dev/null @@ -1,27 +0,0 @@ -name: Release - -on: - release: - types: [published] - -jobs: - alidist: - runs-on: ubuntu-latest - steps: - - uses: actions/checkout@v2 - with: - repository: 'alisw/alidist' - - name: Change version in recipe - run: | - set +x - CURRENT_VERSION=`cat monitoring.sh | grep "tag:" | awk '{print $2}'` - sed -i "s/${CURRENT_VERSION}/${{ github.event.release.tag_name }}/g" monitoring.sh - - name: Create PR in alidist - uses: peter-evans/create-pull-request@v3 - with: - token: ${{ secrets.PAT }} - commit-message: Bump monitoring - author: ${{ github.actor }} <${{ github.actor }}@users.noreply.github.com> - branch: monitoring-${{ github.event.release.tag_name }} - body: Auto-generated PR for the following release ${{ github.event.release.html_url }} - title: Bump monitoring to ${{ github.event.release.tag_name }} diff --git a/.gitignore b/.gitignore deleted file mode 100644 index 949fb5640..000000000 --- a/.gitignore +++ /dev/null @@ -1,7 +0,0 @@ -/build/ -.project -.cproject -*~ -.idea -examples/config.ini -/cmake-build-debug/ diff --git a/1-Basic_8cxx.html b/1-Basic_8cxx.html new file mode 100644 index 000000000..8d9bdf511 --- /dev/null +++ b/1-Basic_8cxx.html @@ -0,0 +1,144 @@ + + +
+ + + +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"+Functions | |
| +int | main () |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"+Typedefs | |
| +using | Monitoring = o2::monitoring::MonitoringFactory |
+Functions | |
| +int | main () |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"+Functions | |
| int | main () |
| int main | +( | +) | ++ |
Add global tags
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"+Functions | |
| +int | main () |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"#include <boost/program_options.hpp>#include <random>+Functions | |
| +int | main (int argc, char *argv[]) |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"+Typedefs | |
| +using | Monitoring = o2::monitoring::MonitoringFactory |
| +using | DerivedMetricMode = o2::monitoring::DerivedMetricMode |
+Functions | |
| +int | main () |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"#include <boost/program_options.hpp>#include <random>+Functions | |
| +int | main (int argc, char *argv[]) |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "ApMonBackend.h"#include <iostream>#include <sstream>#include "../MonLogger.h"#include "../Exceptions/MonitoringException.h"+Classes | |
| struct | o2::monitoring::backends::overloaded< Ts > |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::backends | |
| Monitoring backends. | |
+Functions | |
| +template<class... Ts> | |
| o2::monitoring::backends::overloaded (Ts...) -> overloaded< Ts... > | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/Backend.h"#include <ApMon.h>#include <string>#include <chrono>#include <memory>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::backends::ApMonBackend |
| Backend that uses AppMon (MonALISA) More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::backends | |
| Monitoring backends. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Go to the source code of this file.
++Classes | |
| class | o2::monitoring::Backend |
| Backend pure virtual interface. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/DerivedMetrics.h"#include "Exceptions/MonitoringException.h"#include <chrono>#include <iostream>#include <map>#include <memory>#include <string>#include <vector>#include "VariantVisitorAdd.h"#include "VariantVisitorRate.h"+Classes | |
| struct | overloaded< Ts > |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
+Functions | |
| +template<class... Ts> | |
| overloaded (Ts...) -> overloaded< Ts... > | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <unordered_map>#include <memory>#include <string>#include <vector>#include "Monitoring/Metric.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::DerivedMetrics |
| Enables Calculation of derived metrics. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
+Enumerations | |
| enum | o2::monitoring::DerivedMetricMode { RATE, +INCREMENT, +NONE + } |
| Available derived metric modes. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "HTTP.h"#include "../MonLogger.h"#include "../Exceptions/MonitoringException.h"#include <boost/algorithm/string.hpp>+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::HTTP |
| HTTP POST transport. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "InfluxDB.h"#include <sstream>#include <string>#include <variant>#include <boost/algorithm/string/replace.hpp>#include "../Exceptions/MonitoringException.h"+Classes | |
| struct | o2::monitoring::backends::overloaded< Ts > |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::backends | |
| Monitoring backends. | |
+Functions | |
| +template<class... Ts> | |
| o2::monitoring::backends::overloaded (Ts...) -> overloaded< Ts... > | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/Backend.h"#include "../Transports/TransportInterface.h"#include "../MonLogger.h"#include <chrono>#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::backends::InfluxDB |
| Backend that sends metrics to InfluxDB time-series databse. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::backends | |
| Monitoring backends. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "TransportInterface.h"#include <boost/array.hpp>#include <boost/asio.hpp>#include <boost/algorithm/string.hpp>#include <chrono>#include <string>#include <librdkafka/rdkafkacpp.h>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::Kafka |
| Transport that sends string formatted metrics via Kafka. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <string>#include <chrono>#include <map>#include <regex>#include <variant>#include <vector>#include "Tags.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::Metric |
| Represents a metric including value, type of the value, name, timestamp and tags. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
+Enumerations | |
| enum | o2::monitoring::Verbosity : short { Prod, +Info, +Debug + } |
| Metric and Backedn verbosity. | |
| enum | o2::monitoring::MetricType { INT = 0, +STRING = 1, +DOUBLE = 2, +UINT64_T = 3 + } |
| Metric types. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <chrono>#include <iomanip>#include <iostream>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::MonLogger |
| Simple Monitoring logging class. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
+Enumerations | |
| enum | o2::monitoring::Severity { Error = 31, +Warn = 33, +Info = 49 + } |
| List of possible log severities. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <exception>#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::MonitoringException |
| Internal monitoring exception. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/MonitoringFactory.h"#include <functional>#include <stdexcept>#include <boost/algorithm/string.hpp>#include "MonLogger.h"#include "UriParser/UriParser.h"#include "Backends/StdOut.h"#include "Backends/Noop.h"#include "Backends/InfluxDB.h"#include "Transports/UDP.h"#include "Transports/Unix.h"#include "Transports/StdOut.h"+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
+Functions | |
| +std::unique_ptr< Backend > | o2::monitoring::getStdOut (http::url uri) |
| std::unique_ptr< Backend > | o2::monitoring::getInfluxDbv2 (http::url uri) |
| +std::unique_ptr< Backend > | o2::monitoring::getInfluxDb (http::url uri) |
| +std::unique_ptr< Backend > | o2::monitoring::getApMon (http::url) |
| +std::unique_ptr< Backend > | o2::monitoring::getNoop (http::url) |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/Monitoring.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::MonitoringFactory |
| Monitoring and monitoring backends factory. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/Monitoring.h"#include "Exceptions/MonitoringException.h"#include <boost/lexical_cast.hpp>#include <chrono>#include <iostream>#include <memory>#include <string>#include <utility>#include <vector>#include "MonLogger.h"#include "ProcessDetails.h"+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <atomic>#include <chrono>#include <map>#include <memory>#include <string>#include <thread>#include <tuple>#include <unordered_map>#include <vector>#include <deque>#include "Monitoring/Backend.h"#include "Monitoring/DerivedMetrics.h"#include "Monitoring/ProcessMonitor.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::Monitoring |
| Main class that collects metrics from user and dispatches them to selected monitoring backends. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/Backend.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::backends::Noop |
| No-op backend. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::backends | |
| Monitoring backends. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::ProcessDetails |
| Collects process and machine related details such as PID, process name, hostname. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "Monitoring/ProcessMonitor.h"#include "MonLogger.h"#include <boost/algorithm/string/classification.hpp>#include <chrono>#include <sstream>#include <cmath>#include <fstream>#include <utility>#include <numeric>+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <atomic>#include <boost/algorithm/string.hpp>#include <iostream>#include <string>#include <vector>#include <sys/resource.h>#include "Monitoring/Metric.h"Go to the source code of this file.
++Classes | |
| class | o2::monitoring::ProcessMonitor |
| Monitors current process and/or other processes running at the same machien. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "TCP.h"#include <string>#include <iostream>#include "Exceptions/MonitoringException.h"#include "../MonLogger.h"+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "TransportInterface.h"#include <boost/array.hpp>#include <boost/asio.hpp>#include <boost/algorithm/string.hpp>#include <chrono>#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::TCP |
| Transport that sends string formatted metrics via TCP. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <string>Go to the source code of this file.
++Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::TransportInterface |
| Transport interface for backends. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "TransportInterface.h"#include <boost/array.hpp>#include <boost/asio.hpp>#include <boost/algorithm/string.hpp>#include <chrono>#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::UDP |
| Transport that sends string formatted metrics via UDP. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
#include "TransportInterface.h"#include <boost/array.hpp>#include <boost/asio.hpp>#include <boost/algorithm/string.hpp>#include <chrono>#include <string>Go to the source code of this file.
++Classes | |
| class | o2::monitoring::transports::Unix |
| Transport that sends string formatted metrics via Unix datagram socket. More... | |
+Namespaces | |
| o2::monitoring | |
| ALICE O2 Monitoring system. | |
| o2::monitoring::transports | |
| Monitoring transports. | |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| ▼Nhttp | |
| Curl | |
| ▼No2 | |
| ▼Nmonitoring | ALICE O2 Monitoring system |
| ▼Nbackends | Monitoring backends |
| CApMonBackend | Backend that uses AppMon (MonALISA) |
| CInfluxDB | Backend that sends metrics to InfluxDB time-series databse |
| CNoop | No-op backend |
| Coverloaded | |
| CStdOut | Prints metrics to standard output via std::cout |
| ▼Ntransports | Monitoring transports |
| CHTTP | HTTP POST transport |
| CKafka | Transport that sends string formatted metrics via Kafka |
| CStdOut | Transport that sends string formatted metrics via StdOut |
| CTCP | Transport that sends string formatted metrics via TCP |
| CTransportInterface | Transport interface for backends |
| CUDP | Transport that sends string formatted metrics via UDP |
| CUnix | Transport that sends string formatted metrics via Unix datagram socket |
| CBackend | Backend pure virtual interface |
| CDerivedMetrics | Enables Calculation of derived metrics |
| CMetric | Represents a metric including value, type of the value, name, timestamp and tags |
| CMonitoring | Main class that collects metrics from user and dispatches them to selected monitoring backends |
| CMonitoringException | Internal monitoring exception |
| CMonitoringFactory | Monitoring and monitoring backends factory |
| CMonLogger | Simple Monitoring logging class |
| CProcessDetails | Collects process and machine related details such as PID, process name, hostname |
| CProcessMonitor | Monitors current process and/or other processes running at the same machien |
| CVariantVisitorAdd | Adds boost variants |
| CVariantVisitorRate | Subtracts boost variants in order to calculate rate |
| Coverloaded |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
|
| MonitoringFactory (o2::monitoring) | StdOut (o2::monitoring::backends) | VariantVisitorRate (o2::monitoring) | |||
| MonLogger (o2::monitoring) |
|
| |||||
| ApMonBackend (o2::monitoring::backends) | InfluxDB (o2::monitoring::backends) |
| |||||
|
| TCP (o2::monitoring::transports) | overloaded | ||||
| Noop (o2::monitoring::backends) | TransportInterface (o2::monitoring::transports) | overloaded (o2::monitoring::backends) | |||||
| Backend (o2::monitoring) | Kafka (o2::monitoring::transports) |
|
|
| |||
|
| ||||||
| ProcessDetails (o2::monitoring) | UDP (o2::monitoring::transports) | url (http) | |||||
| DerivedMetrics (o2::monitoring) | Metric (o2::monitoring) | ProcessMonitor (o2::monitoring) | Unix (o2::monitoring::transports) | ||||
| Monitoring (o2::monitoring) |
|
| ||||
| MonitoringException (o2::monitoring) | |||||||
| HTTP (o2::monitoring::transports) | StdOut (o2::monitoring::transports) | VariantVisitorAdd (o2::monitoring) | |||||
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::Backend, including all inherited members.
+| addGlobalTag(std::string_view name, std::string_view value)=0 | o2::monitoring::Backend | pure virtual |
| Backend() | o2::monitoring::Backend | inline |
| getVerbosity() | o2::monitoring::Backend | inline |
| send(const Metric &metric)=0 | o2::monitoring::Backend | pure virtual |
| send(std::vector< Metric > &&metrics)=0 | o2::monitoring::Backend | pure virtual |
| setVerbosisty(Verbosity level) | o2::monitoring::Backend | inline |
| ~Backend()=default | o2::monitoring::Backend | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Backend pure virtual interface. + More...
+ +#include <Backend.h>
+Public Member Functions | |
| + | Backend () |
| Default constructor. | |
| +virtual | ~Backend ()=default |
| Default destructor. | |
| +void | setVerbosisty (Verbosity level) |
| Set verbosity level. | |
| +Verbosity | getVerbosity () |
| Get verbosity level. | |
| +virtual void | send (const Metric &metric)=0 |
| Sends metric via backend. | |
| +virtual void | send (std::vector< Metric > &&metrics)=0 |
| Sends multiple metrics not related to each other. | |
| +virtual void | addGlobalTag (std::string_view name, std::string_view value)=0 |
| Sets a tag. | |
Backend pure virtual interface.
+Interface that allows to send a metric to remote backend. In addition, default tagset (for all handled metrics) can be created.
+![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::DerivedMetrics, including all inherited members.
+| DerivedMetrics()=default | o2::monitoring::DerivedMetrics | |
| mStorage | o2::monitoring::DerivedMetrics | |
| process(Metric &metric, DerivedMetricMode mode) | o2::monitoring::DerivedMetrics | |
| ~DerivedMetrics()=default | o2::monitoring::DerivedMetrics |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Enables Calculation of derived metrics. + More...
+ +#include <DerivedMetrics.h>
+Public Member Functions | |
| + | DerivedMetrics ()=default |
| Default constructor. | |
| + | ~DerivedMetrics ()=default |
| Default destructor. | |
| void | process (Metric &metric, DerivedMetricMode mode) |
+Public Attributes | |
| +std::unordered_map< std::string, Metric > | mStorage |
| Metrics store necessary for derived metrics. | |
Enables Calculation of derived metrics.
+Calculates derived metrics such as rate or increment values... (available modes are enumerated in DerivedMetricMode class) For this purpose metrics are stored in a container.
+| void o2::monitoring::DerivedMetrics::process | +( | +Metric & | +metric, | +
| + | + | DerivedMetricMode | +mode | +
| + | ) | ++ |
Entry method to DerivedMetrics Switches over processing modes: rate and increment
+create pseudo unique key
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::Metric, including all inherited members.
+| addTag(tags::Key key, tags::Value value) | o2::monitoring::Metric | |
| addTag(tags::Key key, unsigned short int number) | o2::monitoring::Metric | |
| addValue(int value, const std::string &name) | o2::monitoring::Metric | |
| addValue(double value, const std::string &name) | o2::monitoring::Metric | |
| addValue(uint64_t value, const std::string &name) | o2::monitoring::Metric | |
| addValue(std::string value, const std::string &name) | o2::monitoring::Metric | |
| addValue(const std::variant< int, std::string, double, uint64_t > &value, const std::string &name) | o2::monitoring::Metric | |
| DefaultVerbosity | o2::monitoring::Metric | static |
| getCurrentTimestamp() -> decltype(std::chrono::system_clock::now()) | o2::monitoring::Metric | static |
| getFirstValue() const | o2::monitoring::Metric | |
| getFirstValueType() const | o2::monitoring::Metric | |
| getName() const | o2::monitoring::Metric | |
| getTags() const | o2::monitoring::Metric | |
| getTimestamp() const | o2::monitoring::Metric | |
| getValues() const | o2::monitoring::Metric | |
| getValuesSize() const noexcept | o2::monitoring::Metric | |
| getVerbosity() | o2::monitoring::Metric | |
| includeTimestamp | o2::monitoring::Metric | static |
| mDefaultValueName | o2::monitoring::Metric | protectedstatic |
| Metric(int value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | o2::monitoring::Metric | |
| Metric(std::string value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | o2::monitoring::Metric | |
| Metric(double value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | o2::monitoring::Metric | |
| Metric(uint64_t value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | o2::monitoring::Metric | |
| Metric(const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity, const std::chrono::time_point< std::chrono::system_clock > ×tamp=Metric::getCurrentTimestamp()) | o2::monitoring::Metric | |
| mName | o2::monitoring::Metric | protected |
| mRegexPolicy | o2::monitoring::Metric | protectedstatic |
| mTags | o2::monitoring::Metric | protected |
| mTimestamp | o2::monitoring::Metric | protected |
| mValues | o2::monitoring::Metric | protected |
| mVerbosity | o2::monitoring::Metric | protected |
| o2::monitoring::DerivedMetrics class | o2::monitoring::Metric | friend |
| overwriteVerbosity() | o2::monitoring::Metric | protected |
| setDefaultVerbosity(Verbosity verbosity) | o2::monitoring::Metric | static |
| setTags(std::vector< std::pair< int, int >> &&tags) | o2::monitoring::Metric | protected |
| setVerbosityPolicy(Verbosity verbosity, const std::regex ®ex) | o2::monitoring::Metric | static |
| ~Metric()=default | o2::monitoring::Metric |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Represents a metric including value, type of the value, name, timestamp and tags. + More...
+ +#include <Metric.h>
+Public Member Functions | |
| Metric (int value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | |
| Metric (std::string value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | |
| Metric (double value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | |
| Metric (uint64_t value, const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity) | |
| Metric (const std::string &name, Verbosity verbosity=Metric::DefaultVerbosity, const std::chrono::time_point< std::chrono::system_clock > ×tamp=Metric::getCurrentTimestamp()) | |
| Metric && | addValue (int value, const std::string &name) |
| Metric && | addValue (double value, const std::string &name) |
| Metric && | addValue (uint64_t value, const std::string &name) |
| Metric && | addValue (std::string value, const std::string &name) |
| Metric && | addValue (const std::variant< int, std::string, double, uint64_t > &value, const std::string &name) |
| + | ~Metric ()=default |
| Default destructor. | |
| const std::string & | getName () const |
| std::chrono::time_point< std::chrono::system_clock > | getTimestamp () const |
| const std::vector< std::pair< std::string, std::variant< int, std::string, double, uint64_t > > > & | getValues () const |
| const std::pair< std::string, std::variant< int, std::string, double, uint64_t > > & | getFirstValue () const |
| +std::size_t | getValuesSize () const noexcept |
| Values vector size getter. | |
| const std::vector< std::pair< int, int > > & | getTags () const |
| Metric && | addTag (tags::Key key, tags::Value value) |
| Metric && | addTag (tags::Key key, unsigned short int number) |
| +Verbosity | getVerbosity () |
| Verbosity getter. | |
| +int | getFirstValueType () const |
| This is required for backward compability with boost::variant and old StdOut format. | |
+Static Public Member Functions | |
| static auto | getCurrentTimestamp () -> decltype(std::chrono::system_clock::now()) |
| +static void | setDefaultVerbosity (Verbosity verbosity) |
| Sets default verbosity of metrics. | |
| +static void | setVerbosityPolicy (Verbosity verbosity, const std::regex ®ex) |
| Regex policy setter. | |
+Static Public Attributes | |
| +static Verbosity | DefaultVerbosity = Verbosity::Info |
| Default metric verbosity. | |
| +static bool | includeTimestamp = true |
| Whether timestamp should be included or not. | |
+Protected Member Functions | |
| +Metric && | setTags (std::vector< std::pair< int, int >> &&tags) |
| Set full vector of tags. | |
| +void | overwriteVerbosity () |
| Overwirte verbosity using regex policy. | |
+Protected Attributes | |
| +std::vector< std::pair< std::string, std::variant< int, std::string, double, uint64_t > > > | mValues |
| Metric values. | |
| +std::string | mName |
| Metric name. | |
| +std::chrono::time_point< std::chrono::system_clock > | mTimestamp |
| Metric timestamp. | |
| +std::vector< std::pair< int, int > > | mTags |
| Metric tags. | |
| +Verbosity | mVerbosity |
| Metric verbosity. | |
+Static Protected Attributes | |
| +static std::map< std::underlying_type< Verbosity >::type, std::regex > | mRegexPolicy |
| Regex policy map. | |
| +static constexpr char | mDefaultValueName [] = "value" |
| Default value name. | |
+Friends | |
| +class | o2::monitoring::DerivedMetrics |
| Allow DerivedMetrics access to setTags. | |
Represents a metric including value, type of the value, name, timestamp and tags.
+| o2::monitoring::Metric::Metric | +( | +int | +value, | +
| + | + | const std::string & | +name, | +
| + | + | Verbosity | +verbosity = Metric::DefaultVerbosity |
+
| + | ) | ++ |
Integer metric construtor
| value | metric value (int) |
| name | metric name |
| o2::monitoring::Metric::Metric | +( | +std::string | +value, | +
| + | + | const std::string & | +name, | +
| + | + | Verbosity | +verbosity = Metric::DefaultVerbosity |
+
| + | ) | ++ |
String metric construtor
| value | metric value (string) |
| name | the metric name |
| o2::monitoring::Metric::Metric | +( | +double | +value, | +
| + | + | const std::string & | +name, | +
| + | + | Verbosity | +verbosity = Metric::DefaultVerbosity |
+
| + | ) | ++ |
Double metric constructor
| value | metric value (double) |
| name | metric name |
| o2::monitoring::Metric::Metric | +( | +uint64_t | +value, | +
| + | + | const std::string & | +name, | +
| + | + | Verbosity | +verbosity = Metric::DefaultVerbosity |
+
| + | ) | ++ |
uint64_t metric constructor
| value | metric value (uint64_t) |
| name | metric name |
| o2::monitoring::Metric::Metric | +( | +const std::string & | +name, | +
| + | + | Verbosity | +verbosity = Metric::DefaultVerbosity, |
+
| + | + | const std::chrono::time_point< std::chrono::system_clock > & | +timestamp = Metric::getCurrentTimestamp() |
+
| + | ) | ++ |
Constructor that does not require any value to be specified, .addValue needs to be used
| name | metric name |
| Metric && o2::monitoring::Metric::addTag | +( | +tags::Key | +key, | +
| + | + | tags::Value | +value | +
| + | ) | ++ |
Add user defined tags
| key | enum tag key |
| value | emum tag value |
| Metric&& o2::monitoring::Metric::addTag | +( | +tags::Key | +key, | +
| + | + | unsigned short int | +number | +
| + | ) | ++ |
Add user defined tags
| key | enum tag key |
| value | numeric value |
| Metric && o2::monitoring::Metric::addValue | +( | +int | +value, | +
| + | + | const std::string & | +name | +
| + | ) | ++ |
Adds additional int value to metric
| value | |
| name |
| Metric && o2::monitoring::Metric::addValue | +( | +double | +value, | +
| + | + | const std::string & | +name | +
| + | ) | ++ |
Adds additional double value to metric
| value | |
| name |
| Metric && o2::monitoring::Metric::addValue | +( | +uint64_t | +value, | +
| + | + | const std::string & | +name | +
| + | ) | ++ |
Adds additional uint64_t value to metric
| value | |
| name |
| Metric && o2::monitoring::Metric::addValue | +( | +std::string | +value, | +
| + | + | const std::string & | +name | +
| + | ) | ++ |
Adds additional string value to metric
| value | |
| name |
| Metric && o2::monitoring::Metric::addValue | +( | +const std::variant< int, std::string, double, uint64_t > & | +value, | +
| + | + | const std::string & | +name | +
| + | ) | ++ |
Adds additional variant value to metric
| value | |
| name |
+
|
+ +static | +
Generetes current timestamp return timestamp as std::chrono::system_clock
+ +| const std::pair< std::string, std::variant< int, std::string, double, uint64_t > > & o2::monitoring::Metric::getFirstValue | +( | +) | +const | +
First value getter
| const std::string & o2::monitoring::Metric::getName | +( | +) | +const | +
Name getter
| const std::vector< std::pair< int, int > > & o2::monitoring::Metric::getTags | +( | +) | +const | +
Tag list getter
| std::chrono::time_point< std::chrono::system_clock > o2::monitoring::Metric::getTimestamp | +( | +) | +const | +
Timestamp getter
| const std::vector< std::pair< std::string, std::variant< int, std::string, double, uint64_t > > > & o2::monitoring::Metric::getValues | +( | +) | +const | +
Values getter
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::MonLogger, including all inherited members.
+| End() -> decltype("\033[0m\n") | o2::monitoring::MonLogger | inlinestatic |
| Get(Severity severity=Severity::Info) | o2::monitoring::MonLogger | inlinestatic |
| operator<<(const T &log) | o2::monitoring::MonLogger | inline |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Simple Monitoring logging class. + More...
+ +#include <MonLogger.h>
+Public Member Functions | |
| template<typename T > | |
| MonLogger & | operator<< (const T &log) |
+Static Public Member Functions | |
| static MonLogger & | Get (Severity severity=Severity::Info) |
| static auto | End () -> decltype("\033[0m\n") |
Simple Monitoring logging class.
+
+
|
+ +inlinestatic | +
Terminates log line return - string with color termination and new line
+ +
+
|
+ +inlinestatic | +
Singleton Returns Logger instance with current date and given severity
| severity | - severity level |
+
|
+ +inline | +
Appends value/message to the log
| log | - message |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::Monitoring, including all inherited members.
+| addBackend(std::unique_ptr< Backend > backend) | o2::monitoring::Monitoring | |
| addGlobalTag(std::string_view name, std::string_view value) | o2::monitoring::Monitoring | |
| addGlobalTag(tags::Key key, tags::Value value) | o2::monitoring::Monitoring | |
| enableBuffering(const std::size_t size=128) | o2::monitoring::Monitoring | |
| enableProcessMonitoring(const unsigned int interval=5) | o2::monitoring::Monitoring | |
| flushBuffer() | o2::monitoring::Monitoring | |
| Monitoring(const Monitoring &)=delete | o2::monitoring::Monitoring | |
| Monitoring() | o2::monitoring::Monitoring | |
| operator=(const Monitoring &)=delete | o2::monitoring::Monitoring | |
| send(Metric &&metric, DerivedMetricMode mode=DerivedMetricMode::NONE) | o2::monitoring::Monitoring | |
| ~Monitoring() | o2::monitoring::Monitoring |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Main class that collects metrics from user and dispatches them to selected monitoring backends. + More...
+ +#include <Monitoring.h>
+Public Member Functions | |
| +Monitoring & | operator= (const Monitoring &)=delete |
| Disable copy constructor. | |
| + | Monitoring (const Monitoring &)=delete |
| Disable copy constructor. | |
| + | Monitoring () |
| Instantiates derived metrics processor (see DerivedMetrics) and process monitor (seeProcessMonitor). | |
| +void | addBackend (std::unique_ptr< Backend > backend) |
| Creates and appends backend to the backend list. | |
| + | ~Monitoring () |
| Joins process monitor thread if possible. | |
| void | send (Metric &&metric, DerivedMetricMode mode=DerivedMetricMode::NONE) |
| void | enableProcessMonitoring (const unsigned int interval=5) |
| +void | flushBuffer () |
| Flushes metric buffer (this can also happen when buffer is full) | |
| void | enableBuffering (const std::size_t size=128) |
| void | addGlobalTag (std::string_view name, std::string_view value) |
| void | addGlobalTag (tags::Key key, tags::Value value) |
Main class that collects metrics from user and dispatches them to selected monitoring backends.
+Collects user-defined metrics (seeMetric class) and pushes them through all selected backends (seeBackend). Calculates derived metrics such as rate and increment value (seeDerivedMetrics class). Adds default tags to each metric: proces name, hostname (seeProcessDetails class) Monitors the process itself - including memory, cpu and network usage (seeProcessMonitor class).
+| void o2::monitoring::Monitoring::addGlobalTag | +( | +std::string_view | +name, | +
| + | + | std::string_view | +value | +
| + | ) | ++ |
Adds global tag
| name | tag name |
| value | tag value |
| void o2::monitoring::Monitoring::addGlobalTag | +( | +tags::Key | +key, | +
| + | + | tags::Value | +value | +
| + | ) | ++ |
Adds global tag
| name | tag name |
| value | tag value |
| void o2::monitoring::Monitoring::enableBuffering | +( | +const std::size_t | +size = 128 | ) | ++ |
Enables metric buffering
| size | buffer size |
| void o2::monitoring::Monitoring::enableProcessMonitoring | +( | +const unsigned int | +interval = 5 | ) | ++ |
Enables process monitoring
| interval | refresh interval |
| void o2::monitoring::Monitoring::send | +( | +Metric && | +metric, | +
| + | + | DerivedMetricMode | +mode = DerivedMetricMode::NONE |
+
| + | ) | ++ |
Sends a metric to all avaliabes backends If DerivedMetricMode is specified it generates and sends derived metric
| metric | r-value to metric object |
| mode | Derived metric mode |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::MonitoringException, including all inherited members.
+| MonitoringException(const std::string &source, const std::string &message) (defined in o2::monitoring::MonitoringException) | o2::monitoring::MonitoringException | |
| MonitoringException(int code, const std::string &source, const std::string &message) (defined in o2::monitoring::MonitoringException) | o2::monitoring::MonitoringException | |
| what() const (defined in o2::monitoring::MonitoringException) | o2::monitoring::MonitoringException | |
| ~MonitoringException()=default (defined in o2::monitoring::MonitoringException) | o2::monitoring::MonitoringException |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Internal monitoring exception. + More...
+ +#include <MonitoringException.h>
Internal monitoring exception.
+![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::MonitoringFactory, including all inherited members.
+| Get(std::string urlsString) noexcept(false) | o2::monitoring::MonitoringFactory | static |
| GetBackend(std::string &url) | o2::monitoring::MonitoringFactory | static |
| MonitoringFactory(const MonitoringFactory &)=delete (defined in o2::monitoring::MonitoringFactory) | o2::monitoring::MonitoringFactory | |
| operator=(const MonitoringFactory &)=delete | o2::monitoring::MonitoringFactory |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Monitoring and monitoring backends factory. + More...
+ +#include <MonitoringFactory.h>
+Public Member Functions | |
| +MonitoringFactory & | operator= (const MonitoringFactory &)=delete |
| Disables copy constructor. | |
| + | MonitoringFactory (const MonitoringFactory &)=delete |
+Static Public Member Functions | |
| static std::unique_ptr< Monitoring > | Get (std::string urlsString) noexcept(false) |
| static std::unique_ptr< Backend > | GetBackend (std::string &url) |
Monitoring and monitoring backends factory.
+
+
|
+ +staticnoexcept | +
Provides single instance on Monitoring Monitoring (singleton)
| MonitoringException | when backend initialisation failed |
+
|
+ +static | +
Provides a Monitoring backend based on the URL
| MonitoringException | when backend initialisation failed |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::ProcessDetails, including all inherited members.
+| getHostname() const | o2::monitoring::ProcessDetails | |
| getPid() const | o2::monitoring::ProcessDetails | |
| getProcessName() const | o2::monitoring::ProcessDetails | |
| ProcessDetails() | o2::monitoring::ProcessDetails |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Collects process and machine related details such as PID, process name, hostname. + More...
+ +#include <ProcessDetails.h>
+Public Member Functions | |
| + | ProcessDetails () |
| Generates all data. | |
| +unsigned int | getPid () const |
| PID getter. | |
| +std::string | getProcessName () const |
| Process name getter. | |
| +std::string | getHostname () const |
| Hostname getter. | |
Collects process and machine related details such as PID, process name, hostname.
+![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::ProcessMonitor, including all inherited members.
+![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Monitors current process and/or other processes running at the same machien. + More...
+ +#include <ProcessMonitor.h>
+Public Member Functions | |
| +std::vector< Metric > | getPerformanceMetrics () |
| + | ProcessMonitor () |
| Prepares externam software commands (ps) | |
| + | ~ProcessMonitor ()=default |
| Default destructor. | |
| +void | init () |
+Static Public Member Functions | |
| +static std::vector< std::string > | getAvailableMetricsNames () |
+Friends | |
| +class | Monitoring |
Monitors current process and/or other processes running at the same machien.
+![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::VariantVisitorAdd, including all inherited members.
+| operator()(const T &a, const T &b) const | o2::monitoring::VariantVisitorAdd | inline |
| operator()(const T &, const U &) const | o2::monitoring::VariantVisitorAdd | inline |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Adds boost variants. + More...
+ +#include <VariantVisitorAdd.h>
+Public Member Functions | |
| +template<typename T , typename = typename std::enable_if<std::is_arithmetic<T>::value, T>::type> | |
| std::variant< int, std::string, double, uint64_t > | operator() (const T &a, const T &b) const |
| Overloads operator() that sums numeric values. | |
| template<typename T , typename U > | |
| std::variant< int, std::string, double, uint64_t > | operator() (const T &, const U &) const |
Adds boost variants.
+
+
|
+ +inline | +
If arguments have different type an exception is raised
| MonitoringException |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::VariantVisitorRate, including all inherited members.
+| operator()(const T &a, const T &b) const | o2::monitoring::VariantVisitorRate | inline |
| operator()(const T &, const U &) const | o2::monitoring::VariantVisitorRate | inline |
| VariantVisitorRate(int count) | o2::monitoring::VariantVisitorRate | inline |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Subtracts boost variants in order to calculate rate. + More...
+ +#include <VariantVisitorRate.h>
+Public Member Functions | |
| VariantVisitorRate (int count) | |
| template<typename T , typename = typename std::enable_if<std::is_arithmetic<T>::value, T>::type> | |
| double | operator() (const T &a, const T &b) const |
| template<typename T , typename U > | |
| double | operator() (const T &, const U &) const |
Subtracts boost variants in order to calculate rate.
+
+
|
+ +inline | +
Creates variant visitor functor
| count | timestamp difference in milliseconds |
+
|
+ +inline | +
Calculates rate only when two arguments of the same type are passed
+
|
+ +inline | +
If arguments have different type an exception is raised
| MonitoringException |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::backends::ApMonBackend, including all inherited members.
+| addGlobalTag(std::string_view name, std::string_view value) override | o2::monitoring::backends::ApMonBackend | virtual |
| ApMonBackend(const std::string &path) | o2::monitoring::backends::ApMonBackend | |
| Backend() | o2::monitoring::Backend | inline |
| getVerbosity() | o2::monitoring::Backend | inline |
| send(std::vector< Metric > &&metrics) override | o2::monitoring::backends::ApMonBackend | virtual |
| send(const Metric &metric) override | o2::monitoring::backends::ApMonBackend | virtual |
| setVerbosisty(Verbosity level) | o2::monitoring::Backend | inline |
| ~ApMonBackend()=default | o2::monitoring::backends::ApMonBackend | |
| ~Backend()=default | o2::monitoring::Backend | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Backend that uses AppMon (MonALISA) + More...
+ +#include <ApMonBackend.h>
+Public Member Functions | |
| ApMonBackend (const std::string &path) | |
| + | ~ApMonBackend ()=default |
| Default destructor. | |
| void | send (std::vector< Metric > &&metrics) override |
| void | send (const Metric &metric) override |
| void | addGlobalTag (std::string_view name, std::string_view value) override |
Public Member Functions inherited from o2::monitoring::Backend | |
| + | Backend () |
| Default constructor. | |
| +virtual | ~Backend ()=default |
| Default destructor. | |
| +void | setVerbosisty (Verbosity level) |
| Set verbosity level. | |
| +Verbosity | getVerbosity () |
| Get verbosity level. | |
Backend that uses AppMon (MonALISA)
+Uses ApMonBackend library to push metric to MonALISA Service. ApMonBackend accepts timestamps as integers, therefore a cast is needed.
+ +| o2::monitoring::backends::ApMonBackend::ApMonBackend | +( | +const std::string & | +path | ) | ++ |
Constructs AppMon backend
| path | filepath to ApMonBackend configuration file |
+
|
+ +overridevirtual | +
Extends entity value
| name | tag name (unused) |
| value | tag value that is concatenated to entity string |
Implements o2::monitoring::Backend.
+ +
+
|
+ +overridevirtual | +
Sends multiple metrics not related to each other @param metrics vector of metrics
+ +Implements o2::monitoring::Backend.
+ +
+
|
+ +overridevirtual | +
Sends metric via MonALISA ApMonBackend's intances is type-aware therefore cast of metric value is needed
| metric | reference to metric object: |
Implements o2::monitoring::Backend.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::backends::InfluxDB, including all inherited members.
+| addGlobalTag(std::string_view name, std::string_view value) override | o2::monitoring::backends::InfluxDB | virtual |
| Backend() | o2::monitoring::Backend | inline |
| convertTimestamp(const std::chrono::time_point< std::chrono::system_clock > ×tamp) | o2::monitoring::backends::InfluxDB | inline |
| getVerbosity() | o2::monitoring::Backend | inline |
| InfluxDB(std::unique_ptr< transports::TransportInterface > transport) | o2::monitoring::backends::InfluxDB | |
| send(const Metric &metric) override | o2::monitoring::backends::InfluxDB | virtual |
| send(std::vector< Metric > &&metrics) override | o2::monitoring::backends::InfluxDB | virtual |
| setVerbosisty(Verbosity level) | o2::monitoring::Backend | inline |
| toInfluxLineProtocol(const Metric &metric) | o2::monitoring::backends::InfluxDB | |
| ~Backend()=default | o2::monitoring::Backend | virtual |
| ~InfluxDB()=default | o2::monitoring::backends::InfluxDB |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Backend that sends metrics to InfluxDB time-series databse. + More...
+ +#include <InfluxDB.h>
+Public Member Functions | |
| InfluxDB (std::unique_ptr< transports::TransportInterface > transport) | |
| + | ~InfluxDB ()=default |
| Default destructor. | |
| unsigned long | convertTimestamp (const std::chrono::time_point< std::chrono::system_clock > ×tamp) |
| void | send (const Metric &metric) override |
| void | send (std::vector< Metric > &&metrics) override |
| void | addGlobalTag (std::string_view name, std::string_view value) override |
| std::string | toInfluxLineProtocol (const Metric &metric) |
Public Member Functions inherited from o2::monitoring::Backend | |
| + | Backend () |
| Default constructor. | |
| +virtual | ~Backend ()=default |
| Default destructor. | |
| +void | setVerbosisty (Verbosity level) |
| Set verbosity level. | |
| +Verbosity | getVerbosity () |
| Get verbosity level. | |
Backend that sends metrics to InfluxDB time-series databse.
+Metrics are converted into Influx Line protocol and then sent via one of available transports
+| o2::monitoring::backends::InfluxDB::InfluxDB | +( | +std::unique_ptr< transports::TransportInterface > | +transport | ) | ++ |
Constuctor
| transport | Any available transport (udp, unix, kafka) |
+
|
+ +overridevirtual | +
Adds tag
| name | tag name |
| value | tag value |
Implements o2::monitoring::Backend.
+ +
+
|
+ +inline | +
Convert timestamp to unsigned long as required by InfluxDB
| timestamp | chrono time_point timestamp |
+
|
+ +overridevirtual | +
Sends metric to InfluxDB instance via one transport
| metric | reference to metric object |
Implements o2::monitoring::Backend.
+ +
+
|
+ +overridevirtual | +
Sends multiple metrics not related to each other @param metrics vector of metrics
+ +Implements o2::monitoring::Backend.
+ +| std::string o2::monitoring::backends::InfluxDB::toInfluxLineProtocol | +( | +const Metric & | +metric | ) | ++ |
Converts metric to Influx Line Protocol format
| metric |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::backends::Noop, including all inherited members.
+| addGlobalTag(std::string_view, std::string_view) final | o2::monitoring::backends::Noop | inlinevirtual |
| Backend() | o2::monitoring::Backend | inline |
| getVerbosity() | o2::monitoring::Backend | inline |
| Noop()=default | o2::monitoring::backends::Noop | |
| send(std::vector< Metric > &&) final | o2::monitoring::backends::Noop | inlinevirtual |
| send(const Metric &) final | o2::monitoring::backends::Noop | inlinevirtual |
| setVerbosisty(Verbosity level) | o2::monitoring::Backend | inline |
| ~Backend()=default | o2::monitoring::Backend | virtual |
| ~Noop()=default | o2::monitoring::backends::Noop |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
No-op backend. + More...
+ +#include <Noop.h>
+Public Member Functions | |
| + | Noop ()=default |
| Constructs backend. | |
| + | ~Noop ()=default |
| Default destructor. | |
| +void | send (std::vector< Metric > &&) final |
| @param metrics vector of metrics | |
| void | send (const Metric &) final |
| void | addGlobalTag (std::string_view, std::string_view) final |
Public Member Functions inherited from o2::monitoring::Backend | |
| + | Backend () |
| Default constructor. | |
| +virtual | ~Backend ()=default |
| Default destructor. | |
| +void | setVerbosisty (Verbosity level) |
| Set verbosity level. | |
| +Verbosity | getVerbosity () |
| Get verbosity level. | |
No-op backend.
+ +
+
|
+ +inlinefinalvirtual | +
| name | tag name |
| value | tag value that is concatenated to entity string |
Implements o2::monitoring::Backend.
+ +
+
|
+ +inlinefinalvirtual | +
| metric | reference to metric object: |
Implements o2::monitoring::Backend.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::backends::StdOut, including all inherited members.
+| addGlobalTag(std::string_view name, std::string_view value) override | o2::monitoring::backends::StdOut | virtual |
| Backend() | o2::monitoring::Backend | inline |
| getVerbosity() | o2::monitoring::Backend | inline |
| send(const Metric &metric) override | o2::monitoring::backends::StdOut | virtual |
| send(std::vector< Metric > &&metrics) override | o2::monitoring::backends::StdOut | virtual |
| setVerbosisty(Verbosity level) | o2::monitoring::Backend | inline |
| StdOut(const std::string &prefix="METRIC") | o2::monitoring::backends::StdOut | |
| ~Backend()=default | o2::monitoring::Backend | virtual |
| ~StdOut()=default | o2::monitoring::backends::StdOut |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Prints metrics to standard output via std::cout. + More...
+ +#include <StdOut.h>
+Public Member Functions | |
| + | StdOut (const std::string &prefix="METRIC") |
| Default constructor. | |
| + | ~StdOut ()=default |
| Default destructor. | |
| void | send (const Metric &metric) override |
| void | send (std::vector< Metric > &&metrics) override |
| void | addGlobalTag (std::string_view name, std::string_view value) override |
Public Member Functions inherited from o2::monitoring::Backend | |
| + | Backend () |
| Default constructor. | |
| +virtual | ~Backend ()=default |
| Default destructor. | |
| +void | setVerbosisty (Verbosity level) |
| Set verbosity level. | |
| +Verbosity | getVerbosity () |
| Get verbosity level. | |
Prints metrics to standard output via std::cout.
+
+
|
+ +overridevirtual | +
Adds tag
| name | tag name |
| value | tag value |
Implements o2::monitoring::Backend.
+ +
+
|
+ +overridevirtual | +
Prints metric
| metric | reference to metric object |
Implements o2::monitoring::Backend.
+ +
+
|
+ +overridevirtual | +
Prints vector of metrics @param metrics vector of metrics
+ +Implements o2::monitoring::Backend.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::HTTP, including all inherited members.
+| addHeader(const std::string &header) | o2::monitoring::transports::HTTP | |
| HTTP(const std::string &url) | o2::monitoring::transports::HTTP | |
| send(std::string &&post) | o2::monitoring::transports::HTTP | virtual |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| ~HTTP() | o2::monitoring::transports::HTTP | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
HTTP POST transport. + More...
+ +#include <HTTP.h>
+Public Member Functions | |
| HTTP (const std::string &url) | |
| + | ~HTTP () |
| Destructor. | |
| void | send (std::string &&post) |
| +void | addHeader (const std::string &header) |
| Adds custom HTTP header. | |
| o2::monitoring::transports::HTTP::HTTP | +( | +const std::string & | +url | ) | ++ |
Constructor
| url | URL of HTTP server endpoint |
+
|
+ +virtual | +
Sends metric via HTTP POST
| post | r-value reference string formatted metric |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::Kafka, including all inherited members.
+| Kafka(const std::string &host, unsigned int port, const std::string &topic="test") | o2::monitoring::transports::Kafka | |
| send(std::string &&message) override | o2::monitoring::transports::Kafka | virtual |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| ~Kafka() | o2::monitoring::transports::Kafka | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport that sends string formatted metrics via Kafka. + More...
+ +#include <Kafka.h>
+Public Member Functions | |
| Kafka (const std::string &host, unsigned int port, const std::string &topic="test") | |
| + | ~Kafka () |
| Deletes producer. | |
| void | send (std::string &&message) override |
Transport that sends string formatted metrics via Kafka.
+| o2::monitoring::transports::Kafka::Kafka | +( | +const std::string & | +host, | +
| + | + | unsigned int | +port, | +
| + | + | const std::string & | +topic = "test" |
+
| + | ) | ++ |
Creates producer
| hostname | Hostname |
| port | Port number |
| topic | Kafka topic |
+
|
+ +overridevirtual | +
Sends metric via Kafka
| message | r-value string formated |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::StdOut, including all inherited members.
+| operator<<(const T &msg) | o2::monitoring::transports::StdOut | |
| send(std::string &&message) override | o2::monitoring::transports::StdOut | virtual |
| StdOut()=default | o2::monitoring::transports::StdOut | |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| ~StdOut()=default | o2::monitoring::transports::StdOut | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport that sends string formatted metrics via StdOut. + More...
+ +#include <StdOut.h>
+Public Member Functions | |
| + | StdOut ()=default |
| Constructor. | |
| + | ~StdOut ()=default |
| Default destructor. | |
| void | send (std::string &&message) override |
| +template<typename T > | |
| StdOut & | operator<< (const T &msg) |
| Overload stream operator. | |
Transport that sends string formatted metrics via StdOut.
+
+
|
+ +overridevirtual | +
Sends metric via StdOut
| message | r-value string formated |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::TCP, including all inherited members.
+| send(std::string &&message) override | o2::monitoring::transports::TCP | virtual |
| TCP(const std::string &hostname, int port) | o2::monitoring::transports::TCP | |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| ~TCP()=default | o2::monitoring::transports::TCP | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport that sends string formatted metrics via TCP. + More...
+ +#include <TCP.h>
+Public Member Functions | |
| TCP (const std::string &hostname, int port) | |
| + | ~TCP ()=default |
| Default destructor. | |
| void | send (std::string &&message) override |
Transport that sends string formatted metrics via TCP.
+| o2::monitoring::transports::TCP::TCP | +( | +const std::string & | +hostname, | +
| + | + | int | +port | +
| + | ) | ++ |
Constructor
| hostname | InfluxDB instance hostname |
| port | InfluxDB instance port number |
+
|
+ +overridevirtual | +
Sends metric via UDP
| message | r-value string formated |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::TransportInterface, including all inherited members.
+| send(std::string &&message)=0 | o2::monitoring::transports::TransportInterface | pure virtual |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport interface for backends. + More...
+ +#include <TransportInterface.h>
+Public Member Functions | |
| virtual void | send (std::string &&message)=0 |
Transport interface for backends.
+
+
|
+ +pure virtual | +
Sends metric via given transport
| message | r-value to string formatted metric |
Implemented in o2::monitoring::transports::Kafka, o2::monitoring::transports::TCP, o2::monitoring::transports::UDP, o2::monitoring::transports::Unix, o2::monitoring::transports::StdOut, and o2::monitoring::transports::HTTP.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::UDP, including all inherited members.
+| send(std::string &&message) override | o2::monitoring::transports::UDP | virtual |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| UDP(const std::string &hostname, int port) | o2::monitoring::transports::UDP | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
| ~UDP()=default | o2::monitoring::transports::UDP |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport that sends string formatted metrics via UDP. + More...
+ +#include <UDP.h>
+Public Member Functions | |
| UDP (const std::string &hostname, int port) | |
| + | ~UDP ()=default |
| Default destructor. | |
| void | send (std::string &&message) override |
Transport that sends string formatted metrics via UDP.
+| o2::monitoring::transports::UDP::UDP | +( | +const std::string & | +hostname, | +
| + | + | int | +port | +
| + | ) | ++ |
Constructor
| hostname | InfluxDB instance hostname |
| port | InfluxDB instance port number |
+
|
+ +overridevirtual | +
Sends metric via UDP
| message | r-value string formated |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
This is the complete list of members for o2::monitoring::transports::Unix, including all inherited members.
+| send(std::string &&message) override | o2::monitoring::transports::Unix | virtual |
| TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | |
| Unix(const std::string &socketPath) | o2::monitoring::transports::Unix | |
| ~TransportInterface()=default (defined in o2::monitoring::transports::TransportInterface) | o2::monitoring::transports::TransportInterface | virtual |
| ~Unix()=default | o2::monitoring::transports::Unix |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
Transport that sends string formatted metrics via Unix datagram socket. + More...
+ +#include <Unix.h>
+Public Member Functions | |
| Unix (const std::string &socketPath) | |
| + | ~Unix ()=default |
| Default destructor. | |
| void | send (std::string &&message) override |
Transport that sends string formatted metrics via Unix datagram socket.
+| o2::monitoring::transports::Unix::Unix | +( | +const std::string & | +socketPath | ) | ++ |
| hostname | |
| port |
+
|
+ +overridevirtual | +
| message | r-value string formated |
Implements o2::monitoring::transports::TransportInterface.
+ +![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in examples | Includes file in include |
|---|---|
| 1-Basic.cxx | Monitoring / MonitoringFactory.h |
| 10-Buffering.cxx | Monitoring / MonitoringFactory.h |
| 2-TaggedMetrics.cxx | Monitoring / MonitoringFactory.h |
| 3-Verbosity.cxx | Monitoring / MonitoringFactory.h |
| 4-RateDerivedMetric.cxx | Monitoring / MonitoringFactory.h |
| 5-Benchmark.cxx | Monitoring / MonitoringFactory.h |
| 6-Increment.cxx | Monitoring / MonitoringFactory.h |
| 7-InternalBenchamrk.cxx | Monitoring / MonitoringFactory.h |
| 8-DbFiller.cxx | Monitoring / MonitoringFactory.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in src | Includes file in src/Backends |
|---|---|
| MonitoringFactory.cxx | InfluxDB.h |
| MonitoringFactory.cxx | Noop.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in src/Backends | Includes file in include |
|---|---|
| ApMonBackend.h | Monitoring / Backend.h |
| InfluxDB.h | Monitoring / Backend.h |
| Noop.h | Monitoring / Backend.h |
| StdOut.h | Monitoring / Backend.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in src/Backends | Includes file in src/Transports |
|---|---|
| InfluxDB.h | TransportInterface.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in src/Backends | Includes file in src/Exceptions |
|---|---|
| ApMonBackend.cxx | MonitoringException.h |
| InfluxDB.cxx | MonitoringException.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in src/Transports | Includes file in src/Exceptions |
|---|---|
| HTTP.cxx | MonitoringException.h |
| TCP.cxx | MonitoringException.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in test | Includes file in include |
|---|---|
| testApMon.cxx | Monitoring / MonitoringFactory.h |
| testDerived.cxx | Monitoring / DerivedMetrics.h |
| testInfluxDb.cxx | Monitoring / MonitoringFactory.h |
| testMetric.cxx | Monitoring / Metric.h |
| testMonitoring.cxx | Monitoring / MonitoringFactory.h |
| testMonitoringFactory.cxx | Monitoring / MonitoringFactory.h |
| testProcessMonitor.cxx | Monitoring / MonitoringFactory.h |
| testProcessMonitor.cxx | Monitoring / ProcessMonitor.h |
| testThreads.cxx | Monitoring / MonitoringFactory.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
| File in test | Includes file in src |
|---|---|
| testDerived.cxx | Exceptions / MonitoringException.h |
| testNoop.cxx | Backends / Noop.h |
| testProcessDetails.cxx | ProcessDetails.h |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Files | |
| file | ApMonBackend.cxx |
| file | ApMonBackend.h [code] |
| file | InfluxDB.cxx |
| file | InfluxDB.h [code] |
| file | Noop.h [code] |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Directories |
+Files | |
| file | DerivedMetrics.cxx |
| file | Metric.cxx |
| file | Monitoring.cxx |
| file | MonitoringFactory.cxx |
| file | MonLogger.h [code] |
| file | ProcessDetails.cxx |
| file | ProcessDetails.h [code] |
| file | ProcessMonitor.cxx |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Files | |
| file | MonitoringException.cxx |
| file | MonitoringException.h [code] |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Files | |
| file | 1-Basic.cxx |
| file | 10-Buffering.cxx |
| file | 2-TaggedMetrics.cxx |
| file | 4-RateDerivedMetric.cxx |
| file | 5-Benchmark.cxx |
| file | 6-Increment.cxx |
| file | 8-DbFiller.cxx |
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
![]() |
+
+ Monitoring
+ 3.3.4
+
+ O2 Monitoring library
+ |
+
+Files | |
| file | Backend.h [code] |
| file | DerivedMetrics.h [code] |
| file | Metric.h [code] |
| file | Monitoring.h [code] |
| file | MonitoringFactory.h [code] |
| file | ProcessMonitor.h [code] |
| file | Tags.h [code] |
![]() |
+
+ Monitoring
+ |