Skip to content

Commit f5a3db9

Browse files
test: verify broker properties update reconciliation
Signed-off-by: Pavan Vishnu Sai Bestha <pavanvishnusai@gmail.com>
1 parent 604bdcb commit f5a3db9

1 file changed

Lines changed: 10 additions & 3 deletions

File tree

agent/src/util/discovery_configuration_controller.rs

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,14 +15,14 @@ use futures::StreamExt;
1515
use tokio::sync::mpsc;
1616

1717
use crate::discovery_handler_manager::{
18-
DiscoveryError, discovery_handler_registry::DiscoveryHandlerRegistry,
18+
discovery_handler_registry::DiscoveryHandlerRegistry, DiscoveryError,
1919
};
2020

2121
use kube::api::ObjectMeta;
2222
use kube::runtime::{
23-
Controller,
2423
controller::Action,
2524
reflector::{ObjectRef, Store},
25+
Controller,
2626
};
2727
use kube::{Resource, ResourceExt};
2828
use thiserror::Error;
@@ -490,6 +490,10 @@ mod tests {
490490
let mut request = MockDiscoveryHandlerRequest::new();
491491
request
492492
.expect_set_extra_device_properties()
493+
.with(eq(HashMap::from([(
494+
"BROKER_PROPERTY".to_string(),
495+
"updated-value".to_string(),
496+
)])))
493497
.returning(|_| {});
494498
request.expect_get_instances().returning(|| Ok(vec![]));
495499
registry
@@ -522,7 +526,10 @@ mod tests {
522526
broker_spec: None,
523527
instance_service_spec: None,
524528
configuration_service_spec: None,
525-
broker_properties: Default::default(),
529+
broker_properties: HashMap::from([(
530+
"BROKER_PROPERTY".to_string(),
531+
"updated-value".to_string(),
532+
)]),
526533
},
527534
});
528535

0 commit comments

Comments
 (0)