pub struct ConfiguredClient<C> { /* private fields */ }Expand description
A client with ClientOptions attached, which can be passed to initialize workers, or can be used directly. Is cheap to clone.
Implementations§
Source§impl<C> ConfiguredClient<C>
impl<C> ConfiguredClient<C>
Sourcepub fn set_headers(
&self,
headers: HashMap<String, String>,
) -> Result<(), InvalidHeaderError>
pub fn set_headers( &self, headers: HashMap<String, String>, ) -> Result<(), InvalidHeaderError>
Set HTTP request headers overwriting previous headers.
This will not affect headers set via ClientOptions::binary_headers.
§Errors
Will return an error if any of the provided keys or values are not valid gRPC metadata. If an error is returned, the previous headers will remain unchanged.
Sourcepub fn set_binary_headers(
&self,
binary_headers: HashMap<String, Vec<u8>>,
) -> Result<(), InvalidHeaderError>
pub fn set_binary_headers( &self, binary_headers: HashMap<String, Vec<u8>>, ) -> Result<(), InvalidHeaderError>
Set binary HTTP request headers overwriting previous headers.
This will not affect headers set via ClientOptions::headers.
§Errors
Will return an error if any of the provided keys are not valid gRPC binary metadata keys. If an error is returned, the previous headers will remain unchanged.
Sourcepub fn set_api_key(&self, api_key: Option<String>)
pub fn set_api_key(&self, api_key: Option<String>)
Set API key, overwriting previous
Sourcepub fn options(&self) -> &ClientOptions
pub fn options(&self) -> &ClientOptions
Returns the options the client is configured with
Sourcepub fn capabilities(&self) -> Option<&Capabilities>
pub fn capabilities(&self) -> Option<&Capabilities>
Returns the server capabilities we (may have) learned about when establishing an initial connection
Sourcepub fn workers(&self) -> Arc<SlotManager>
pub fn workers(&self) -> Arc<SlotManager>
Returns a cloned reference to a registry with workers using this client instance
Trait Implementations§
Source§impl<C: Clone> Clone for ConfiguredClient<C>
impl<C: Clone> Clone for ConfiguredClient<C>
Source§fn clone(&self) -> ConfiguredClient<C>
fn clone(&self) -> ConfiguredClient<C>
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl<C: Debug> Debug for ConfiguredClient<C>
impl<C: Debug> Debug for ConfiguredClient<C>
Source§impl<C> Deref for ConfiguredClient<C>
impl<C> Deref for ConfiguredClient<C>
Auto Trait Implementations§
impl<C> Freeze for ConfiguredClient<C>where
C: Freeze,
impl<C> !RefUnwindSafe for ConfiguredClient<C>
impl<C> Send for ConfiguredClient<C>where
C: Send,
impl<C> Sync for ConfiguredClient<C>where
C: Sync,
impl<C> Unpin for ConfiguredClient<C>where
C: Unpin,
impl<C> !UnwindSafe for ConfiguredClient<C>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<RC, T> CloudService for RCwhere
RC: RawClientLike<SvcType = T>,
T: GrpcService<Body> + Send + Clone + 'static,
<T as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T as GrpcService<Body>>::Error: Into<Box<dyn Error + Sync + Send>>,
<T as GrpcService<Body>>::Future: Send,
<<T as GrpcService<Body>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,
impl<RC, T> CloudService for RCwhere
RC: RawClientLike<SvcType = T>,
T: GrpcService<Body> + Send + Clone + 'static,
<T as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T as GrpcService<Body>>::Error: Into<Box<dyn Error + Sync + Send>>,
<T as GrpcService<Body>>::Future: Send,
<<T as GrpcService<Body>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,
Source§fn get_users(
&mut self,
request: impl IntoRequest<GetUsersRequest>,
) -> BoxFuture<'_, Result<Response<GetUsersResponse>, Status>>
fn get_users( &mut self, request: impl IntoRequest<GetUsersRequest>, ) -> BoxFuture<'_, Result<Response<GetUsersResponse>, Status>>
Source§fn get_user(
&mut self,
request: impl IntoRequest<GetUserRequest>,
) -> BoxFuture<'_, Result<Response<GetUserResponse>, Status>>
fn get_user( &mut self, request: impl IntoRequest<GetUserRequest>, ) -> BoxFuture<'_, Result<Response<GetUserResponse>, Status>>
Source§fn create_user(
&mut self,
request: impl IntoRequest<CreateUserRequest>,
) -> BoxFuture<'_, Result<Response<CreateUserResponse>, Status>>
fn create_user( &mut self, request: impl IntoRequest<CreateUserRequest>, ) -> BoxFuture<'_, Result<Response<CreateUserResponse>, Status>>
Source§fn update_user(
&mut self,
request: impl IntoRequest<UpdateUserRequest>,
) -> BoxFuture<'_, Result<Response<UpdateUserResponse>, Status>>
fn update_user( &mut self, request: impl IntoRequest<UpdateUserRequest>, ) -> BoxFuture<'_, Result<Response<UpdateUserResponse>, Status>>
Source§fn delete_user(
&mut self,
request: impl IntoRequest<DeleteUserRequest>,
) -> BoxFuture<'_, Result<Response<DeleteUserResponse>, Status>>
fn delete_user( &mut self, request: impl IntoRequest<DeleteUserRequest>, ) -> BoxFuture<'_, Result<Response<DeleteUserResponse>, Status>>
Source§fn set_user_namespace_access(
&mut self,
request: impl IntoRequest<SetUserNamespaceAccessRequest>,
) -> BoxFuture<'_, Result<Response<SetUserNamespaceAccessResponse>, Status>>
fn set_user_namespace_access( &mut self, request: impl IntoRequest<SetUserNamespaceAccessRequest>, ) -> BoxFuture<'_, Result<Response<SetUserNamespaceAccessResponse>, Status>>
Source§fn get_async_operation(
&mut self,
request: impl IntoRequest<GetAsyncOperationRequest>,
) -> BoxFuture<'_, Result<Response<GetAsyncOperationResponse>, Status>>
fn get_async_operation( &mut self, request: impl IntoRequest<GetAsyncOperationRequest>, ) -> BoxFuture<'_, Result<Response<GetAsyncOperationResponse>, Status>>
Source§fn create_namespace(
&mut self,
request: impl IntoRequest<CreateNamespaceRequest>,
) -> BoxFuture<'_, Result<Response<CreateNamespaceResponse>, Status>>
fn create_namespace( &mut self, request: impl IntoRequest<CreateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<CreateNamespaceResponse>, Status>>
Source§fn get_namespaces(
&mut self,
request: impl IntoRequest<GetNamespacesRequest>,
) -> BoxFuture<'_, Result<Response<GetNamespacesResponse>, Status>>
fn get_namespaces( &mut self, request: impl IntoRequest<GetNamespacesRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespacesResponse>, Status>>
Source§fn get_namespace(
&mut self,
request: impl IntoRequest<GetNamespaceRequest>,
) -> BoxFuture<'_, Result<Response<GetNamespaceResponse>, Status>>
fn get_namespace( &mut self, request: impl IntoRequest<GetNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceResponse>, Status>>
Source§fn update_namespace(
&mut self,
request: impl IntoRequest<UpdateNamespaceRequest>,
) -> BoxFuture<'_, Result<Response<UpdateNamespaceResponse>, Status>>
fn update_namespace( &mut self, request: impl IntoRequest<UpdateNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceResponse>, Status>>
Source§fn rename_custom_search_attribute(
&mut self,
request: impl IntoRequest<RenameCustomSearchAttributeRequest>,
) -> BoxFuture<'_, Result<Response<RenameCustomSearchAttributeResponse>, Status>>
fn rename_custom_search_attribute( &mut self, request: impl IntoRequest<RenameCustomSearchAttributeRequest>, ) -> BoxFuture<'_, Result<Response<RenameCustomSearchAttributeResponse>, Status>>
Source§fn delete_namespace(
&mut self,
request: impl IntoRequest<DeleteNamespaceRequest>,
) -> BoxFuture<'_, Result<Response<DeleteNamespaceResponse>, Status>>
fn delete_namespace( &mut self, request: impl IntoRequest<DeleteNamespaceRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceResponse>, Status>>
Source§fn failover_namespace_region(
&mut self,
request: impl IntoRequest<FailoverNamespaceRegionRequest>,
) -> BoxFuture<'_, Result<Response<FailoverNamespaceRegionResponse>, Status>>
fn failover_namespace_region( &mut self, request: impl IntoRequest<FailoverNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<FailoverNamespaceRegionResponse>, Status>>
Source§fn add_namespace_region(
&mut self,
request: impl IntoRequest<AddNamespaceRegionRequest>,
) -> BoxFuture<'_, Result<Response<AddNamespaceRegionResponse>, Status>>
fn add_namespace_region( &mut self, request: impl IntoRequest<AddNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<AddNamespaceRegionResponse>, Status>>
Source§fn delete_namespace_region(
&mut self,
request: impl IntoRequest<DeleteNamespaceRegionRequest>,
) -> BoxFuture<'_, Result<Response<DeleteNamespaceRegionResponse>, Status>>
fn delete_namespace_region( &mut self, request: impl IntoRequest<DeleteNamespaceRegionRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceRegionResponse>, Status>>
Source§fn get_regions(
&mut self,
request: impl IntoRequest<GetRegionsRequest>,
) -> BoxFuture<'_, Result<Response<GetRegionsResponse>, Status>>
fn get_regions( &mut self, request: impl IntoRequest<GetRegionsRequest>, ) -> BoxFuture<'_, Result<Response<GetRegionsResponse>, Status>>
Source§fn get_region(
&mut self,
request: impl IntoRequest<GetRegionRequest>,
) -> BoxFuture<'_, Result<Response<GetRegionResponse>, Status>>
fn get_region( &mut self, request: impl IntoRequest<GetRegionRequest>, ) -> BoxFuture<'_, Result<Response<GetRegionResponse>, Status>>
Source§fn get_api_keys(
&mut self,
request: impl IntoRequest<GetApiKeysRequest>,
) -> BoxFuture<'_, Result<Response<GetApiKeysResponse>, Status>>
fn get_api_keys( &mut self, request: impl IntoRequest<GetApiKeysRequest>, ) -> BoxFuture<'_, Result<Response<GetApiKeysResponse>, Status>>
Source§fn get_api_key(
&mut self,
request: impl IntoRequest<GetApiKeyRequest>,
) -> BoxFuture<'_, Result<Response<GetApiKeyResponse>, Status>>
fn get_api_key( &mut self, request: impl IntoRequest<GetApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<GetApiKeyResponse>, Status>>
Source§fn create_api_key(
&mut self,
request: impl IntoRequest<CreateApiKeyRequest>,
) -> BoxFuture<'_, Result<Response<CreateApiKeyResponse>, Status>>
fn create_api_key( &mut self, request: impl IntoRequest<CreateApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<CreateApiKeyResponse>, Status>>
Source§fn update_api_key(
&mut self,
request: impl IntoRequest<UpdateApiKeyRequest>,
) -> BoxFuture<'_, Result<Response<UpdateApiKeyResponse>, Status>>
fn update_api_key( &mut self, request: impl IntoRequest<UpdateApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<UpdateApiKeyResponse>, Status>>
Source§fn delete_api_key(
&mut self,
request: impl IntoRequest<DeleteApiKeyRequest>,
) -> BoxFuture<'_, Result<Response<DeleteApiKeyResponse>, Status>>
fn delete_api_key( &mut self, request: impl IntoRequest<DeleteApiKeyRequest>, ) -> BoxFuture<'_, Result<Response<DeleteApiKeyResponse>, Status>>
Source§fn get_nexus_endpoints(
&mut self,
request: impl IntoRequest<GetNexusEndpointsRequest>,
) -> BoxFuture<'_, Result<Response<GetNexusEndpointsResponse>, Status>>
fn get_nexus_endpoints( &mut self, request: impl IntoRequest<GetNexusEndpointsRequest>, ) -> BoxFuture<'_, Result<Response<GetNexusEndpointsResponse>, Status>>
Source§fn get_nexus_endpoint(
&mut self,
request: impl IntoRequest<GetNexusEndpointRequest>,
) -> BoxFuture<'_, Result<Response<GetNexusEndpointResponse>, Status>>
fn get_nexus_endpoint( &mut self, request: impl IntoRequest<GetNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<GetNexusEndpointResponse>, Status>>
Source§fn create_nexus_endpoint(
&mut self,
request: impl IntoRequest<CreateNexusEndpointRequest>,
) -> BoxFuture<'_, Result<Response<CreateNexusEndpointResponse>, Status>>
fn create_nexus_endpoint( &mut self, request: impl IntoRequest<CreateNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<CreateNexusEndpointResponse>, Status>>
Source§fn update_nexus_endpoint(
&mut self,
request: impl IntoRequest<UpdateNexusEndpointRequest>,
) -> BoxFuture<'_, Result<Response<UpdateNexusEndpointResponse>, Status>>
fn update_nexus_endpoint( &mut self, request: impl IntoRequest<UpdateNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNexusEndpointResponse>, Status>>
Source§fn delete_nexus_endpoint(
&mut self,
request: impl IntoRequest<DeleteNexusEndpointRequest>,
) -> BoxFuture<'_, Result<Response<DeleteNexusEndpointResponse>, Status>>
fn delete_nexus_endpoint( &mut self, request: impl IntoRequest<DeleteNexusEndpointRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNexusEndpointResponse>, Status>>
Source§fn get_user_groups(
&mut self,
request: impl IntoRequest<GetUserGroupsRequest>,
) -> BoxFuture<'_, Result<Response<GetUserGroupsResponse>, Status>>
fn get_user_groups( &mut self, request: impl IntoRequest<GetUserGroupsRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupsResponse>, Status>>
Source§fn get_user_group(
&mut self,
request: impl IntoRequest<GetUserGroupRequest>,
) -> BoxFuture<'_, Result<Response<GetUserGroupResponse>, Status>>
fn get_user_group( &mut self, request: impl IntoRequest<GetUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupResponse>, Status>>
Source§fn create_user_group(
&mut self,
request: impl IntoRequest<CreateUserGroupRequest>,
) -> BoxFuture<'_, Result<Response<CreateUserGroupResponse>, Status>>
fn create_user_group( &mut self, request: impl IntoRequest<CreateUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<CreateUserGroupResponse>, Status>>
Source§fn update_user_group(
&mut self,
request: impl IntoRequest<UpdateUserGroupRequest>,
) -> BoxFuture<'_, Result<Response<UpdateUserGroupResponse>, Status>>
fn update_user_group( &mut self, request: impl IntoRequest<UpdateUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<UpdateUserGroupResponse>, Status>>
Source§fn delete_user_group(
&mut self,
request: impl IntoRequest<DeleteUserGroupRequest>,
) -> BoxFuture<'_, Result<Response<DeleteUserGroupResponse>, Status>>
fn delete_user_group( &mut self, request: impl IntoRequest<DeleteUserGroupRequest>, ) -> BoxFuture<'_, Result<Response<DeleteUserGroupResponse>, Status>>
Source§fn add_user_group_member(
&mut self,
request: impl IntoRequest<AddUserGroupMemberRequest>,
) -> BoxFuture<'_, Result<Response<AddUserGroupMemberResponse>, Status>>
fn add_user_group_member( &mut self, request: impl IntoRequest<AddUserGroupMemberRequest>, ) -> BoxFuture<'_, Result<Response<AddUserGroupMemberResponse>, Status>>
Source§fn remove_user_group_member(
&mut self,
request: impl IntoRequest<RemoveUserGroupMemberRequest>,
) -> BoxFuture<'_, Result<Response<RemoveUserGroupMemberResponse>, Status>>
fn remove_user_group_member( &mut self, request: impl IntoRequest<RemoveUserGroupMemberRequest>, ) -> BoxFuture<'_, Result<Response<RemoveUserGroupMemberResponse>, Status>>
Source§fn get_user_group_members(
&mut self,
request: impl IntoRequest<GetUserGroupMembersRequest>,
) -> BoxFuture<'_, Result<Response<GetUserGroupMembersResponse>, Status>>
fn get_user_group_members( &mut self, request: impl IntoRequest<GetUserGroupMembersRequest>, ) -> BoxFuture<'_, Result<Response<GetUserGroupMembersResponse>, Status>>
Source§fn set_user_group_namespace_access(
&mut self,
request: impl IntoRequest<SetUserGroupNamespaceAccessRequest>,
) -> BoxFuture<'_, Result<Response<SetUserGroupNamespaceAccessResponse>, Status>>
fn set_user_group_namespace_access( &mut self, request: impl IntoRequest<SetUserGroupNamespaceAccessRequest>, ) -> BoxFuture<'_, Result<Response<SetUserGroupNamespaceAccessResponse>, Status>>
Source§fn create_service_account(
&mut self,
request: impl IntoRequest<CreateServiceAccountRequest>,
) -> BoxFuture<'_, Result<Response<CreateServiceAccountResponse>, Status>>
fn create_service_account( &mut self, request: impl IntoRequest<CreateServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<CreateServiceAccountResponse>, Status>>
Source§fn get_service_account(
&mut self,
request: impl IntoRequest<GetServiceAccountRequest>,
) -> BoxFuture<'_, Result<Response<GetServiceAccountResponse>, Status>>
fn get_service_account( &mut self, request: impl IntoRequest<GetServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<GetServiceAccountResponse>, Status>>
Source§fn get_service_accounts(
&mut self,
request: impl IntoRequest<GetServiceAccountsRequest>,
) -> BoxFuture<'_, Result<Response<GetServiceAccountsResponse>, Status>>
fn get_service_accounts( &mut self, request: impl IntoRequest<GetServiceAccountsRequest>, ) -> BoxFuture<'_, Result<Response<GetServiceAccountsResponse>, Status>>
Source§fn update_service_account(
&mut self,
request: impl IntoRequest<UpdateServiceAccountRequest>,
) -> BoxFuture<'_, Result<Response<UpdateServiceAccountResponse>, Status>>
fn update_service_account( &mut self, request: impl IntoRequest<UpdateServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<UpdateServiceAccountResponse>, Status>>
Source§fn delete_service_account(
&mut self,
request: impl IntoRequest<DeleteServiceAccountRequest>,
) -> BoxFuture<'_, Result<Response<DeleteServiceAccountResponse>, Status>>
fn delete_service_account( &mut self, request: impl IntoRequest<DeleteServiceAccountRequest>, ) -> BoxFuture<'_, Result<Response<DeleteServiceAccountResponse>, Status>>
Source§fn get_usage(
&mut self,
request: impl IntoRequest<GetUsageRequest>,
) -> BoxFuture<'_, Result<Response<GetUsageResponse>, Status>>
fn get_usage( &mut self, request: impl IntoRequest<GetUsageRequest>, ) -> BoxFuture<'_, Result<Response<GetUsageResponse>, Status>>
Source§fn get_account(
&mut self,
request: impl IntoRequest<GetAccountRequest>,
) -> BoxFuture<'_, Result<Response<GetAccountResponse>, Status>>
fn get_account( &mut self, request: impl IntoRequest<GetAccountRequest>, ) -> BoxFuture<'_, Result<Response<GetAccountResponse>, Status>>
Source§fn update_account(
&mut self,
request: impl IntoRequest<UpdateAccountRequest>,
) -> BoxFuture<'_, Result<Response<UpdateAccountResponse>, Status>>
fn update_account( &mut self, request: impl IntoRequest<UpdateAccountRequest>, ) -> BoxFuture<'_, Result<Response<UpdateAccountResponse>, Status>>
Source§fn create_namespace_export_sink(
&mut self,
request: impl IntoRequest<CreateNamespaceExportSinkRequest>,
) -> BoxFuture<'_, Result<Response<CreateNamespaceExportSinkResponse>, Status>>
fn create_namespace_export_sink( &mut self, request: impl IntoRequest<CreateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<CreateNamespaceExportSinkResponse>, Status>>
Source§fn get_namespace_export_sink(
&mut self,
request: impl IntoRequest<GetNamespaceExportSinkRequest>,
) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinkResponse>, Status>>
fn get_namespace_export_sink( &mut self, request: impl IntoRequest<GetNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinkResponse>, Status>>
Source§fn get_namespace_export_sinks(
&mut self,
request: impl IntoRequest<GetNamespaceExportSinksRequest>,
) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinksResponse>, Status>>
fn get_namespace_export_sinks( &mut self, request: impl IntoRequest<GetNamespaceExportSinksRequest>, ) -> BoxFuture<'_, Result<Response<GetNamespaceExportSinksResponse>, Status>>
Source§fn update_namespace_export_sink(
&mut self,
request: impl IntoRequest<UpdateNamespaceExportSinkRequest>,
) -> BoxFuture<'_, Result<Response<UpdateNamespaceExportSinkResponse>, Status>>
fn update_namespace_export_sink( &mut self, request: impl IntoRequest<UpdateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<UpdateNamespaceExportSinkResponse>, Status>>
Source§fn delete_namespace_export_sink(
&mut self,
request: impl IntoRequest<DeleteNamespaceExportSinkRequest>,
) -> BoxFuture<'_, Result<Response<DeleteNamespaceExportSinkResponse>, Status>>
fn delete_namespace_export_sink( &mut self, request: impl IntoRequest<DeleteNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<DeleteNamespaceExportSinkResponse>, Status>>
Source§fn validate_namespace_export_sink(
&mut self,
request: impl IntoRequest<ValidateNamespaceExportSinkRequest>,
) -> BoxFuture<'_, Result<Response<ValidateNamespaceExportSinkResponse>, Status>>
fn validate_namespace_export_sink( &mut self, request: impl IntoRequest<ValidateNamespaceExportSinkRequest>, ) -> BoxFuture<'_, Result<Response<ValidateNamespaceExportSinkResponse>, Status>>
Source§fn create_connectivity_rule(
&mut self,
request: impl IntoRequest<CreateConnectivityRuleRequest>,
) -> BoxFuture<'_, Result<Response<CreateConnectivityRuleResponse>, Status>>
fn create_connectivity_rule( &mut self, request: impl IntoRequest<CreateConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<CreateConnectivityRuleResponse>, Status>>
Source§fn get_connectivity_rule(
&mut self,
request: impl IntoRequest<GetConnectivityRuleRequest>,
) -> BoxFuture<'_, Result<Response<GetConnectivityRuleResponse>, Status>>
fn get_connectivity_rule( &mut self, request: impl IntoRequest<GetConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<GetConnectivityRuleResponse>, Status>>
Source§fn get_connectivity_rules(
&mut self,
request: impl IntoRequest<GetConnectivityRulesRequest>,
) -> BoxFuture<'_, Result<Response<GetConnectivityRulesResponse>, Status>>
fn get_connectivity_rules( &mut self, request: impl IntoRequest<GetConnectivityRulesRequest>, ) -> BoxFuture<'_, Result<Response<GetConnectivityRulesResponse>, Status>>
Source§fn delete_connectivity_rule(
&mut self,
request: impl IntoRequest<DeleteConnectivityRuleRequest>,
) -> BoxFuture<'_, Result<Response<DeleteConnectivityRuleResponse>, Status>>
fn delete_connectivity_rule( &mut self, request: impl IntoRequest<DeleteConnectivityRuleRequest>, ) -> BoxFuture<'_, Result<Response<DeleteConnectivityRuleResponse>, Status>>
Source§impl<RC, T> HealthService for RCwhere
RC: RawClientLike<SvcType = T>,
T: GrpcService<Body> + Send + Clone + 'static,
<T as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T as GrpcService<Body>>::Error: Into<Box<dyn Error + Sync + Send>>,
<T as GrpcService<Body>>::Future: Send,
<<T as GrpcService<Body>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,
impl<RC, T> HealthService for RCwhere
RC: RawClientLike<SvcType = T>,
T: GrpcService<Body> + Send + Clone + 'static,
<T as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T as GrpcService<Body>>::Error: Into<Box<dyn Error + Sync + Send>>,
<T as GrpcService<Body>>::Future: Send,
<<T as GrpcService<Body>>::ResponseBody as Body>::Error: Into<Box<dyn Error + Sync + Send>> + Send,
Source§fn check(
&mut self,
request: impl IntoRequest<HealthCheckRequest>,
) -> BoxFuture<'_, Result<Response<HealthCheckResponse>, Status>>
fn check( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> BoxFuture<'_, Result<Response<HealthCheckResponse>, Status>>
Source§fn watch(
&mut self,
request: impl IntoRequest<HealthCheckRequest>,
) -> BoxFuture<'_, Result<Response<Streaming<HealthCheckResponse>>, Status>>
fn watch( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> BoxFuture<'_, Result<Response<Streaming<HealthCheckResponse>>, Status>>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request