Skip to content

Commit 2661685

Browse files
committed
format code
1 parent ffc754c commit 2661685

File tree

1 file changed

+17
-9
lines changed

1 file changed

+17
-9
lines changed

rust/operator-binary/src/main.rs

Lines changed: 17 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -143,9 +143,7 @@ async fn main() -> anyhow::Result<()> {
143143
superset_store_2
144144
.state()
145145
.into_iter()
146-
.filter(move |superset| {
147-
references_configmap(superset, &config_map)
148-
})
146+
.filter(move |superset| references_configmap(superset, &config_map))
149147
.map(|superset| ObjectRef::from_obj(&*superset))
150148
},
151149
)
@@ -284,18 +282,28 @@ fn references_authentication_class(
284282

285283
fn references_configmap(
286284
superset: &DeserializeGuard<v1alpha1::SupersetCluster>,
287-
config_map: &DeserializeGuard<ConfigMap>
285+
config_map: &DeserializeGuard<ConfigMap>,
288286
) -> bool {
289287
let Ok(superset) = &superset.0 else {
290288
return false;
291289
};
292290

293291
let config_map_name = config_map.name_any();
294-
superset.spec.cluster_config.vector_aggregator_config_map_name == Some(config_map_name.to_owned()) ||
295-
match superset.spec.cluster_config.authorization.clone() {
296-
Some (superset_authorization) => if superset_authorization.role_mapping_from_opa.opa.config_map_name == config_map_name { true } else { false }
297-
None => false
298-
}
292+
superset
293+
.spec
294+
.cluster_config
295+
.vector_aggregator_config_map_name
296+
== Some(config_map_name.to_owned())
297+
|| match superset.spec.cluster_config.authorization.clone() {
298+
Some(superset_authorization) => {
299+
superset_authorization
300+
.role_mapping_from_opa
301+
.opa
302+
.config_map_name
303+
== config_map_name
304+
}
305+
None => false,
306+
}
299307
}
300308

301309
fn valid_druid_connection(

0 commit comments

Comments
 (0)