We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e88f35 commit 035b195Copy full SHA for 035b195
rust/operator-binary/src/main.rs
@@ -162,7 +162,7 @@ pub async fn create_controller(
162
namespace.get_api::<DeserializeGuard<v1alpha1::KafkaCluster>>(&client),
163
watcher::Config::default(),
164
);
165
- let kafka_store_1 = kafka_controller.store();
+ let config_map_store = kafka_controller.store();
166
kafka_controller
167
.owns(
168
namespace.get_api::<StatefulSet>(&client),
@@ -193,7 +193,7 @@ pub async fn create_controller(
193
namespace.get_api::<DeserializeGuard<ConfigMap>>(&client),
194
195
move |config_map| {
196
- kafka_store_1
+ config_map_store
197
.state()
198
.into_iter()
199
.filter(move |kafka| references_config_map(kafka, &config_map))
0 commit comments