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<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>,
namespace: String,
) -> Client
pub fn new( client: ConfiguredClient<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>, namespace: String, ) -> Client
Create a new client from an existing configured lower level client and a namespace
Sourcepub fn raw_retry_client(
&self,
) -> RetryClient<WorkflowServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
pub fn raw_retry_client( &self, ) -> RetryClient<WorkflowServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
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,
) -> &WorkflowServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>
pub fn raw_client( &self, ) -> &WorkflowServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>
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<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
pub fn inner( &self, ) -> &ConfiguredClient<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
Returns a reference to the underlying client
Sourcepub fn into_inner(
self,
) -> ConfiguredClient<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
pub fn into_inner( self, ) -> ConfiguredClient<TemporalServiceClient<InterceptedService<GrpcMetricSvc, ServiceCallInterceptor>>>
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
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>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUsersResponse>, Status>> + Send + '_>>
fn get_users( &mut self, request: impl IntoRequest<GetUsersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUsersResponse>, Status>> + Send + '_>>
Source§fn get_user(
&mut self,
request: impl IntoRequest<GetUserRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUserResponse>, Status>> + Send + '_>>
fn get_user( &mut self, request: impl IntoRequest<GetUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserResponse>, Status>> + Send + '_>>
Source§fn create_user(
&mut self,
request: impl IntoRequest<CreateUserRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserResponse>, Status>> + Send + '_>>
fn create_user( &mut self, request: impl IntoRequest<CreateUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserResponse>, Status>> + Send + '_>>
Source§fn update_user(
&mut self,
request: impl IntoRequest<UpdateUserRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserResponse>, Status>> + Send + '_>>
fn update_user( &mut self, request: impl IntoRequest<UpdateUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserResponse>, Status>> + Send + '_>>
Source§fn delete_user(
&mut self,
request: impl IntoRequest<DeleteUserRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserResponse>, Status>> + Send + '_>>
fn delete_user( &mut self, request: impl IntoRequest<DeleteUserRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserResponse>, Status>> + Send + '_>>
Source§fn set_user_namespace_access(
&mut self,
request: impl IntoRequest<SetUserNamespaceAccessRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SetUserNamespaceAccessResponse>, Status>> + Send + '_>>
fn set_user_namespace_access( &mut self, request: impl IntoRequest<SetUserNamespaceAccessRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetUserNamespaceAccessResponse>, Status>> + Send + '_>>
Source§fn get_async_operation(
&mut self,
request: impl IntoRequest<GetAsyncOperationRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetAsyncOperationResponse>, Status>> + Send + '_>>
fn get_async_operation( &mut self, request: impl IntoRequest<GetAsyncOperationRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAsyncOperationResponse>, Status>> + Send + '_>>
Source§fn create_namespace(
&mut self,
request: impl IntoRequest<CreateNamespaceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceResponse>, Status>> + Send + '_>>
fn create_namespace( &mut self, request: impl IntoRequest<CreateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceResponse>, Status>> + Send + '_>>
Source§fn get_namespaces(
&mut self,
request: impl IntoRequest<GetNamespacesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespacesResponse>, Status>> + Send + '_>>
fn get_namespaces( &mut self, request: impl IntoRequest<GetNamespacesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespacesResponse>, Status>> + Send + '_>>
Source§fn get_namespace(
&mut self,
request: impl IntoRequest<GetNamespaceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceResponse>, Status>> + Send + '_>>
fn get_namespace( &mut self, request: impl IntoRequest<GetNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceResponse>, Status>> + Send + '_>>
Source§fn update_namespace(
&mut self,
request: impl IntoRequest<UpdateNamespaceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceResponse>, Status>> + Send + '_>>
fn update_namespace( &mut self, request: impl IntoRequest<UpdateNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceResponse>, Status>> + Send + '_>>
Source§fn rename_custom_search_attribute(
&mut self,
request: impl IntoRequest<RenameCustomSearchAttributeRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<RenameCustomSearchAttributeResponse>, Status>> + Send + '_>>
fn rename_custom_search_attribute( &mut self, request: impl IntoRequest<RenameCustomSearchAttributeRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RenameCustomSearchAttributeResponse>, Status>> + Send + '_>>
Source§fn delete_namespace(
&mut self,
request: impl IntoRequest<DeleteNamespaceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>
fn delete_namespace( &mut self, request: impl IntoRequest<DeleteNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>
Source§fn failover_namespace_region(
&mut self,
request: impl IntoRequest<FailoverNamespaceRegionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<FailoverNamespaceRegionResponse>, Status>> + Send + '_>>
fn failover_namespace_region( &mut self, request: impl IntoRequest<FailoverNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<FailoverNamespaceRegionResponse>, Status>> + Send + '_>>
Source§fn add_namespace_region(
&mut self,
request: impl IntoRequest<AddNamespaceRegionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddNamespaceRegionResponse>, Status>> + Send + '_>>
fn add_namespace_region( &mut self, request: impl IntoRequest<AddNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddNamespaceRegionResponse>, Status>> + Send + '_>>
Source§fn delete_namespace_region(
&mut self,
request: impl IntoRequest<DeleteNamespaceRegionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceRegionResponse>, Status>> + Send + '_>>
fn delete_namespace_region( &mut self, request: impl IntoRequest<DeleteNamespaceRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceRegionResponse>, Status>> + Send + '_>>
Source§fn get_regions(
&mut self,
request: impl IntoRequest<GetRegionsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionsResponse>, Status>> + Send + '_>>
fn get_regions( &mut self, request: impl IntoRequest<GetRegionsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionsResponse>, Status>> + Send + '_>>
Source§fn get_region(
&mut self,
request: impl IntoRequest<GetRegionRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionResponse>, Status>> + Send + '_>>
fn get_region( &mut self, request: impl IntoRequest<GetRegionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRegionResponse>, Status>> + Send + '_>>
Source§fn get_api_keys(
&mut self,
request: impl IntoRequest<GetApiKeysRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeysResponse>, Status>> + Send + '_>>
fn get_api_keys( &mut self, request: impl IntoRequest<GetApiKeysRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeysResponse>, Status>> + Send + '_>>
Source§fn get_api_key(
&mut self,
request: impl IntoRequest<GetApiKeyRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeyResponse>, Status>> + Send + '_>>
fn get_api_key( &mut self, request: impl IntoRequest<GetApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetApiKeyResponse>, Status>> + Send + '_>>
Source§fn create_api_key(
&mut self,
request: impl IntoRequest<CreateApiKeyRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + '_>>
fn create_api_key( &mut self, request: impl IntoRequest<CreateApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateApiKeyResponse>, Status>> + Send + '_>>
Source§fn update_api_key(
&mut self,
request: impl IntoRequest<UpdateApiKeyRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateApiKeyResponse>, Status>> + Send + '_>>
fn update_api_key( &mut self, request: impl IntoRequest<UpdateApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateApiKeyResponse>, Status>> + Send + '_>>
Source§fn delete_api_key(
&mut self,
request: impl IntoRequest<DeleteApiKeyRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteApiKeyResponse>, Status>> + Send + '_>>
fn delete_api_key( &mut self, request: impl IntoRequest<DeleteApiKeyRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteApiKeyResponse>, Status>> + Send + '_>>
Source§fn get_nexus_endpoints(
&mut self,
request: impl IntoRequest<GetNexusEndpointsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointsResponse>, Status>> + Send + '_>>
fn get_nexus_endpoints( &mut self, request: impl IntoRequest<GetNexusEndpointsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointsResponse>, Status>> + Send + '_>>
Source§fn get_nexus_endpoint(
&mut self,
request: impl IntoRequest<GetNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>
fn get_nexus_endpoint( &mut self, request: impl IntoRequest<GetNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn create_nexus_endpoint(
&mut self,
request: impl IntoRequest<CreateNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>
fn create_nexus_endpoint( &mut self, request: impl IntoRequest<CreateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn update_nexus_endpoint(
&mut self,
request: impl IntoRequest<UpdateNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>
fn update_nexus_endpoint( &mut self, request: impl IntoRequest<UpdateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn delete_nexus_endpoint(
&mut self,
request: impl IntoRequest<DeleteNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>
fn delete_nexus_endpoint( &mut self, request: impl IntoRequest<DeleteNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn get_user_groups(
&mut self,
request: impl IntoRequest<GetUserGroupsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupsResponse>, Status>> + Send + '_>>
fn get_user_groups( &mut self, request: impl IntoRequest<GetUserGroupsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupsResponse>, Status>> + Send + '_>>
Source§fn get_user_group(
&mut self,
request: impl IntoRequest<GetUserGroupRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupResponse>, Status>> + Send + '_>>
fn get_user_group( &mut self, request: impl IntoRequest<GetUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupResponse>, Status>> + Send + '_>>
Source§fn create_user_group(
&mut self,
request: impl IntoRequest<CreateUserGroupRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserGroupResponse>, Status>> + Send + '_>>
fn create_user_group( &mut self, request: impl IntoRequest<CreateUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateUserGroupResponse>, Status>> + Send + '_>>
Source§fn update_user_group(
&mut self,
request: impl IntoRequest<UpdateUserGroupRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserGroupResponse>, Status>> + Send + '_>>
fn update_user_group( &mut self, request: impl IntoRequest<UpdateUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateUserGroupResponse>, Status>> + Send + '_>>
Source§fn delete_user_group(
&mut self,
request: impl IntoRequest<DeleteUserGroupRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserGroupResponse>, Status>> + Send + '_>>
fn delete_user_group( &mut self, request: impl IntoRequest<DeleteUserGroupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteUserGroupResponse>, Status>> + Send + '_>>
Source§fn add_user_group_member(
&mut self,
request: impl IntoRequest<AddUserGroupMemberRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddUserGroupMemberResponse>, Status>> + Send + '_>>
fn add_user_group_member( &mut self, request: impl IntoRequest<AddUserGroupMemberRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddUserGroupMemberResponse>, Status>> + Send + '_>>
Source§fn remove_user_group_member(
&mut self,
request: impl IntoRequest<RemoveUserGroupMemberRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<RemoveUserGroupMemberResponse>, Status>> + Send + '_>>
fn remove_user_group_member( &mut self, request: impl IntoRequest<RemoveUserGroupMemberRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveUserGroupMemberResponse>, Status>> + Send + '_>>
Source§fn get_user_group_members(
&mut self,
request: impl IntoRequest<GetUserGroupMembersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupMembersResponse>, Status>> + Send + '_>>
fn get_user_group_members( &mut self, request: impl IntoRequest<GetUserGroupMembersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUserGroupMembersResponse>, Status>> + Send + '_>>
Source§fn set_user_group_namespace_access(
&mut self,
request: impl IntoRequest<SetUserGroupNamespaceAccessRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SetUserGroupNamespaceAccessResponse>, Status>> + Send + '_>>
fn set_user_group_namespace_access( &mut self, request: impl IntoRequest<SetUserGroupNamespaceAccessRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SetUserGroupNamespaceAccessResponse>, Status>> + Send + '_>>
Source§fn create_service_account(
&mut self,
request: impl IntoRequest<CreateServiceAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateServiceAccountResponse>, Status>> + Send + '_>>
fn create_service_account( &mut self, request: impl IntoRequest<CreateServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateServiceAccountResponse>, Status>> + Send + '_>>
Source§fn get_service_account(
&mut self,
request: impl IntoRequest<GetServiceAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountResponse>, Status>> + Send + '_>>
fn get_service_account( &mut self, request: impl IntoRequest<GetServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountResponse>, Status>> + Send + '_>>
Source§fn get_service_accounts(
&mut self,
request: impl IntoRequest<GetServiceAccountsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountsResponse>, Status>> + Send + '_>>
fn get_service_accounts( &mut self, request: impl IntoRequest<GetServiceAccountsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetServiceAccountsResponse>, Status>> + Send + '_>>
Source§fn update_service_account(
&mut self,
request: impl IntoRequest<UpdateServiceAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateServiceAccountResponse>, Status>> + Send + '_>>
fn update_service_account( &mut self, request: impl IntoRequest<UpdateServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateServiceAccountResponse>, Status>> + Send + '_>>
Source§fn delete_service_account(
&mut self,
request: impl IntoRequest<DeleteServiceAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteServiceAccountResponse>, Status>> + Send + '_>>
fn delete_service_account( &mut self, request: impl IntoRequest<DeleteServiceAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteServiceAccountResponse>, Status>> + Send + '_>>
Source§fn get_usage(
&mut self,
request: impl IntoRequest<GetUsageRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetUsageResponse>, Status>> + Send + '_>>
fn get_usage( &mut self, request: impl IntoRequest<GetUsageRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetUsageResponse>, Status>> + Send + '_>>
Source§fn get_account(
&mut self,
request: impl IntoRequest<GetAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetAccountResponse>, Status>> + Send + '_>>
fn get_account( &mut self, request: impl IntoRequest<GetAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAccountResponse>, Status>> + Send + '_>>
Source§fn update_account(
&mut self,
request: impl IntoRequest<UpdateAccountRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateAccountResponse>, Status>> + Send + '_>>
fn update_account( &mut self, request: impl IntoRequest<UpdateAccountRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateAccountResponse>, Status>> + Send + '_>>
Source§fn create_namespace_export_sink(
&mut self,
request: impl IntoRequest<CreateNamespaceExportSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceExportSinkResponse>, Status>> + Send + '_>>
fn create_namespace_export_sink( &mut self, request: impl IntoRequest<CreateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNamespaceExportSinkResponse>, Status>> + Send + '_>>
Source§fn get_namespace_export_sink(
&mut self,
request: impl IntoRequest<GetNamespaceExportSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinkResponse>, Status>> + Send + '_>>
fn get_namespace_export_sink( &mut self, request: impl IntoRequest<GetNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinkResponse>, Status>> + Send + '_>>
Source§fn get_namespace_export_sinks(
&mut self,
request: impl IntoRequest<GetNamespaceExportSinksRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinksResponse>, Status>> + Send + '_>>
fn get_namespace_export_sinks( &mut self, request: impl IntoRequest<GetNamespaceExportSinksRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNamespaceExportSinksResponse>, Status>> + Send + '_>>
Source§fn update_namespace_export_sink(
&mut self,
request: impl IntoRequest<UpdateNamespaceExportSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceExportSinkResponse>, Status>> + Send + '_>>
fn update_namespace_export_sink( &mut self, request: impl IntoRequest<UpdateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNamespaceExportSinkResponse>, Status>> + Send + '_>>
Source§fn delete_namespace_export_sink(
&mut self,
request: impl IntoRequest<DeleteNamespaceExportSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceExportSinkResponse>, Status>> + Send + '_>>
fn delete_namespace_export_sink( &mut self, request: impl IntoRequest<DeleteNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceExportSinkResponse>, Status>> + Send + '_>>
Source§fn validate_namespace_export_sink(
&mut self,
request: impl IntoRequest<ValidateNamespaceExportSinkRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ValidateNamespaceExportSinkResponse>, Status>> + Send + '_>>
fn validate_namespace_export_sink( &mut self, request: impl IntoRequest<ValidateNamespaceExportSinkRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ValidateNamespaceExportSinkResponse>, Status>> + Send + '_>>
Source§fn create_connectivity_rule(
&mut self,
request: impl IntoRequest<CreateConnectivityRuleRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateConnectivityRuleResponse>, Status>> + Send + '_>>
fn create_connectivity_rule( &mut self, request: impl IntoRequest<CreateConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateConnectivityRuleResponse>, Status>> + Send + '_>>
Source§fn get_connectivity_rule(
&mut self,
request: impl IntoRequest<GetConnectivityRuleRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRuleResponse>, Status>> + Send + '_>>
fn get_connectivity_rule( &mut self, request: impl IntoRequest<GetConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRuleResponse>, Status>> + Send + '_>>
Source§fn get_connectivity_rules(
&mut self,
request: impl IntoRequest<GetConnectivityRulesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRulesResponse>, Status>> + Send + '_>>
fn get_connectivity_rules( &mut self, request: impl IntoRequest<GetConnectivityRulesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetConnectivityRulesResponse>, Status>> + Send + '_>>
Source§fn delete_connectivity_rule(
&mut self,
request: impl IntoRequest<DeleteConnectivityRuleRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteConnectivityRuleResponse>, Status>> + Send + '_>>
fn delete_connectivity_rule( &mut self, request: impl IntoRequest<DeleteConnectivityRuleRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteConnectivityRuleResponse>, Status>> + Send + '_>>
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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>,
) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + '_>>
fn check( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<HealthCheckResponse>, Status>> + Send + '_>>
Source§fn watch(
&mut self,
request: impl IntoRequest<HealthCheckRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<HealthCheckResponse>>, Status>> + Send + '_>>
fn watch( &mut self, request: impl IntoRequest<HealthCheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Streaming<HealthCheckResponse>>, Status>> + Send + '_>>
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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::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>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddSearchAttributesResponse>, Status>> + Send + '_>>
fn add_search_attributes( &mut self, request: impl IntoRequest<AddSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddSearchAttributesResponse>, Status>> + Send + '_>>
Source§fn remove_search_attributes(
&mut self,
request: impl IntoRequest<RemoveSearchAttributesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<RemoveSearchAttributesResponse>, Status>> + Send + '_>>
fn remove_search_attributes( &mut self, request: impl IntoRequest<RemoveSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveSearchAttributesResponse>, Status>> + Send + '_>>
Source§fn list_search_attributes(
&mut self,
request: impl IntoRequest<ListSearchAttributesRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListSearchAttributesResponse>, Status>> + Send + '_>>
fn list_search_attributes( &mut self, request: impl IntoRequest<ListSearchAttributesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListSearchAttributesResponse>, Status>> + Send + '_>>
Source§fn delete_namespace(
&mut self,
request: impl IntoRequest<DeleteNamespaceRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>
fn delete_namespace( &mut self, request: impl IntoRequest<DeleteNamespaceRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNamespaceResponse>, Status>> + Send + '_>>
Source§fn add_or_update_remote_cluster(
&mut self,
request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<AddOrUpdateRemoteClusterResponse>, Status>> + Send + '_>>
fn add_or_update_remote_cluster( &mut self, request: impl IntoRequest<AddOrUpdateRemoteClusterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<AddOrUpdateRemoteClusterResponse>, Status>> + Send + '_>>
Source§fn remove_remote_cluster(
&mut self,
request: impl IntoRequest<RemoveRemoteClusterRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<RemoveRemoteClusterResponse>, Status>> + Send + '_>>
fn remove_remote_cluster( &mut self, request: impl IntoRequest<RemoveRemoteClusterRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RemoveRemoteClusterResponse>, Status>> + Send + '_>>
Source§fn list_clusters(
&mut self,
request: impl IntoRequest<ListClustersRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListClustersResponse>, Status>> + Send + '_>>
fn list_clusters( &mut self, request: impl IntoRequest<ListClustersRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListClustersResponse>, Status>> + Send + '_>>
Source§fn get_nexus_endpoint(
&mut self,
request: impl IntoRequest<GetNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>
fn get_nexus_endpoint( &mut self, request: impl IntoRequest<GetNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn create_nexus_endpoint(
&mut self,
request: impl IntoRequest<CreateNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>
fn create_nexus_endpoint( &mut self, request: impl IntoRequest<CreateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn update_nexus_endpoint(
&mut self,
request: impl IntoRequest<UpdateNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>
fn update_nexus_endpoint( &mut self, request: impl IntoRequest<UpdateNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn delete_nexus_endpoint(
&mut self,
request: impl IntoRequest<DeleteNexusEndpointRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>
fn delete_nexus_endpoint( &mut self, request: impl IntoRequest<DeleteNexusEndpointRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<DeleteNexusEndpointResponse>, Status>> + Send + '_>>
Source§fn list_nexus_endpoints(
&mut self,
request: impl IntoRequest<ListNexusEndpointsRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListNexusEndpointsResponse>, Status>> + Send + '_>>
fn list_nexus_endpoints( &mut self, request: impl IntoRequest<ListNexusEndpointsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListNexusEndpointsResponse>, Status>> + Send + '_>>
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
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>,
) -> Pin<Box<dyn Future<Output = Result<Response<LockTimeSkippingResponse>, Status>> + Send + '_>>
fn lock_time_skipping( &mut self, request: impl IntoRequest<LockTimeSkippingRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<LockTimeSkippingResponse>, Status>> + Send + '_>>
Source§fn unlock_time_skipping(
&mut self,
request: impl IntoRequest<UnlockTimeSkippingRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<UnlockTimeSkippingResponse>, Status>> + Send + '_>>
fn unlock_time_skipping( &mut self, request: impl IntoRequest<UnlockTimeSkippingRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UnlockTimeSkippingResponse>, Status>> + Send + '_>>
Source§fn sleep(
&mut self,
request: impl IntoRequest<SleepRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
fn sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
Source§fn sleep_until(
&mut self,
request: impl IntoRequest<SleepUntilRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
fn sleep_until( &mut self, request: impl IntoRequest<SleepUntilRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
Source§fn unlock_time_skipping_with_sleep(
&mut self,
request: impl IntoRequest<SleepRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
fn unlock_time_skipping_with_sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SleepResponse>, Status>> + Send + '_>>
Source§fn get_current_time(
&mut self,
request: impl IntoRequest<()>,
) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentTimeResponse>, Status>> + Send + '_>>
fn get_current_time( &mut self, request: impl IntoRequest<()>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetCurrentTimeResponse>, Status>> + Send + '_>>
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>>
Create an untyped handle for a workflow execution, which can be used to do things like
wait for that workflow’s result.
run_id may be left blank to target the latest run.