Skip to content

Commit 1e8476e

Browse files
committed
feat!: Use Tracing::pre_configured from stackable-telemetry
BREAKING: The console log level, file log level and directory variables have been changed
1 parent 81eac01 commit 1e8476e

File tree

2 files changed

+9
-47
lines changed

2 files changed

+9
-47
lines changed

crate-hashes.json

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

rust/operator-binary/src/main.rs

Lines changed: 8 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,9 @@ use stackable_operator::{
2626
logging::controller::report_controller_reconciled,
2727
namespace::WatchNamespace,
2828
shared::yaml::SerializeOptions,
29-
telemetry::{
30-
Tracing,
31-
tracing::{RollingPeriod, settings::Settings},
32-
},
29+
telemetry::Tracing,
3330
};
34-
use tracing::{info_span, level_filters::LevelFilter};
31+
use tracing::info_span;
3532
use tracing_futures::Instrument;
3633

3734
use crate::crd::{HdfsCluster, constants::APP_NAME, v1alpha1};
@@ -53,9 +50,6 @@ mod built_info {
5350

5451
pub const OPERATOR_NAME: &str = "hdfs.stackable.tech";
5552

56-
// TODO (@NickLarsenNZ): Change the variable to `CONSOLE_LOG`
57-
pub const ENV_VAR_CONSOLE_LOG: &str = "HDFS_OPERATOR_LOG";
58-
5953
#[derive(clap::Parser)]
6054
#[clap(about, author)]
6155
struct Opts {
@@ -75,44 +69,12 @@ async fn main() -> anyhow::Result<()> {
7569
telemetry_arguments,
7670
cluster_info_opts,
7771
}) => {
78-
let _tracing_guard = Tracing::builder()
79-
// TODO (@Techassi): This should be a constant
80-
.service_name("hbase-operator")
81-
.with_console_output((
82-
ENV_VAR_CONSOLE_LOG,
83-
LevelFilter::INFO,
84-
!telemetry_arguments.no_console_output,
85-
))
86-
// NOTE (@Techassi): Before stackable-telemetry was used, the log directory was
87-
// set via an env: `HDFS_OPERATOR_LOG_DIRECTORY`.
88-
// See: https://github.com/stackabletech/operator-rs/blob/f035997fca85a54238c8de895389cc50b4d421e2/crates/stackable-operator/src/logging/mod.rs#L40
89-
// Now it will be `ROLLING_LOGS` (or via `--rolling-logs <DIRECTORY>`).
90-
.with_file_output(telemetry_arguments.rolling_logs.map(|log_directory| {
91-
let rotation_period = telemetry_arguments
92-
.rolling_logs_period
93-
.unwrap_or(RollingPeriod::Hourly)
94-
.clone();
95-
96-
Settings::builder()
97-
// TODO (@Techassi): Change to CONSOLE_LOG or FILE_LOG, create constant
98-
.with_environment_variable(ENV_VAR_CONSOLE_LOG)
99-
.with_default_level(LevelFilter::INFO)
100-
.file_log_settings_builder(log_directory, "tracing-rs.json")
101-
.with_rotation_period(rotation_period)
102-
.build()
103-
}))
104-
.with_otlp_log_exporter((
105-
"OTLP_LOG",
106-
LevelFilter::DEBUG,
107-
telemetry_arguments.otlp_logs,
108-
))
109-
.with_otlp_trace_exporter((
110-
"OTLP_TRACE",
111-
LevelFilter::DEBUG,
112-
telemetry_arguments.otlp_traces,
113-
))
114-
.build()
115-
.init()?;
72+
// NOTE (@NickLarsenNZ): Before stackable-telemetry was used:
73+
// - The console log level was set by `HDFS_OPERATOR_LOG`, and is now `CONSOLE_LOG` (when using Tracing::pre_configured).
74+
// - The file log level was set by `HDFS_OPERATOR_LOG`, and is now set via `FILE_LOG` (when using Tracing::pre_configured).
75+
// - The file log directory was set by `HDFS_OPERATOR_LOG_DIRECTORY`, and is now set by `ROLLING_LOGS_DIR` (or via `--rolling-logs <DIRECTORY>`).
76+
let _tracing_guard =
77+
Tracing::pre_configured(built_info::PKG_NAME, telemetry_arguments).init()?;
11678

11779
tracing::info!(
11880
built_info.pkg_version = built_info::PKG_VERSION,

0 commit comments

Comments
 (0)