123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492 |
- // Copyright The OpenTelemetry Authors
- // SPDX-License-Identifier: Apache-2.0
- #pragma once
- #include "opentelemetry/logs/logger_type_traits.h"
- #include "opentelemetry/logs/severity.h"
- #include "opentelemetry/nostd/string_view.h"
- #include "opentelemetry/nostd/unique_ptr.h"
- #include "opentelemetry/version.h"
- OPENTELEMETRY_BEGIN_NAMESPACE
- namespace common
- {
- class KeyValueIterable;
- } // namespace common
- namespace logs
- {
- class EventId;
- class LogRecord;
- /**
- * Handles log record creation.
- **/
- class Logger
- {
- public:
- virtual ~Logger() = default;
- /* Returns the name of the logger */
- virtual const nostd::string_view GetName() noexcept = 0;
- /**
- * Create a Log Record object
- *
- * @return nostd::unique_ptr<LogRecord>
- */
- virtual nostd::unique_ptr<LogRecord> CreateLogRecord() noexcept = 0;
- /**
- * Emit a Log Record object
- *
- * @param log_record Log record
- */
- virtual void EmitLogRecord(nostd::unique_ptr<LogRecord> &&log_record) noexcept = 0;
- /**
- * Emit a Log Record object with arguments
- *
- * @param log_record Log record
- * @param args Arguments which can be used to set data of log record by type.
- * Severity -> severity, severity_text
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void EmitLogRecord(nostd::unique_ptr<LogRecord> &&log_record, ArgumentType &&...args)
- {
- if (!log_record)
- {
- return;
- }
- //
- // Keep the parameter pack unpacking order from left to right because left
- // ones are usually more important like severity and event_id than the
- // attributes. The left to right unpack order could pass the more important
- // data to processors to avoid caching and memory allocating.
- //
- #if __cplusplus <= 201402L
- // C++14 does not support fold expressions for parameter pack expansion.
- int dummy[] = {(detail::LogRecordSetterTrait<typename std::decay<ArgumentType>::type>::Set(
- log_record.get(), std::forward<ArgumentType>(args)),
- 0)...};
- IgnoreTraitResult(dummy);
- #else
- IgnoreTraitResult((detail::LogRecordSetterTrait<typename std::decay<ArgumentType>::type>::Set(
- log_record.get(), std::forward<ArgumentType>(args)),
- ...));
- #endif
- EmitLogRecord(std::move(log_record));
- }
- /**
- * Emit a Log Record object with arguments
- *
- * @param args Arguments which can be used to set data of log record by type.
- * Severity -> severity, severity_text
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void EmitLogRecord(ArgumentType &&...args)
- {
- nostd::unique_ptr<LogRecord> log_record = CreateLogRecord();
- EmitLogRecord(std::move(log_record), std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of trace.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Trace(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kTrace, std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of debug.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Debug(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kDebug, std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of info.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Info(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kInfo, std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of warn.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Warn(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kWarn, std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of error.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Error(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kError, std::forward<ArgumentType>(args)...);
- }
- /**
- * Writes a log with a severity of fatal.
- * @param args Arguments which can be used to set data of log record by type.
- * string_view -> body
- * AttributeValue -> body
- * SpanContext -> span_id,trace_id and trace_flags
- * SpanId -> span_id
- * TraceId -> trace_id
- * TraceFlags -> trace_flags
- * SystemTimestamp -> timestamp
- * system_clock::time_point -> timestamp
- * KeyValueIterable -> attributes
- * Key value iterable container -> attributes
- * span<pair<string_view, AttributeValue>> -> attributes(return type of MakeAttributes)
- */
- template <class... ArgumentType>
- void Fatal(ArgumentType &&...args) noexcept
- {
- static_assert(
- !detail::LogRecordHasType<Severity, typename std::decay<ArgumentType>::type...>::value,
- "Severity is already set.");
- this->EmitLogRecord(Severity::kFatal, std::forward<ArgumentType>(args)...);
- }
- //
- // OpenTelemetry C++ user-facing Logs API
- //
- inline bool Enabled(Severity severity, const EventId &event_id) const noexcept
- {
- if OPENTELEMETRY_LIKELY_CONDITION (!Enabled(severity))
- {
- return false;
- }
- return EnabledImplementation(severity, event_id);
- }
- inline bool Enabled(Severity severity, int64_t event_id) const noexcept
- {
- if OPENTELEMETRY_LIKELY_CONDITION (!Enabled(severity))
- {
- return false;
- }
- return EnabledImplementation(severity, event_id);
- }
- inline bool Enabled(Severity severity) const noexcept
- {
- return static_cast<uint8_t>(severity) >= OPENTELEMETRY_ATOMIC_READ_8(&minimum_severity_);
- }
- /**
- * Log an event
- *
- * @severity severity of the log
- * @event_id event identifier of the log
- * @format an utf-8 string following https://messagetemplates.org/
- * @attributes key value pairs of the log
- */
- virtual void Log(Severity severity,
- const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->EmitLogRecord(severity, event_id, format, attributes);
- }
- virtual void Log(Severity severity,
- int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->EmitLogRecord(severity, EventId{event_id}, format, attributes);
- }
- virtual void Log(Severity severity,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->EmitLogRecord(severity, format, attributes);
- }
- virtual void Log(Severity severity, nostd::string_view message) noexcept
- {
- this->EmitLogRecord(severity, message);
- }
- // Convenient wrappers based on virtual methods Log().
- // https://github.com/open-telemetry/opentelemetry-specification/blob/main/specification/logs/data-model.md#field-severitynumber
- inline void Trace(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kTrace, event_id, format, attributes);
- }
- inline void Trace(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kTrace, EventId{event_id}, format, attributes);
- }
- inline void Trace(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kTrace, format, attributes);
- }
- inline void Trace(nostd::string_view message) noexcept { this->Log(Severity::kTrace, message); }
- inline void Debug(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kDebug, event_id, format, attributes);
- }
- inline void Debug(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kDebug, EventId{event_id}, format, attributes);
- }
- inline void Debug(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kDebug, format, attributes);
- }
- inline void Debug(nostd::string_view message) noexcept { this->Log(Severity::kDebug, message); }
- inline void Info(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kInfo, event_id, format, attributes);
- }
- inline void Info(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kInfo, EventId{event_id}, format, attributes);
- }
- inline void Info(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kInfo, format, attributes);
- }
- inline void Info(nostd::string_view message) noexcept { this->Log(Severity::kInfo, message); }
- inline void Warn(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kWarn, event_id, format, attributes);
- }
- inline void Warn(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kWarn, EventId{event_id}, format, attributes);
- }
- inline void Warn(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kWarn, format, attributes);
- }
- inline void Warn(nostd::string_view message) noexcept { this->Log(Severity::kWarn, message); }
- inline void Error(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kError, event_id, format, attributes);
- }
- inline void Error(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kError, EventId{event_id}, format, attributes);
- }
- inline void Error(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kError, format, attributes);
- }
- inline void Error(nostd::string_view message) noexcept { this->Log(Severity::kError, message); }
- inline void Fatal(const EventId &event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kFatal, event_id, format, attributes);
- }
- inline void Fatal(int64_t event_id,
- nostd::string_view format,
- const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kFatal, EventId{event_id}, format, attributes);
- }
- inline void Fatal(nostd::string_view format, const common::KeyValueIterable &attributes) noexcept
- {
- this->Log(Severity::kFatal, format, attributes);
- }
- inline void Fatal(nostd::string_view message) noexcept { this->Log(Severity::kFatal, message); }
- //
- // End of OpenTelemetry C++ user-facing Log API.
- //
- protected:
- // TODO: discuss with community about naming for internal methods.
- virtual bool EnabledImplementation(Severity /*severity*/,
- const EventId & /*event_id*/) const noexcept
- {
- return false;
- }
- virtual bool EnabledImplementation(Severity /*severity*/, int64_t /*event_id*/) const noexcept
- {
- return false;
- }
- void SetMinimumSeverity(uint8_t severity_or_max) noexcept
- {
- OPENTELEMETRY_ATOMIC_WRITE_8(&minimum_severity_, severity_or_max);
- }
- private:
- template <class... ValueType>
- void IgnoreTraitResult(ValueType &&...)
- {}
- //
- // minimum_severity_ can be updated concurrently by multiple threads/cores, so race condition on
- // read/write should be handled. And std::atomic can not be used here because it is not ABI
- // compatible for OpenTelemetry C++ API.
- //
- mutable uint8_t minimum_severity_{kMaxSeverity};
- };
- } // namespace logs
- OPENTELEMETRY_END_NAMESPACE
|