Struct google_api_proto::google::devtools::testing::v1::direct_access_service_client::DirectAccessServiceClient
source · pub struct DirectAccessServiceClient<T> { /* private fields */ }
Expand description
A service for allocating devices and interacting with the live-allocated devices.
This service is part of Firebase Test Lab. To learn about how to use the product, and how to integrate it with your system, visit https://firebase.google.com/docs/test-lab.
Each Session will wait for available capacity, at a higher priority over Test Execution. When allocated, the session will be exposed through a stream for integration.
DirectAccessService is currently available as a preview to select developers. You can register today on behalf of you and your team at https://developer.android.com/studio/preview/android-device-streaming
Implementations§
source§impl<T> DirectAccessServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> DirectAccessServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_origin(inner: T, origin: Uri) -> Self
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> DirectAccessServiceClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
sourcepub async fn create_device_session(
&mut self,
request: impl IntoRequest<CreateDeviceSessionRequest>,
) -> Result<Response<DeviceSession>, Status>
pub async fn create_device_session( &mut self, request: impl IntoRequest<CreateDeviceSessionRequest>, ) -> Result<Response<DeviceSession>, Status>
POST /v1/projects/{project_id}/deviceSessions
sourcepub async fn list_device_sessions(
&mut self,
request: impl IntoRequest<ListDeviceSessionsRequest>,
) -> Result<Response<ListDeviceSessionsResponse>, Status>
pub async fn list_device_sessions( &mut self, request: impl IntoRequest<ListDeviceSessionsRequest>, ) -> Result<Response<ListDeviceSessionsResponse>, Status>
GET /v1/projects/{project_id}/deviceSessions Lists device Sessions owned by the project user.
sourcepub async fn get_device_session(
&mut self,
request: impl IntoRequest<GetDeviceSessionRequest>,
) -> Result<Response<DeviceSession>, Status>
pub async fn get_device_session( &mut self, request: impl IntoRequest<GetDeviceSessionRequest>, ) -> Result<Response<DeviceSession>, Status>
GET /v1/projects/{project_id}/deviceSessions/{device_session_id} Return a DeviceSession, which documents the allocation status and whether the device is allocated. Clients making requests from this API must poll GetDeviceSession.
sourcepub async fn cancel_device_session(
&mut self,
request: impl IntoRequest<CancelDeviceSessionRequest>,
) -> Result<Response<()>, Status>
pub async fn cancel_device_session( &mut self, request: impl IntoRequest<CancelDeviceSessionRequest>, ) -> Result<Response<()>, Status>
POST /v1/projects/{project_id}/deviceSessions/{device_session_id}:cancel Changes the DeviceSession to state FINISHED and terminates all connections. Canceled sessions are not deleted and can be retrieved or listed by the user until they expire based on the 28 day deletion policy.
sourcepub async fn update_device_session(
&mut self,
request: impl IntoRequest<UpdateDeviceSessionRequest>,
) -> Result<Response<DeviceSession>, Status>
pub async fn update_device_session( &mut self, request: impl IntoRequest<UpdateDeviceSessionRequest>, ) -> Result<Response<DeviceSession>, Status>
PATCH /v1/projects/{projectId}/deviceSessions/deviceSessionId}:updateDeviceSession Updates the current device session to the fields described by the update_mask.
sourcepub async fn adb_connect(
&mut self,
request: impl IntoStreamingRequest<Message = AdbMessage>,
) -> Result<Response<Streaming<DeviceMessage>>, Status>
pub async fn adb_connect( &mut self, request: impl IntoStreamingRequest<Message = AdbMessage>, ) -> Result<Response<Streaming<DeviceMessage>>, Status>
Exposes ADB connection for use with the Adb Device Forwarder project if the reserved device supports ADB. gRPC headers are used to authenticate the Connect RPC, as well as associate to a particular device session. In particular, the user must specify the “X-FTL-Session-Name” header.
Trait Implementations§
source§impl<T: Clone> Clone for DirectAccessServiceClient<T>
impl<T: Clone> Clone for DirectAccessServiceClient<T>
source§fn clone(&self) -> DirectAccessServiceClient<T>
fn clone(&self) -> DirectAccessServiceClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl<T> !Freeze for DirectAccessServiceClient<T>
impl<T> RefUnwindSafe for DirectAccessServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for DirectAccessServiceClient<T>where
T: Send,
impl<T> Sync for DirectAccessServiceClient<T>where
T: Sync,
impl<T> Unpin for DirectAccessServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for DirectAccessServiceClient<T>where
T: UnwindSafe,
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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