/* * Copyright The OpenTelemetry Authors * SPDX-License-Identifier: Apache-2.0 */ /* * DO NOT EDIT, this is an Auto-generated file from: * buildscripts/semantic-convention/templates/registry/semantic_metrics-h.j2 */ #pragma once #include "opentelemetry/common/macros.h" #include "opentelemetry/metrics/meter.h" #include "opentelemetry/version.h" OPENTELEMETRY_BEGIN_NAMESPACE namespace semconv { namespace messaging { /** * Number of messages that were delivered to the application. *

* Records the number of messages pulled from the broker or number of messages dispatched to the * application in push-based scenarios. The metric SHOULD be reported once per message delivery. For * example, if receiving and processing operations are both instrumented for a single message * delivery, this counter is incremented when the message is received and not reported when it is * processed.

counter */ static constexpr const char *kMetricMessagingClientConsumedMessages = "messaging.client.consumed.messages"; static constexpr const char *descrMetricMessagingClientConsumedMessages = "Number of messages that were delivered to the application."; static constexpr const char *unitMetricMessagingClientConsumedMessages = "{message}"; static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingClientConsumedMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingClientConsumedMessages, descrMetricMessagingClientConsumedMessages, unitMetricMessagingClientConsumedMessages); } static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingClientConsumedMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingClientConsumedMessages, descrMetricMessagingClientConsumedMessages, unitMetricMessagingClientConsumedMessages); } static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingClientConsumedMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingClientConsumedMessages, descrMetricMessagingClientConsumedMessages, unitMetricMessagingClientConsumedMessages); } static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingClientConsumedMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingClientConsumedMessages, descrMetricMessagingClientConsumedMessages, unitMetricMessagingClientConsumedMessages); } /** * Duration of messaging operation initiated by a producer or consumer client. *

* This metric SHOULD NOT be used to report processing duration - processing duration is reported in * @code messaging.process.duration @endcode metric.

histogram */ static constexpr const char *kMetricMessagingClientOperationDuration = "messaging.client.operation.duration"; static constexpr const char *descrMetricMessagingClientOperationDuration = "Duration of messaging operation initiated by a producer or consumer client."; static constexpr const char *unitMetricMessagingClientOperationDuration = "s"; static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingClientOperationDuration(metrics::Meter *meter) { return meter->CreateUInt64Histogram(kMetricMessagingClientOperationDuration, descrMetricMessagingClientOperationDuration, unitMetricMessagingClientOperationDuration); } static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingClientOperationDuration(metrics::Meter *meter) { return meter->CreateDoubleHistogram(kMetricMessagingClientOperationDuration, descrMetricMessagingClientOperationDuration, unitMetricMessagingClientOperationDuration); } /** * Deprecated. Use @code messaging.client.sent.messages @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.sent.messages @endcode.", "reason": "uncategorized"} *

* counter */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingClientPublishedMessages = "messaging.client.published.messages"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingClientPublishedMessages = "Deprecated. Use `messaging.client.sent.messages` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingClientPublishedMessages = "{message}"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingClientPublishedMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingClientPublishedMessages, descrMetricMessagingClientPublishedMessages, unitMetricMessagingClientPublishedMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingClientPublishedMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingClientPublishedMessages, descrMetricMessagingClientPublishedMessages, unitMetricMessagingClientPublishedMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingClientPublishedMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingClientPublishedMessages, descrMetricMessagingClientPublishedMessages, unitMetricMessagingClientPublishedMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingClientPublishedMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingClientPublishedMessages, descrMetricMessagingClientPublishedMessages, unitMetricMessagingClientPublishedMessages); } /** * Number of messages producer attempted to send to the broker. *

* This metric MUST NOT count messages that were created but haven't yet been sent. *

* counter */ static constexpr const char *kMetricMessagingClientSentMessages = "messaging.client.sent.messages"; static constexpr const char *descrMetricMessagingClientSentMessages = "Number of messages producer attempted to send to the broker."; static constexpr const char *unitMetricMessagingClientSentMessages = "{message}"; static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingClientSentMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingClientSentMessages, descrMetricMessagingClientSentMessages, unitMetricMessagingClientSentMessages); } static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingClientSentMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingClientSentMessages, descrMetricMessagingClientSentMessages, unitMetricMessagingClientSentMessages); } static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingClientSentMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingClientSentMessages, descrMetricMessagingClientSentMessages, unitMetricMessagingClientSentMessages); } static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingClientSentMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingClientSentMessages, descrMetricMessagingClientSentMessages, unitMetricMessagingClientSentMessages); } /** * Duration of processing operation. *

* This metric MUST be reported for operations with @code messaging.operation.type @endcode that * matches @code process @endcode.

histogram */ static constexpr const char *kMetricMessagingProcessDuration = "messaging.process.duration"; static constexpr const char *descrMetricMessagingProcessDuration = "Duration of processing operation."; static constexpr const char *unitMetricMessagingProcessDuration = "s"; static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingProcessDuration(metrics::Meter *meter) { return meter->CreateUInt64Histogram(kMetricMessagingProcessDuration, descrMetricMessagingProcessDuration, unitMetricMessagingProcessDuration); } static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingProcessDuration(metrics::Meter *meter) { return meter->CreateDoubleHistogram(kMetricMessagingProcessDuration, descrMetricMessagingProcessDuration, unitMetricMessagingProcessDuration); } /** * Deprecated. Use @code messaging.client.consumed.messages @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.consumed.messages @endcode.", "reason": * "uncategorized"}

counter */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingProcessMessages = "messaging.process.messages"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingProcessMessages = "Deprecated. Use `messaging.client.consumed.messages` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingProcessMessages = "{message}"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingProcessMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingProcessMessages, descrMetricMessagingProcessMessages, unitMetricMessagingProcessMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingProcessMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingProcessMessages, descrMetricMessagingProcessMessages, unitMetricMessagingProcessMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingProcessMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingProcessMessages, descrMetricMessagingProcessMessages, unitMetricMessagingProcessMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingProcessMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingProcessMessages, descrMetricMessagingProcessMessages, unitMetricMessagingProcessMessages); } /** * Deprecated. Use @code messaging.client.operation.duration @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.operation.duration @endcode.", "reason": * "uncategorized"}

