Program Listing for File processor.h

↰ Return to documentation for file (/tmp/B.puc0r6hi/BUILD/opentelemetry-cpp-1.27.0-build/opentelemetry-cpp-1.27.0/sdk/include/opentelemetry/sdk/logs/processor.h)

// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0

#pragma once

#include <chrono>
#include <memory>

#include "opentelemetry/context/context.h"
#include "opentelemetry/logs/severity.h"
#include "opentelemetry/nostd/string_view.h"
#include "opentelemetry/version.h"

OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
namespace instrumentationscope
{
class InstrumentationScope;
}  // namespace instrumentationscope
}  // namespace sdk

namespace sdk
{
namespace logs
{
class Recordable;

class LogRecordProcessor
{
public:
  LogRecordProcessor() = default;

  LogRecordProcessor(const LogRecordProcessor &)            = delete;
  LogRecordProcessor(LogRecordProcessor &&)                 = delete;
  LogRecordProcessor &operator=(const LogRecordProcessor &) = delete;
  LogRecordProcessor &operator=(LogRecordProcessor &&)      = delete;

  virtual ~LogRecordProcessor() = default;

  virtual std::unique_ptr<Recordable> MakeRecordable() noexcept = 0;

  virtual void OnEmit(std::unique_ptr<Recordable> &&record) noexcept = 0;

  bool Enabled(
      const opentelemetry::context::Context &context,
      const opentelemetry::sdk::instrumentationscope::InstrumentationScope &instrumentation_scope,
      opentelemetry::logs::Severity severity,
      opentelemetry::nostd::string_view event_name = {}) const noexcept
  {
    return EnabledImplementation(context, instrumentation_scope, severity, event_name);
  }

  virtual bool ForceFlush(
      std::chrono::microseconds timeout = (std::chrono::microseconds::max)()) noexcept = 0;

  virtual bool Shutdown(
      std::chrono::microseconds timeout = (std::chrono::microseconds::max)()) noexcept = 0;

protected:
  virtual bool EnabledImplementation(
      const opentelemetry::context::Context & /*context*/,
      const opentelemetry::sdk::instrumentationscope::InstrumentationScope
          & /*instrumentation_scope*/,
      opentelemetry::logs::Severity /*severity*/,
      opentelemetry::nostd::string_view /*event_name*/) const noexcept
  {
    return true;
  }
};
}  // namespace logs
}  // namespace sdk
OPENTELEMETRY_END_NAMESPACE