Struct gapi_grpc::google::storagetransfer::v1::storage_transfer_service_client::StorageTransferServiceClient [−][src]
Transfers data between between Google Cloud Storage buckets or from a data source external to Google to a Cloud Storage bucket.
Implementations
impl StorageTransferServiceClient<Channel>[src]
pub async fn connect<D>(dst: D) -> Result<Self, Error> where
D: TryInto<Endpoint>,
D::Error: Into<StdError>, [src]
D: TryInto<Endpoint>,
D::Error: Into<StdError>,
Attempt to create a new client by connecting to a given endpoint.
impl<T> StorageTransferServiceClient<T> where
T: GrpcService<BoxBody>,
T::ResponseBody: Body + HttpBody + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, [src]
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[src]
pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self[src]
pub async fn get_google_service_account(
&mut self,
request: impl IntoRequest<GetGoogleServiceAccountRequest>
) -> Result<Response<GoogleServiceAccount>, Status>[src]
&mut self,
request: impl IntoRequest<GetGoogleServiceAccountRequest>
) -> Result<Response<GoogleServiceAccount>, Status>
Returns the Google service account that is used by Storage Transfer Service to access buckets in the project where transfers run or in other projects. Each Google service account is associated with one Google Cloud Platform Console project. Users should add this service account to the Google Cloud Storage bucket ACLs to grant access to Storage Transfer Service. This service account is created and owned by Storage Transfer Service and can only be used by Storage Transfer Service.
pub async fn create_transfer_job(
&mut self,
request: impl IntoRequest<CreateTransferJobRequest>
) -> Result<Response<TransferJob>, Status>[src]
&mut self,
request: impl IntoRequest<CreateTransferJobRequest>
) -> Result<Response<TransferJob>, Status>
Creates a transfer job that runs periodically.
pub async fn update_transfer_job(
&mut self,
request: impl IntoRequest<UpdateTransferJobRequest>
) -> Result<Response<TransferJob>, Status>[src]
&mut self,
request: impl IntoRequest<UpdateTransferJobRequest>
) -> Result<Response<TransferJob>, Status>
Updates a transfer job. Updating a job’s transfer spec does not affect transfer operations that are running already. Updating the scheduling of a job is not allowed.
pub async fn get_transfer_job(
&mut self,
request: impl IntoRequest<GetTransferJobRequest>
) -> Result<Response<TransferJob>, Status>[src]
&mut self,
request: impl IntoRequest<GetTransferJobRequest>
) -> Result<Response<TransferJob>, Status>
Gets a transfer job.
pub async fn list_transfer_jobs(
&mut self,
request: impl IntoRequest<ListTransferJobsRequest>
) -> Result<Response<ListTransferJobsResponse>, Status>[src]
&mut self,
request: impl IntoRequest<ListTransferJobsRequest>
) -> Result<Response<ListTransferJobsResponse>, Status>
Lists transfer jobs.
pub async fn pause_transfer_operation(
&mut self,
request: impl IntoRequest<PauseTransferOperationRequest>
) -> Result<Response<()>, Status>[src]
&mut self,
request: impl IntoRequest<PauseTransferOperationRequest>
) -> Result<Response<()>, Status>
Pauses a transfer operation.
pub async fn resume_transfer_operation(
&mut self,
request: impl IntoRequest<ResumeTransferOperationRequest>
) -> Result<Response<()>, Status>[src]
&mut self,
request: impl IntoRequest<ResumeTransferOperationRequest>
) -> Result<Response<()>, Status>
Resumes a transfer operation that is paused.
Trait Implementations
impl<T: Clone> Clone for StorageTransferServiceClient<T>[src]
fn clone(&self) -> Self[src]
pub fn clone_from(&mut self, source: &Self)1.0.0[src]
impl<T> Debug for StorageTransferServiceClient<T>[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for StorageTransferServiceClient<T>
impl<T> Send for StorageTransferServiceClient<T> where
T: Send,
T: Send,
impl<T> Sync for StorageTransferServiceClient<T> where
T: Sync,
T: Sync,
impl<T> Unpin for StorageTransferServiceClient<T> where
T: Unpin,
T: Unpin,
impl<T> !UnwindSafe for StorageTransferServiceClient<T>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> IntoRequest<T> for T[src]
pub fn into_request(self) -> Request<T>[src]
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T[src]
pub fn clone_into(&self, target: &mut T)[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>, [src]
V: MultiLane<T>,
impl<T> WithSubscriber for T[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>, [src]
S: Into<Dispatch>,