histogram */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingPublishDuration = "messaging.publish.duration"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingPublishDuration = "Deprecated. Use `messaging.client.operation.duration` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingPublishDuration = "s"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingPublishDuration(metrics::Meter *meter) { return meter->CreateUInt64Histogram(kMetricMessagingPublishDuration, descrMetricMessagingPublishDuration, unitMetricMessagingPublishDuration); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingPublishDuration(metrics::Meter *meter) { return meter->CreateDoubleHistogram(kMetricMessagingPublishDuration, descrMetricMessagingPublishDuration, unitMetricMessagingPublishDuration); } /** * Deprecated. Use @code messaging.client.produced.messages @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.produced.messages @endcode.", "reason": * "uncategorized"}

counter */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingPublishMessages = "messaging.publish.messages"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingPublishMessages = "Deprecated. Use `messaging.client.produced.messages` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingPublishMessages = "{message}"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingPublishMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingPublishMessages, descrMetricMessagingPublishMessages, unitMetricMessagingPublishMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingPublishMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingPublishMessages, descrMetricMessagingPublishMessages, unitMetricMessagingPublishMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingPublishMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingPublishMessages, descrMetricMessagingPublishMessages, unitMetricMessagingPublishMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingPublishMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingPublishMessages, descrMetricMessagingPublishMessages, unitMetricMessagingPublishMessages); } /** * Deprecated. Use @code messaging.client.operation.duration @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.operation.duration @endcode.", "reason": * "uncategorized"}

histogram */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingReceiveDuration = "messaging.receive.duration"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingReceiveDuration = "Deprecated. Use `messaging.client.operation.duration` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingReceiveDuration = "s"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingReceiveDuration(metrics::Meter *meter) { return meter->CreateUInt64Histogram(kMetricMessagingReceiveDuration, descrMetricMessagingReceiveDuration, unitMetricMessagingReceiveDuration); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingReceiveDuration(metrics::Meter *meter) { return meter->CreateDoubleHistogram(kMetricMessagingReceiveDuration, descrMetricMessagingReceiveDuration, unitMetricMessagingReceiveDuration); } /** * Deprecated. Use @code messaging.client.consumed.messages @endcode instead. * * @deprecated * {"note": "Replaced by @code messaging.client.consumed.messages @endcode.", "reason": * "uncategorized"}

counter */ OPENTELEMETRY_DEPRECATED static constexpr const char *kMetricMessagingReceiveMessages = "messaging.receive.messages"; OPENTELEMETRY_DEPRECATED static constexpr const char *descrMetricMessagingReceiveMessages = "Deprecated. Use `messaging.client.consumed.messages` instead."; OPENTELEMETRY_DEPRECATED static constexpr const char *unitMetricMessagingReceiveMessages = "{message}"; OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncInt64MetricMessagingReceiveMessages(metrics::Meter *meter) { return meter->CreateUInt64Counter(kMetricMessagingReceiveMessages, descrMetricMessagingReceiveMessages, unitMetricMessagingReceiveMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::unique_ptr> CreateSyncDoubleMetricMessagingReceiveMessages(metrics::Meter *meter) { return meter->CreateDoubleCounter(kMetricMessagingReceiveMessages, descrMetricMessagingReceiveMessages, unitMetricMessagingReceiveMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncInt64MetricMessagingReceiveMessages(metrics::Meter *meter) { return meter->CreateInt64ObservableCounter(kMetricMessagingReceiveMessages, descrMetricMessagingReceiveMessages, unitMetricMessagingReceiveMessages); } OPENTELEMETRY_DEPRECATED static inline nostd::shared_ptr CreateAsyncDoubleMetricMessagingReceiveMessages(metrics::Meter *meter) { return meter->CreateDoubleObservableCounter(kMetricMessagingReceiveMessages, descrMetricMessagingReceiveMessages, unitMetricMessagingReceiveMessages); } } // namespace messaging } // namespace semconv OPENTELEMETRY_END_NAMESPACE