downgrade some logs

Author: passcod

src/bin/operator.rs

@@ -13,7 +13,7 @@ use kube::{
 };
 use prometheus::Encoder;
 use tower_http::trace::TraceLayer;
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 use postgres_restore_operator::{
 	context::Context,
@@ -243,7 +243,7 @@ async fn livez(State(state): State<ProbeState>) -> (StatusCode, &'static str) {
 	let last = state.heartbeat.load(Ordering::Relaxed);
 	let age = chrono::Utc::now().timestamp() - last;
 	if age <= 30 {
-		info!(heartbeat_age_secs = age, "livez ok");
+		debug!(heartbeat_age_secs = age, "livez ok");
 		(StatusCode::OK, "ok")
 	} else {
 		tracing::warn!(
@@ -259,7 +259,7 @@ async fn readyz(State(state): State<ProbeState>) -> (StatusCode, &'static str) {
 	let last = state.heartbeat.load(Ordering::Relaxed);
 	let age = chrono::Utc::now().timestamp() - last;
 	if age <= 30 {
-		info!(heartbeat_age_secs = age, "readyz ok");
+		debug!(heartbeat_age_secs = age, "readyz ok");
 		(StatusCode::OK, "ok")
 	} else {
 		tracing::warn!(

src/controllers/overlay.rs

@@ -16,7 +16,7 @@ use kube::{
 };
 
 use kube_quantity::ParsedQuantity;
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 use super::env_from_secret;
 use crate::{
@@ -343,7 +343,7 @@ pub async fn ensure_cnpg_cluster(
 		.unwrap_or_default();
 
 	if status.is_ready() {
-		info!(
+		debug!(
 			replica = replica_name,
 			cluster = cluster_name,
 			"overlay CNPG cluster is ready"
@@ -386,7 +386,7 @@ pub async fn ensure_overlay_service_annotations(
 	let services: Api<Service> = Api::namespaced(client.clone(), namespace);
 
 	if services.get_opt(&svc_name).await?.is_none() {
-		info!(
+		debug!(
 			replica = replica_name,
 			service = svc_name,
 			"overlay -rw service not yet created by CNPG, skipping annotation patch"
@@ -412,7 +412,7 @@ pub async fn ensure_overlay_service_annotations(
 		)
 		.await?;
 
-	info!(
+	debug!(
 		replica = replica_name,
 		service = svc_name,
 		count = annotations.len(),

src/controllers/replica.rs

@@ -8,7 +8,7 @@ use kube::{
 	runtime::controller::Action,
 };
 use rand::RngExt;
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 use super::{overlay, read_job_termination_message};
 use crate::{
@@ -420,7 +420,7 @@ pub async fn reconcile(replica: Arc<PostgresPhysicalReplica>, ctx: Arc<Context>)
 	// 9. Decide whether to trigger a new restore
 	if let Some(in_progress) = in_progress_restore {
 		let phase = in_progress.status.as_ref().and_then(|s| s.phase.as_ref());
-		info!(
+		debug!(
 			replica = name,
 			restore = in_progress.name_any(),
 			phase = ?phase,
@@ -519,7 +519,7 @@ pub async fn reconcile(replica: Arc<PostgresPhysicalReplica>, ctx: Arc<Context>)
 
 					// "{}" means no matching snapshots were found
 					if raw == "{}" {
-						info!(
+						warn!(
 							replica = name,
 							"snapshot list job returned no matching snapshots"
 						);
@@ -536,7 +536,7 @@ pub async fn reconcile(replica: Arc<PostgresPhysicalReplica>, ctx: Arc<Context>)
 						let current_snapshot_id = active_restore.map(|r| r.spec.snapshot.as_str());
 
 						if current_snapshot_id == Some(&snap.id) {
-							info!(
+							debug!(
 								replica = name,
 								snapshot = snap.id,
 								"latest snapshot already active, skipping"

src/controllers/replica/scheduling.rs

@@ -2,7 +2,7 @@ use std::time::Duration;
 
 use chrono::Utc;
 use kube::ResourceExt;
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 use crate::{types::*, util::parse_duration};
 
@@ -43,7 +43,7 @@ pub fn compute_next_scheduled_restore(schedule: &str) -> Option<chrono::DateTime
 pub fn should_trigger_scheduled_restore(replica: &PostgresPhysicalReplica) -> bool {
 	let name = replica.name_any();
 	let Some(schedule) = &replica.spec.schedule else {
-		info!(replica = %name, "no schedule configured, skipping scheduled restore");
+		debug!(replica = %name, "no schedule configured, skipping scheduled restore");
 		return false;
 	};
 
@@ -58,7 +58,7 @@ pub fn should_trigger_scheduled_restore(replica: &PostgresPhysicalReplica) -> bo
 			let elapsed = Utc::now().signed_duration_since(last_completed);
 			if elapsed.to_std().unwrap_or_default() < minimum_ttl {
 				let remaining = minimum_ttl - elapsed.to_std().unwrap_or_default();
-				info!(
+				debug!(
 					replica = %name,
 					minimum_ttl_secs = minimum_ttl.as_secs(),
 					remaining_secs = remaining.as_secs(),
@@ -98,7 +98,7 @@ pub fn should_trigger_scheduled_restore(replica: &PostgresPhysicalReplica) -> bo
 			);
 			return true;
 		}
-		info!(
+		debug!(
 			replica = %name,
 			next_scheduled = %next,
 			trigger_at = %trigger_at,
@@ -124,7 +124,7 @@ pub fn should_trigger_scheduled_restore(replica: &PostgresPhysicalReplica) -> bo
 		return true;
 	}
 
-	info!(
+	debug!(
 		replica = %name,
 		schedule = schedule,
 		"no nextScheduledRestore set and no cron occurrence in 24h lookback window, skipping"

src/controllers/restore.rs

@@ -14,7 +14,7 @@ use kube::{
 	api::{ObjectMeta, Patch, PatchParams, PostParams},
 	runtime::controller::Action,
 };
-use tracing::{info, warn};
+use tracing::{debug, info, warn};
 
 use super::read_job_termination_message;
 use crate::{
@@ -202,7 +202,7 @@ async fn reconcile_restoring(
 	let failed = job_status.as_ref().and_then(|s| s.failed).unwrap_or(0);
 
 	if succeeded > 0 {
-		info!(restore = name, "restore job succeeded");
+		debug!(restore = name, "restore job succeeded");
 
 		let pg_version =
 			read_job_termination_message(client, namespace, &job_name, "restore").await;