pub async fn connect_no_namespace(
        &self,
        metrics_meter: Option<&Meter>,
    ) -> Result<RetryClient<ConfiguredClient<WorkflowServiceClientWithMetrics>>, ClientInitError>
    {
        let channel = Channel::from_shared(self.target_url.to_string())?;
        let channel = self.add_tls_to_channel(channel).await?;
        let channel = channel.connect().await?;
        let service = ServiceBuilder::new()
            .layer_fn(|channel| GrpcMetricSvc {
                inner: channel,
                metrics: metrics_meter.map(|mm| MetricsContext::new(vec![], mm)),
            })
            .service(channel);
        let interceptor = ServiceCallInterceptor { opts: self.clone() };

        let mut client = ConfiguredClient {
            client: WorkflowServiceClient::with_interceptor(service, interceptor),
            options: self.clone(),
            capabilities: None,
        };
        match client
            .get_system_info(GetSystemInfoRequest::default())
            .await
        {
            Ok(sysinfo) => {
                client.capabilities = sysinfo.into_inner().capabilities;
            }
            Err(status) => match status.code() {
                Code::Unimplemented => {}
                _ => return Err(ClientInitError::SystemInfoCallError(status)),
            },
        };
        Ok(RetryClient::new(client, self.retry_config.clone()))
    }
/// Attempt to establish a connection to the Temporal server and return a gRPC client which is
/// intercepted with retry, default headers functionality, and metrics if provided.
///
/// See [RetryClient] for more
Attempt to establish a connection to the Temporal server and return a gRPC client which is
intercepted with retry, default headers functionality, and metrics if provided.

See [RetryClient] for more
Attempt to establish a connection to the Temporal server and return a gRPC client which is intercepted with retry default headers functionality and metrics if provided . See [ RetryClient ] for more
pub async fn connect_no_namespace(
        &self,
        metrics_meter: Option<&Meter>,
    ) -> Result<RetryClient<ConfiguredClient<WorkflowServiceClientWithMetrics>>, ClientInitError>
    {
        let channel = Channel::from_shared(self.target_url.to_string())?;
        let channel = self.add_tls_to_channel(channel).await?;
        let channel = channel.connect().await?;
        let service = ServiceBuilder::new()
            .layer_fn(|channel| GrpcMetricSvc {
                inner: channel,
                metrics: metrics_meter.map(|mm| MetricsContext::new(vec![], mm)),
            })
            .service(channel);
        let interceptor = ServiceCallInterceptor { opts: self.clone() };
        let mut client = ConfiguredClient {
            client: WorkflowServiceClient::with_interceptor(service, interceptor),
            options: self.clone(),
            capabilities: None,
        };
        match client
            .get_system_info(GetSystemInfoRequest::default())
            .await
        {
            Ok(sysinfo) => {
                client.capabilities = sysinfo.into_inner().capabilities;
            }
            Err(status) => match status.code() {
                Code::Unimplemented => {}
                _ => return Err(ClientInitError::SystemInfoCallError(status)),
            },
        };
        Ok(RetryClient::new(client, self.retry_config.clone()))
    }
pub async fn connect_no_namespace ( & self , metrics_meter : Option < & Meter > , ) -> Result < RetryClient < ConfiguredClient < WorkflowServiceClientWithMetrics > > , ClientInitError > { let channel = Channel :: from_shared ( self . target_url . to_string ( ) ) ? ; let channel = self . add_tls_to_channel ( channel ) . await ? ; let channel = channel . connect ( ) . await ? ; let service = ServiceBuilder :: new ( ) . layer_fn ( | channel | GrpcMetricSvc { inner : channel , metrics : metrics_meter . map ( | mm | MetricsContext :: new ( vec ! [ ] , mm ) ) , } ) . service ( channel ) ; let interceptor = ServiceCallInterceptor { opts : self . clone ( ) } ; let mut client = ConfiguredClient { client : WorkflowServiceClient :: with_interceptor ( service , interceptor ) , options : self . clone ( ) , capabilities : None , } ; match client . get_system_info ( GetSystemInfoRequest :: default ( ) ) . await { Ok ( sysinfo ) => { client . capabilities = sysinfo . into_inner ( ) . capabilities ; } Err ( status ) => match status . code ( ) { Code :: Unimplemented => { } _ => return Err ( ClientInitError :: SystemInfoCallError ( status ) ) , } , } ; Ok ( RetryClient :: new ( client , self . retry_config . clone ( ) ) ) }
Attempt to establish a connection to the Temporal server and return a gRPC client which is
intercepted with retry, default headers functionality, and metrics if provided.
Attempt to establish a connection to the Temporal server and return a gRPC client which is intercepted with retry default headers functionality and metrics if provided .
&self
metrics_meter
Option<&Meter>
&self
metrics_meter
Option<&Meter>