Struct gapi_grpc::google::cloud::bigquery::datatransfer::v1::data_transfer_service_client::DataTransferServiceClient

pub struct DataTransferServiceClient<T> { /* fields omitted */ }

The Google BigQuery Data Transfer Service API enables BigQuery users to configure the transfer of their data from other Google Products into BigQuery. This service contains methods that are end user exposed. It backs up the frontend.

Implementations

impl DataTransferServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error> where
    D: TryInto<Endpoint>,
    D::Error: Into<StdError>, 

Attempt to create a new client by connecting to a given endpoint.

impl<T> DataTransferServiceClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

pub async fn get_data_source(
    &mut self,
    request: impl IntoRequest<GetDataSourceRequest>
) -> Result<Response<DataSource>, Status>

Retrieves a supported data source and returns its settings, which can be used for UI rendering.

pub async fn list_data_sources(
    &mut self,
    request: impl IntoRequest<ListDataSourcesRequest>
) -> Result<Response<ListDataSourcesResponse>, Status>

Lists supported data sources and returns their settings, which can be used for UI rendering.

pub async fn create_transfer_config(
    &mut self,
    request: impl IntoRequest<CreateTransferConfigRequest>
) -> Result<Response<TransferConfig>, Status>

Creates a new data transfer configuration.

pub async fn update_transfer_config(
    &mut self,
    request: impl IntoRequest<UpdateTransferConfigRequest>
) -> Result<Response<TransferConfig>, Status>

Updates a data transfer configuration. All fields must be set, even if they are not updated.

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

Deletes a data transfer configuration, including any associated transfer runs and logs.

pub async fn get_transfer_config(
    &mut self,
    request: impl IntoRequest<GetTransferConfigRequest>
) -> Result<Response<TransferConfig>, Status>

Returns information about a data transfer config.

pub async fn list_transfer_configs(
    &mut self,
    request: impl IntoRequest<ListTransferConfigsRequest>
) -> Result<Response<ListTransferConfigsResponse>, Status>

Returns information about all data transfers in the project.

pub async fn schedule_transfer_runs(
    &mut self,
    request: impl IntoRequest<ScheduleTransferRunsRequest>
) -> Result<Response<ScheduleTransferRunsResponse>, Status>

Creates transfer runs for a time range [start_time, end_time]. For each date - or whatever granularity the data source supports - in the range, one transfer run is created. Note that runs are created per UTC time in the time range. DEPRECATED: use StartManualTransferRuns instead.

pub async fn start_manual_transfer_runs(
    &mut self,
    request: impl IntoRequest<StartManualTransferRunsRequest>
) -> Result<Response<StartManualTransferRunsResponse>, Status>

Start manual transfer runs to be executed now with schedule_time equal to current time. The transfer runs can be created for a time range where the run_time is between start_time (inclusive) and end_time (exclusive), or for a specific run_time.

pub async fn get_transfer_run(
    &mut self,
    request: impl IntoRequest<GetTransferRunRequest>
) -> Result<Response<TransferRun>, Status>

Returns information about the particular transfer run.

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

Deletes the specified transfer run.

pub async fn list_transfer_runs(
    &mut self,
    request: impl IntoRequest<ListTransferRunsRequest>
) -> Result<Response<ListTransferRunsResponse>, Status>

Returns information about running and completed jobs.

pub async fn list_transfer_logs(
    &mut self,
    request: impl IntoRequest<ListTransferLogsRequest>
) -> Result<Response<ListTransferLogsResponse>, Status>

Returns user facing log messages for the data transfer run.

pub async fn check_valid_creds(
    &mut self,
    request: impl IntoRequest<CheckValidCredsRequest>
) -> Result<Response<CheckValidCredsResponse>, Status>

Returns true if valid credentials exist for the given data source and requesting user. Some data sources doesn’t support service account, so we need to talk to them on behalf of the end user. This API just checks whether we have OAuth token for the particular user, which is a pre-requisite before user can create a transfer config.

Trait Implementations

impl<T: Clone> Clone for DataTransferServiceClient<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for DataTransferServiceClient<T>

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

Formats the value using the given formatter.