///
/// Convert items into actions and send to Controller dispatcher for processing
///
Convert items into actions and send to Controller dispatcher for processing
Convert items into actions and send to Controller dispatcher for processing
async fn process_retrieved_items(
        &mut self,
        k8_items: K8List<S::K8Spec, <<S as Spec>::K8Spec as K8Spec>::Status>,
    ) -> Result<String, C::MetadataClientError> {
        let version = k8_items.metadata.resource_version.clone();
        debug!("UpdateAll {}", S::LABEL);
        // wait to receive all items before sending to channel
        let actions = k8_events_to_metadata_actions(k8_items, &self.metadata);
        self.send_actions(actions).await;
        // return versions to the caller
        Ok(version)
    }
async fn process_retrieved_items ( & mut self , k8_items : K8List < S :: K8Spec , < < S as Spec > :: K8Spec as K8Spec > :: Status > , ) -> Result < String , C :: MetadataClientError > { let version = k8_items . metadata . resource_version . clone ( ) ; debug ! ( " " S LABEL ) ; // wait to receive all items before sending to channel let actions = k8_events_to_metadata_actions ( k8_items , & self . metadata ) ; self . send_actions ( actions ) . await ; // return versions to the caller Ok ( version ) }
Convert items into actions and send to Controller dispatcher for processing
Convert items into actions and send to Controller dispatcher for processing
&mut self
k8_items
K8List<S::K8Spec, <<S as Spec>::K8Spec as K8Spec>::Status>