You are an expert in writing code in many different languages. Your goal is to perform code completion for the following code, keeping in mind the rest of the code and the file meta data.
    Metadata details:
    filename: spu_controller.rs
    path of file: ./repos/fluvio/crates/fluvio-sc/src/k8/controllers
    
    the code of the file until where you have to start completion: use std::{collections::HashMap, fmt, net::IpAddr, time::Duration};

use anyhow::Result;

use fluvio_controlplane_metadata::{
    spu::IngressPort,
    store::{MetadataStoreObject, k8::K8MetaItem},
};

use fluvio_stream_dispatcher::actions::WSAction;
use tracing::{debug, error, instrument, info};

use fluvio_future::task::spawn;
use fluvio_future::timer::sleep;
use fluvio_stream_model::k8_types::core::service::{LoadBalancerIngress, LoadBalancerType};

use crate::stores::StoreContext;
use crate::stores::spu::{IngressAddr, SpuSpec};
use crate::k8::objects::spu_service::SpuServiceSpec;
use crate::k8::objects::spg_group::SpuGroupObj;
use crate::stores::spg::SpuGroupSpec;

/// Update SPU from changes in SPU Group and SPU Services
/// This is only place where we make changes to SPU
/// For each SPU Group, we map
    
    async fn get_spu_services(&self) -> HashMap<String, IngressPort> {
        let services = self.services.store().clone_values().await;
        let mut spu_services = HashMap::new();

        for svc_md in services.into_iter() {
            if let Some(spu_name) = SpuServiceSpec::spu_name(svc_md.ctx().item().inner()) {
                match get_ingress_from_service(&svc_md) {
                    Ok(ingress) => {
                        spu_services.insert(spu_name.to_owned(), ingress);
                    }
                    Err(err) => {
                        error!("error reading ingress: {}", err);
                    }
                }
            } else {
                error!(
                    svc = %svc_md.key(),
                    "spu service doesnt have spu name",
                );
            }
        }

        spu_services
    }