@@ -95,10 +95,13 @@ async fn main() -> anyhow::Result<()> {
9595 watcher:: Config :: default ( ) ,
9696 ) ;
9797
98- let zk_event_recorder = Arc :: new ( Recorder :: new ( client. as_kube_client ( ) , Reporter {
99- controller : ZK_FULL_CONTROLLER_NAME . to_string ( ) ,
100- instance : None ,
101- } ) ) ;
98+ let zk_event_recorder = Arc :: new ( Recorder :: new (
99+ client. as_kube_client ( ) ,
100+ Reporter {
101+ controller : ZK_FULL_CONTROLLER_NAME . to_string ( ) ,
102+ instance : None ,
103+ } ,
104+ ) ) ;
102105 let zk_store = zk_controller. store ( ) ;
103106 let zk_controller = zk_controller
104107 . owns (
@@ -162,10 +165,13 @@ async fn main() -> anyhow::Result<()> {
162165 watch_namespace. get_api :: < DeserializeGuard < v1alpha1:: ZookeeperZnode > > ( & client) ,
163166 watcher:: Config :: default ( ) ,
164167 ) ;
165- let znode_event_recorder = Arc :: new ( Recorder :: new ( client. as_kube_client ( ) , Reporter {
166- controller : ZNODE_FULL_CONTROLLER_NAME . to_string ( ) ,
167- instance : None ,
168- } ) ) ;
168+ let znode_event_recorder = Arc :: new ( Recorder :: new (
169+ client. as_kube_client ( ) ,
170+ Reporter {
171+ controller : ZNODE_FULL_CONTROLLER_NAME . to_string ( ) ,
172+ instance : None ,
173+ } ,
174+ ) ) ;
169175
170176 let znode_store = znode_controller. store ( ) ;
171177 let znode_controller = znode_controller
0 commit comments