pub struct Client { /* private fields */ }
Expand description
Contains an instance of a namespace-bound client for interacting with the Temporal server
Implementations§
Source§impl Client
impl Client
Sourcepub fn new(
client: ConfiguredClient<TemporalServiceClientWithMetrics>,
namespace: String,
) -> Self
pub fn new( client: ConfiguredClient<TemporalServiceClientWithMetrics>, namespace: String, ) -> Self
Create a new client from an existing configured lower level client and a namespace
Sourcepub fn raw_retry_client(&self) -> RetryClient<WorkflowServiceClientWithMetrics>
pub fn raw_retry_client(&self) -> RetryClient<WorkflowServiceClientWithMetrics>
Return an auto-retrying version of the underling grpc client (instrumented with metrics collection, if enabled).
Note that it is reasonably cheap to clone the returned type if you need to own it. Such clones will keep re-using the same channel.
Sourcepub fn raw_client(&self) -> &WorkflowServiceClientWithMetrics
pub fn raw_client(&self) -> &WorkflowServiceClientWithMetrics
Access the underling grpc client. This raw client is not bound to a specific namespace.
Note that it is reasonably cheap to clone the returned type if you need to own it. Such clones will keep re-using the same channel.
Sourcepub fn options(&self) -> &ClientOptions
pub fn options(&self) -> &ClientOptions
Return the options this client was initialized with
Sourcepub fn options_mut(&mut self) -> &mut ClientOptions
pub fn options_mut(&mut self) -> &mut ClientOptions
Return the options this client was initialized with mutably
Sourcepub fn inner(&self) -> &ConfiguredClient<TemporalServiceClientWithMetrics>
pub fn inner(&self) -> &ConfiguredClient<TemporalServiceClientWithMetrics>
Returns a reference to the underlying client
Sourcepub fn into_inner(self) -> ConfiguredClient<TemporalServiceClientWithMetrics>
pub fn into_inner(self) -> ConfiguredClient<TemporalServiceClientWithMetrics>
Consumes self and returns the underlying client
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for Client
impl !RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
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::Request
Source§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.