Struct google_api_proto::google::cloud::bigquery::v2::job_service_client::JobServiceClient

pub struct JobServiceClient<T> { /* private fields */ }

This is an experimental RPC service definition for the BigQuery Job Service.

It should not be relied on for production use cases at this time.

Implementations

impl<T> JobServiceClient<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, ) -> JobServiceClient<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,

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.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn cancel_job( &mut self, request: impl IntoRequest<CancelJobRequest>, ) -> Result<Response<JobCancelResponse>, Status>

Requests that a job be cancelled. This call will return immediately, and the client will need to poll for the job status to see if the cancel completed successfully. Cancelled jobs may still incur costs.

pub async fn get_job( &mut self, request: impl IntoRequest<GetJobRequest>, ) -> Result<Response<Job>, Status>

Returns information about a specific job. Job information is available for a six month period after creation. Requires that you’re the person who ran the job, or have the Is Owner project role.

pub async fn insert_job( &mut self, request: impl IntoRequest<InsertJobRequest>, ) -> Result<Response<Job>, Status>

Starts a new asynchronous job.

This API has two different kinds of endpoint URIs, as this method supports a variety of use cases.

• The Metadata URI is used for most interactions, as it accepts the job configuration directly.
• The Upload URI is ONLY for the case when you’re sending both a load job configuration and a data stream together. In this case, the Upload URI accepts the job configuration and the data as two distinct multipart MIME parts.

pub async fn delete_job( &mut self, request: impl IntoRequest<DeleteJobRequest>, ) -> Result<Response<()>, Status>

Requests the deletion of the metadata of a job. This call returns when the job’s metadata is deleted.

pub async fn list_jobs( &mut self, request: impl IntoRequest<ListJobsRequest>, ) -> Result<Response<JobList>, Status>

Lists all jobs that you started in the specified project. Job information is available for a six month period after creation. The job list is sorted in reverse chronological order, by job creation time. Requires the Can View project role, or the Is Owner project role if you set the allUsers property.

pub async fn get_query_results( &mut self, request: impl IntoRequest<GetQueryResultsRequest>, ) -> Result<Response<GetQueryResultsResponse>, Status>

RPC to get the results of a query job.

pub async fn query( &mut self, request: impl IntoRequest<PostQueryRequest>, ) -> Result<Response<QueryResponse>, Status>

Runs a BigQuery SQL query synchronously and returns query results if the query completes within a specified timeout.

Trait Implementations

impl<T: Clone> Clone for JobServiceClient<T>

fn clone(&self) -> JobServiceClient<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for JobServiceClient<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.