pub struct SharedReplaceableClient<C>{ /* private fields */ }Expand description
A client wrapper that allows replacing the underlying client at a later point in time. Clones of this struct have a shared reference to the underlying client, and each clone also has its own cached clone of the underlying client. Before every service call, a check is made whether the shared client was replaced, and the cached clone is updated accordingly.
This struct is fully thread-safe, and it works in a lock-free manner except when the client is being replaced. A read-write lock is used then, with minimal locking time.
Implementations§
Sourcepub fn new(client: C) -> Self
pub fn new(client: C) -> Self
Creates the initial instance of replaceable client with the provided underlying client.
Use clone() method to create more instances that share the same underlying client.
Sourcepub fn replace_client(&self, new_client: C)
pub fn replace_client(&self, new_client: C)
Replaces the client for all instances that share this instance’s underlying client.
Sourcepub fn inner_clone(&self) -> C
pub fn inner_clone(&self) -> C
Returns a clone of the underlying client.
Sourcepub fn inner_cow(&self) -> Cow<'_, C>
pub fn inner_cow(&self) -> Cow<'_, C>
Returns an immutable reference to this instance’s cached clone of the underlying client if
it’s up to date, or a fresh clone of the shared client otherwise. Because it’s an immutable
method, it will not update this instance’s cached clone. For this reason, prefer to use
inner_mut_refreshed() when possible.
Sourcepub fn inner_mut_refreshed(&mut self) -> &mut C
pub fn inner_mut_refreshed(&mut self) -> &mut C
Returns a mutable reference to this instance’s cached clone of the underlying client. If the cached clone is not up to date, it’s refreshed before the reference is returned. This method is called automatically by most other mutable methods, in particular by all service calls, so most of the time it doesn’t need to be called directly.
While this method allows mutable access to the underlying client, any configuration changes
will not be shared with other instances, and will be lost if the client gets replaced from
anywhere. To make configuration changes, use replace_client() instead.
Trait Implementations§
Source§fn clone(&self) -> Self
fn clone(&self) -> Self
Creates a new instance of replaceable client that shares the underlying client with this instance. Replacing a client in either instance will replace it for both instances, and all other clones too.
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
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
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>
T in a tonic::RequestSource§impl<RC, T> OperatorService 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> OperatorService 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 add_search_attributes(
&mut self,
request: impl IntoRequest<AddSearchAttributesRequest>,
) -> BoxFuture<'_, Result<Response<AddSearchAttributesResponse>, Status>>
fn add_search_attributes( &mut self, request: impl IntoRequest<AddSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<AddSearchAttributesResponse>, Status>>
Source§fn remove_search_attributes(
&mut self,
request: impl IntoRequest<RemoveSearchAttributesRequest>,
) -> BoxFuture<'_, Result<Response<RemoveSearchAttributesResponse>, Status>>
fn remove_search_attributes( &mut self, request: impl IntoRequest<RemoveSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<RemoveSearchAttributesResponse>, Status>>
Source§fn list_search_attributes(
&mut self,
request: impl IntoRequest<ListSearchAttributesRequest>,
) -> BoxFuture<'_, Result<Response<ListSearchAttributesResponse>, Status>>
fn list_search_attributes( &mut self, request: impl IntoRequest<ListSearchAttributesRequest>, ) -> BoxFuture<'_, Result<Response<ListSearchAttributesResponse>, 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 add_or_update_remote_cluster(
&mut self,
request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>,
) -> BoxFuture<'_, Result<Response<AddOrUpdateRemoteClusterResponse>, Status>>
fn add_or_update_remote_cluster( &mut self, request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>, ) -> BoxFuture<'_, Result<Response<AddOrUpdateRemoteClusterResponse>, Status>>
Source§fn remove_remote_cluster(
&mut self,
request: impl IntoRequest<RemoveRemoteClusterRequest>,
) -> BoxFuture<'_, Result<Response<RemoveRemoteClusterResponse>, Status>>
fn remove_remote_cluster( &mut self, request: impl IntoRequest<RemoveRemoteClusterRequest>, ) -> BoxFuture<'_, Result<Response<RemoveRemoteClusterResponse>, Status>>
Source§fn list_clusters(
&mut self,
request: impl IntoRequest<ListClustersRequest>,
) -> BoxFuture<'_, Result<Response<ListClustersResponse>, Status>>
fn list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest>, ) -> BoxFuture<'_, Result<Response<ListClustersResponse>, 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 list_nexus_endpoints(
&mut self,
request: impl IntoRequest<ListNexusEndpointsRequest>,
) -> BoxFuture<'_, Result<Response<ListNexusEndpointsResponse>, Status>>
fn list_nexus_endpoints( &mut self, request: impl IntoRequest<ListNexusEndpointsRequest>, ) -> BoxFuture<'_, Result<Response<ListNexusEndpointsResponse>, Status>>
Source§impl<RC, T> TestService 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> TestService 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 lock_time_skipping(
&mut self,
request: impl IntoRequest<LockTimeSkippingRequest>,
) -> BoxFuture<'_, Result<Response<LockTimeSkippingResponse>, Status>>
fn lock_time_skipping( &mut self, request: impl IntoRequest<LockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<LockTimeSkippingResponse>, Status>>
Source§fn unlock_time_skipping(
&mut self,
request: impl IntoRequest<UnlockTimeSkippingRequest>,
) -> BoxFuture<'_, Result<Response<UnlockTimeSkippingResponse>, Status>>
fn unlock_time_skipping( &mut self, request: impl IntoRequest<UnlockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<UnlockTimeSkippingResponse>, Status>>
Source§fn sleep(
&mut self,
request: impl IntoRequest<SleepRequest>,
) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
fn sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
Source§fn sleep_until(
&mut self,
request: impl IntoRequest<SleepUntilRequest>,
) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
fn sleep_until( &mut self, request: impl IntoRequest<SleepUntilRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
Source§fn unlock_time_skipping_with_sleep(
&mut self,
request: impl IntoRequest<SleepRequest>,
) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
fn unlock_time_skipping_with_sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>
Source§fn get_current_time(
&mut self,
request: impl IntoRequest<()>,
) -> BoxFuture<'_, Result<Response<GetCurrentTimeResponse>, Status>>
fn get_current_time( &mut self, request: impl IntoRequest<()>, ) -> BoxFuture<'_, Result<Response<GetCurrentTimeResponse>, Status>>
Source§impl<T> WfClientExt for Twhere
T: WfHandleClient + Clone,
impl<T> WfClientExt for Twhere
T: WfHandleClient + Clone,
Source§fn get_untyped_workflow_handle(
&self,
workflow_id: impl Into<String>,
run_id: impl Into<String>,
) -> WorkflowHandle<Self, Vec<Payload>>
fn get_untyped_workflow_handle( &self, workflow_id: impl Into<String>, run_id: impl Into<String>, ) -> WorkflowHandle<Self, Vec<Payload>>
run_id may be left blank to target the latest run.