public static final class StorageTransferServiceGrpc.StorageTransferServiceFutureStub extends AbstractFutureStub<StorageTransferServiceGrpc.StorageTransferServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service
StorageTransferService.
Storage Transfer Service and its protos.
Transfers data between between Google Cloud Storage buckets or from a data
source external to Google to a Cloud Storage bucket.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
StorageTransferServiceGrpc.StorageTransferServiceFutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected StorageTransferServiceGrpc.StorageTransferServiceFutureStub build(Channel channel, CallOptions callOptions)
Parameters |
Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createAgentPool(TransferProto.CreateAgentPoolRequest request)
public ListenableFuture<TransferTypes.AgentPool> createAgentPool(TransferProto.CreateAgentPoolRequest request)
Creates an agent pool resource.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<AgentPool> |
|
createTransferJob(TransferProto.CreateTransferJobRequest request)
public ListenableFuture<TransferTypes.TransferJob> createTransferJob(TransferProto.CreateTransferJobRequest request)
Creates a transfer job that runs periodically.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<TransferJob> |
|
deleteAgentPool(TransferProto.DeleteAgentPoolRequest request)
public ListenableFuture<Empty> deleteAgentPool(TransferProto.DeleteAgentPoolRequest request)
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Empty> |
|
deleteTransferJob(TransferProto.DeleteTransferJobRequest request)
public ListenableFuture<Empty> deleteTransferJob(TransferProto.DeleteTransferJobRequest request)
Deletes a transfer job. Deleting a transfer job sets its status to
DELETED.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Empty> |
|
getAgentPool(TransferProto.GetAgentPoolRequest request)
public ListenableFuture<TransferTypes.AgentPool> getAgentPool(TransferProto.GetAgentPoolRequest request)
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<AgentPool> |
|
getGoogleServiceAccount(TransferProto.GetGoogleServiceAccountRequest request)
public ListenableFuture<TransferTypes.GoogleServiceAccount> getGoogleServiceAccount(TransferProto.GetGoogleServiceAccountRequest request)
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 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.
getTransferJob(TransferProto.GetTransferJobRequest request)
public ListenableFuture<TransferTypes.TransferJob> getTransferJob(TransferProto.GetTransferJobRequest request)
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<TransferJob> |
|
listAgentPools(TransferProto.ListAgentPoolsRequest request)
public ListenableFuture<TransferProto.ListAgentPoolsResponse> listAgentPools(TransferProto.ListAgentPoolsRequest request)
listTransferJobs(TransferProto.ListTransferJobsRequest request)
public ListenableFuture<TransferProto.ListTransferJobsResponse> listTransferJobs(TransferProto.ListTransferJobsRequest request)
pauseTransferOperation(TransferProto.PauseTransferOperationRequest request)
public ListenableFuture<Empty> pauseTransferOperation(TransferProto.PauseTransferOperationRequest request)
Pauses a transfer operation.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Empty> |
|
resumeTransferOperation(TransferProto.ResumeTransferOperationRequest request)
public ListenableFuture<Empty> resumeTransferOperation(TransferProto.ResumeTransferOperationRequest request)
Resumes a transfer operation that is paused.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Empty> |
|
runTransferJob(TransferProto.RunTransferJobRequest request)
public ListenableFuture<Operation> runTransferJob(TransferProto.RunTransferJobRequest request)
Starts a new operation for the specified transfer job.
A TransferJob
has a maximum of one active TransferOperation
. If this
method is called while a TransferOperation
is active, an error is
returned.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
updateAgentPool(TransferProto.UpdateAgentPoolRequest request)
public ListenableFuture<TransferTypes.AgentPool> updateAgentPool(TransferProto.UpdateAgentPoolRequest request)
Updates an existing agent pool resource.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<AgentPool> |
|
updateTransferJob(TransferProto.UpdateTransferJobRequest request)
public ListenableFuture<TransferTypes.TransferJob> updateTransferJob(TransferProto.UpdateTransferJobRequest request)
Updates a transfer job. Updating a job's transfer spec does not affect
transfer operations that are running already.
Note: The job's status
field can be modified using this RPC (for example, to set a job's status to
DELETED,
DISABLED, or
ENABLED).
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<TransferJob> |
|