async fn partition_spec_for_spu(&self, target_spu: i32) -> Vec<(ReplicaKey, PartitionSpec)> {
        let mut res = vec![];
        for (name, partition) in self.read().await.iter() {
            if partition.spec.replicas.contains(&target_spu) {
                res.push((name.clone(), partition.spec.clone()));
            }
        }
        res
    }
/// find all partitions that has spu in the replicas
find all partitions that has spu in the replicas
find all partitions that has spu in the replicas
async fn partition_spec_for_spu(&self, target_spu: i32) -> Vec<(ReplicaKey, PartitionSpec)> {
        let mut res = vec![];
        for (name, partition) in self.read().await.iter() {
            if partition.spec.replicas.contains(&target_spu) {
                res.push((name.clone(), partition.spec.clone()));
            }
        }
        res
    }
async fn partition_spec_for_spu ( & self , target_spu : i32 ) -> Vec < ( ReplicaKey , PartitionSpec ) > { let mut res = vec ! [ ] ; for ( name , partition ) in self . read ( ) . await . iter ( ) { if partition . spec . replicas . contains ( & target_spu ) { res . push ( ( name . clone ( ) , partition . spec . clone ( ) ) ) ; } } res }
find all partitions that has spu in the replicas
find all partitions that has spu in the replicas
&self
target_spu
i32
&self
target_spu
i32