Skip to content

Commit 9ee0ede

Browse files
committed
listen on ipv6
1 parent cc46055 commit 9ee0ede

2 files changed

Lines changed: 9 additions & 3 deletions

File tree

operator.yaml

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,10 @@ spec:
158158
- name: controller
159159
image: ghcr.io/beyondessential/postgres-restore-operator:latest
160160
env:
161+
- name: RUST_LOG
162+
value: "info,tower_http=debug"
161163
- name: METRICS_ADDR
162-
value: "0.0.0.0:8080"
164+
value: "[::]:8080"
163165
- name: OPERATOR_NAMESPACE
164166
valueFrom:
165167
fieldRef:

src/bin/operator.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ use postgres_restore_operator::{
2222
};
2323

2424
const DEFAULT_MAX_CONCURRENT_RESTORES: usize = 2;
25-
const DEFAULT_METRICS_ADDR: &str = "0.0.0.0:8080";
25+
const DEFAULT_METRICS_ADDR: &str = "[::]:8080";
2626
const CONFIGMAP_NAME: &str = "postgres-restore-operator-config";
2727

2828
fn operator_namespace() -> String {
@@ -169,7 +169,9 @@ async fn main() -> anyhow::Result<()> {
169169
.await
170170
.expect("failed to bind metrics server");
171171
info!(addr = metrics_addr_clone, "metrics server listening");
172-
axum::serve(listener, app).await.unwrap();
172+
if let Err(e) = axum::serve(listener, app).await {
173+
tracing::error!(error = %e, "metrics/probe server exited with error");
174+
}
173175
});
174176

175177
// Start controllers
@@ -240,6 +242,7 @@ async fn livez(State(state): State<ProbeState>) -> (StatusCode, &'static str) {
240242
let last = state.heartbeat.load(Ordering::Relaxed);
241243
let age = chrono::Utc::now().timestamp() - last;
242244
if age <= 30 {
245+
info!(heartbeat_age_secs = age, "livez ok");
243246
(StatusCode::OK, "ok")
244247
} else {
245248
tracing::warn!(
@@ -255,6 +258,7 @@ async fn readyz(State(state): State<ProbeState>) -> (StatusCode, &'static str) {
255258
let last = state.heartbeat.load(Ordering::Relaxed);
256259
let age = chrono::Utc::now().timestamp() - last;
257260
if age <= 30 {
261+
info!(heartbeat_age_secs = age, "readyz ok");
258262
(StatusCode::OK, "ok")
259263
} else {
260264
tracing::warn!(

0 commit comments

Comments
 (0)