Skip to content

Commit 0c2d660

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 2a5f0e7 commit 0c2d660

File tree

2 files changed

+8
-47
lines changed

2 files changed

+8
-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: 7 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -22,12 +22,8 @@ use stackable_operator::{
2222
},
2323
logging::controller::report_controller_reconciled,
2424
shared::yaml::SerializeOptions,
25-
telemetry::{
26-
Tracing,
27-
tracing::{RollingPeriod, settings::Settings},
28-
},
25+
telemetry::Tracing,
2926
};
30-
use tracing::level_filters::LevelFilter;
3127

3228
use crate::crd::{HbaseCluster, v1alpha1};
3329

@@ -47,9 +43,6 @@ mod built_info {
4743

4844
const OPERATOR_NAME: &str = "hbase.stackable.com";
4945

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

11374
tracing::info!(
11475
built_info.pkg_version = built_info::PKG_VERSION,

0 commit comments

Comments
 (0)