async fn refresh_spu(&self, spu_id: i32) -> Result<(), ScServerError> {
        debug!("Send SPU metadata({})", spu_id);

        if let Some(spu) = self.spu_store.get_by_id(&spu_id) {
            self.send_update_all_to_spu(&spu).await?;
        } else {
            return Err(ScServerError::UnknownSpu(spu_id));
        }

        Ok(())
    }
/// looks-up metadata and sends all SPUs and Replicas leaders associated with the SPU.
looks-up metadata and sends all SPUs and Replicas leaders associated with the SPU.
looks - up metadata and sends all SPUs and Replicas leaders associated with the SPU .
async fn refresh_spu(&self, spu_id: i32) -> Result<(), ScServerError> {
        debug!("Send SPU metadata({})", spu_id);
        if let Some(spu) = self.spu_store.get_by_id(&spu_id) {
            self.send_update_all_to_spu(&spu).await?;
        } else {
            return Err(ScServerError::UnknownSpu(spu_id));
        }
        Ok(())
    }
async fn refresh_spu ( & self , spu_id : i32 ) -> Result < ( ) , ScServerError > { debug ! ( " " spu_id ) ; if let Some ( spu ) = self . spu_store . get_by_id ( & spu_id ) { self . send_update_all_to_spu ( & spu ) . await ? ; } else { return Err ( ScServerError :: UnknownSpu ( spu_id ) ) ; } Ok ( ( ) ) }
looks-up metadata and sends all SPUs and Replicas leaders associated with the SPU.
looks - up metadata and sends all SPUs and Replicas leaders associated with the SPU .
&self
spu_id
i32
&self
spu_id
i32