TestService

squads_temporal_client

Trait TestService 

Source 
pub trait TestService: RawClientLike
where
    <Self as RawClientLike>::SvcType: GrpcService<Body> + Send + Clone + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody: Body<Data = Bytes> + Send + 'static,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Error: Into<StdError>,
    <<Self as RawClientLike>::SvcType as GrpcService<Body>>::Future: Send,
    <<<Self as RawClientLike>::SvcType as GrpcService<Body>>::ResponseBody as Body>::Error: Into<StdError> + Send,
{
    // Provided methods
    fn lock_time_skipping(
        &mut self,
        request: impl IntoRequest<LockTimeSkippingRequest>,
    ) -> BoxFuture<'_, Result<Response<LockTimeSkippingResponse>, Status>> { ... }
    fn unlock_time_skipping(
        &mut self,
        request: impl IntoRequest<UnlockTimeSkippingRequest>,
    ) -> BoxFuture<'_, Result<Response<UnlockTimeSkippingResponse>, Status>> { ... }
    fn sleep(
        &mut self,
        request: impl IntoRequest<SleepRequest>,
    ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>> { ... }
    fn sleep_until(
        &mut self,
        request: impl IntoRequest<SleepUntilRequest>,
    ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>> { ... }
    fn unlock_time_skipping_with_sleep(
        &mut self,
        request: impl IntoRequest<SleepRequest>,
    ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>> { ... }
    fn get_current_time(
        &mut self,
        request: impl IntoRequest<()>,
    ) -> BoxFuture<'_, Result<Response<GetCurrentTimeResponse>, Status>> { ... }
}
Expand description

Trait version of the generated client with modifications to attach appropriate metric labels or whatever else to requests

Provided Methods§

Source

fn lock_time_skipping( &mut self, request: impl IntoRequest<LockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<LockTimeSkippingResponse>, Status>>

See TestServiceClient::lock_time_skipping

Source

fn unlock_time_skipping( &mut self, request: impl IntoRequest<UnlockTimeSkippingRequest>, ) -> BoxFuture<'_, Result<Response<UnlockTimeSkippingResponse>, Status>>

See TestServiceClient::unlock_time_skipping

Source

fn sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::sleep

Source

fn sleep_until( &mut self, request: impl IntoRequest<SleepUntilRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::sleep_until

Source

fn unlock_time_skipping_with_sleep( &mut self, request: impl IntoRequest<SleepRequest>, ) -> BoxFuture<'_, Result<Response<SleepResponse>, Status>>

See TestServiceClient::unlock_time_skipping_with_sleep

Source

fn get_current_time( &mut self, request: impl IntoRequest<()>, ) -> BoxFuture<'_, Result<Response<GetCurrentTimeResponse>, Status>>

See TestServiceClient::get_current_time

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<RC, T> TestService for RC
where RC: RawClientLike<SvcType = T>, T: GrpcService<Body> + Send + Clone + 'static, T::ResponseBody: Body<Data = Bytes> + Send + 'static, T::Error: Into<StdError>, T::Future: Send, <T::ResponseBody as Body>::Error: Into<StdError> + Send,