async fn retrieve_all_k8_items(&mut self) -> Result<String, C::MetadataClientError> {
        let k8_objects = self
            .client
            .retrieve_items::<S::K8Spec>(&self.namespace)
            .await?;

        self.process_retrieved_items(k8_objects).await
    }
///
/// Retrieve all items from Kubernetes (K8) store for forward them to processing engine
///
Retrieve all items from Kubernetes (K8) store for forward them to processing engine
Retrieve all items from Kubernetes ( K8 ) store for forward them to processing engine
async fn retrieve_all_k8_items(&mut self) -> Result<String, C::MetadataClientError> {
        let k8_objects = self
            .client
            .retrieve_items::<S::K8Spec>(&self.namespace)
            .await?;
        self.process_retrieved_items(k8_objects).await
    }
async fn retrieve_all_k8_items ( & mut self ) -> Result < String , C :: MetadataClientError > { let k8_objects = self . client . retrieve_items :: < S :: K8Spec > ( & self . namespace ) . await ? ; self . process_retrieved_items ( k8_objects ) . await }
Retrieve all items from Kubernetes (K8) store for forward them to processing engine
Retrieve all items from Kubernetes ( K8 ) store for forward them to processing engine
&mut self
&mut self