pub async fn build_discovery_configmaps(
    client: &stackable_operator::client::Client,
    owner: &impl Resource<DynamicType = ()>,
    kafka: &KafkaCluster,
    svc: &Service,
) -> Result<Vec<ConfigMap>, Error> {
    let name = owner.name();
    Ok(vec![
        build_discovery_configmap(&name, owner, kafka, service_hosts(svc, "kafka")?)?,
        build_discovery_configmap(
            &format!("{}-nodeport", name),
            owner,
            kafka,
            nodeport_hosts(client, svc, "kafka").await?,
        )?,
    ])
}
/// Builds discovery [`ConfigMap`]s for connecting to a [`KafkaCluster`] for all expected scenarios
Builds discovery [`ConfigMap`]s for connecting to a [`KafkaCluster`] for all expected scenarios
Builds discovery [ ` ConfigMap ` ] s for connecting to a [ ` KafkaCluster ` ] for all expected scenarios
pub async fn build_discovery_configmaps(
    client: &stackable_operator::client::Client,
    owner: &impl Resource<DynamicType = ()>,
    kafka: &KafkaCluster,
    svc: &Service,
) -> Result<Vec<ConfigMap>, Error> {
    let name = owner.name();
    Ok(vec![
        build_discovery_configmap(&name, owner, kafka, service_hosts(svc, "kafka")?)?,
        build_discovery_configmap(
            &format!("{}-nodeport", name),
            owner,
            kafka,
            nodeport_hosts(client, svc, "kafka").await?,
        )?,
    ])
}
pub async fn build_discovery_configmaps ( client : & stackable_operator :: client :: Client , owner : & impl Resource < DynamicType = ( ) > , kafka : & KafkaCluster , svc : & Service , ) -> Result < Vec < ConfigMap > , Error > { let name = owner . name ( ) ; Ok ( vec ! [ build_discovery_configmap ( name owner kafka service_hosts ( svc " " ) ) build_discovery_configmap ( format ( " " name ) owner kafka nodeport_hosts ( client svc " " ) await ) ] ) }
Builds discovery [`ConfigMap`]s for connecting to a [`KafkaCluster`] for all expected scenarios
Builds discovery [ ` ConfigMap ` ] s for connecting to a [ ` KafkaCluster ` ] for all expected scenarios
client
&stackable_operator::client::Client
owner
&impl Resource<DynamicType = ()>
kafka
&KafkaCluster
svc
&Service
client
&stackable_operator::client::Client
owner
&impl Resource<DynamicType = ()>
kafka
&KafkaCluster
svc
&Service