Skip to content

Commit

Permalink
Avoid spurious updates from namespaces and service accounts
Browse files Browse the repository at this point in the history
  • Loading branch information
jackkleeman committed Dec 3, 2024
1 parent 9122423 commit 6c20dfa
Show file tree
Hide file tree
Showing 4 changed files with 13 additions and 6 deletions.
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[package]
name = "restate-operator"
version = "1.1.0"
version = "1.1.1"
authors = ["restate.dev"]
edition = "2021"
rust-version = "1.75"
Expand Down
2 changes: 1 addition & 1 deletion charts/restate-operator-helm/Chart.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -2,4 +2,4 @@ apiVersion: v2
name: restate-operator-helm
description: An operator for Restate clusters
type: application
version: "1.1.0"
version: "1.1.1"
13 changes: 10 additions & 3 deletions src/controller.rs
Original file line number Diff line number Diff line change
Expand Up @@ -781,15 +781,22 @@ pub async fn run(state: State) {

let np_watcher = metadata_watcher(np_api, cfg.clone())
.touched_objects()
// netpols are really bad for apply-loops for some reason?
.predicate_filter(changed_predicate);

let ns_watcher = metadata_watcher(ns_api, cfg.clone())
.touched_objects()
.predicate_filter(changed_predicate);

let svcacc_watcher = metadata_watcher(svcacc_api, cfg.clone())
.touched_objects()
.predicate_filter(changed_predicate);

let controller = Controller::new(rc_api, rc_cfg.clone())
.shutdown_on_signal()
.owns(ns_api, cfg.clone())
.owns(svc_api, cfg.clone())
.owns(svcacc_api, cfg.clone())
.owns(cm_api, cfg.clone())
.owns_stream(ns_watcher)
.owns_stream(svcacc_watcher)
.owns_stream(np_watcher)
.owns_stream(ss_reflector)
.watches_stream(
Expand Down

0 comments on commit 6c20dfa

Please sign in to comment.