pub async fn probe_once(&mut self) -> Result<(), ProbeError> {
        match self
            .dns_lookup
            .resolve_service_endpoints(&self.service_definition)
            .await
        {
            Ok(endpoints) => {
                let changeset = self.create_changeset(&endpoints).await;

                // Report the changeset to `tonic` and commit the new endpoints
                // if we succeed to report the changeset.
                self.report_and_commit(changeset, endpoints).await.map_err(|e| {
                        tracing::error!("Failed to report the discovered DNS changeset. The gRPC client has closed the channel therefore the DNS probe loop will exit.\n{:?}", e);
                        e
                    })?;
            }
            Err(err) => {
                return Err(ProbeError::ResolveServiceDefinition(
                    err.context("failed to resolve ips from host"),
                ));
            }
        }

        Ok(())
    }
/// Update tonic with a set of IPs that are retrieved by querying `hostname`.
Update tonic with a set of IPs that are retrieved by querying `hostname`.
Update tonic with a set of IPs that are retrieved by querying ` hostname ` .
pub async fn probe_once(&mut self) -> Result<(), ProbeError> {
        match self
            .dns_lookup
            .resolve_service_endpoints(&self.service_definition)
            .await
        {
            Ok(endpoints) => {
                let changeset = self.create_changeset(&endpoints).await;
                // Report the changeset to `tonic` and commit the new endpoints
                // if we succeed to report the changeset.
                self.report_and_commit(changeset, endpoints).await.map_err(|e| {
                        tracing::error!("Failed to report the discovered DNS changeset. The gRPC client has closed the channel therefore the DNS probe loop will exit.\n{:?}", e);
                        e
                    })?;
            }
            Err(err) => {
                return Err(ProbeError::ResolveServiceDefinition(
                    err.context("failed to resolve ips from host"),
                ));
            }
        }
        Ok(())
    }
pub async fn probe_once ( & mut self ) -> Result < ( ) , ProbeError > { match self . dns_lookup . resolve_service_endpoints ( & self . service_definition ) . await { Ok ( endpoints ) => { let changeset = self . create_changeset ( & endpoints ) . await ; // Report the changeset to `tonic` and commit the new endpoints // if we succeed to report the changeset. self . report_and_commit ( changeset , endpoints ) . await . map_err ( | e | { tracing :: error ! ( " \n " e ) ; e } ) ? ; } Err ( err ) => { return Err ( ProbeError :: ResolveServiceDefinition ( err . context ( " " ) , ) ) ; } } Ok ( ( ) ) }
Update tonic with a set of IPs that are retrieved by querying `hostname`.
Update tonic with a set of IPs that are retrieved by querying ` hostname ` .
&mut self