Skip to content

Commit bc0e239

Browse files
feat: Implement annotation restarter.stackable.tech/ignore
1 parent cab1835 commit bc0e239

3 files changed

Lines changed: 35 additions & 23 deletions

File tree

Cargo.nix

Lines changed: 9 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

crate-hashes.json

Lines changed: 9 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

rust/operator-binary/src/restart_controller/statefulset.rs

Lines changed: 17 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -278,7 +278,13 @@ pub async fn get_updated_restarter_annotations(
278278
format!(
279279
"{}/{}",
280280
cm.metadata.uid.as_ref()?,
281-
cm.metadata.resource_version.as_ref()?
281+
if cm.annotations().get("restarter.stackable.tech/ignore")
282+
== Some(&"true".to_owned())
283+
{
284+
"any"
285+
} else {
286+
cm.metadata.resource_version.as_ref()?
287+
}
282288
),
283289
))
284290
}));
@@ -308,16 +314,22 @@ pub async fn get_updated_restarter_annotations(
308314
annotations.extend(
309315
secret_refs
310316
.flat_map(|secret_ref| secrets.get(&secret_ref))
311-
.flat_map(|cm| {
317+
.flat_map(|secret| {
312318
Some((
313319
format!(
314320
"secret.restarter.stackable.tech/{}",
315-
cm.metadata.name.as_ref()?
321+
secret.metadata.name.as_ref()?
316322
),
317323
format!(
318324
"{}/{}",
319-
cm.metadata.uid.as_ref()?,
320-
cm.metadata.resource_version.as_ref()?
325+
secret.metadata.uid.as_ref()?,
326+
if secret.annotations().get("restarter.stackable.tech/ignore")
327+
== Some(&"true".to_owned())
328+
{
329+
"any"
330+
} else {
331+
secret.metadata.resource_version.as_ref()?
332+
}
321333
),
322334
))
323335
}),

0 commit comments

Comments
 (0)