public static final class StorageTransferServiceGrpc.StorageTransferServiceStub extends AbstractAsyncStub<StorageTransferServiceGrpc.StorageTransferServiceStub>
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.AbstractAsyncStub >
StorageTransferServiceGrpc.StorageTransferServiceStub
Inherited Members
io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractAsyncStub.<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.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected StorageTransferServiceGrpc.StorageTransferServiceStub build(Channel channel, CallOptions callOptions)
Parameters
Name | Description |
channel | io.grpc.Channel
|
callOptions | io.grpc.CallOptions
|
Returns
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createTransferJob(TransferProto.CreateTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
public void createTransferJob(TransferProto.CreateTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
Creates a transfer job that runs periodically.
Parameters
getGoogleServiceAccount(TransferProto.GetGoogleServiceAccountRequest request, StreamObserver<TransferTypes.GoogleServiceAccount> responseObserver)
public void getGoogleServiceAccount(TransferProto.GetGoogleServiceAccountRequest request, StreamObserver<TransferTypes.GoogleServiceAccount> responseObserver)
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.
Parameters
getTransferJob(TransferProto.GetTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
public void getTransferJob(TransferProto.GetTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
Parameters
listTransferJobs(TransferProto.ListTransferJobsRequest request, StreamObserver<TransferProto.ListTransferJobsResponse> responseObserver)
public void listTransferJobs(TransferProto.ListTransferJobsRequest request, StreamObserver<TransferProto.ListTransferJobsResponse> responseObserver)
Parameters
pauseTransferOperation(TransferProto.PauseTransferOperationRequest request, StreamObserver<Empty> responseObserver)
public void pauseTransferOperation(TransferProto.PauseTransferOperationRequest request, StreamObserver<Empty> responseObserver)
Pauses a transfer operation.
Parameters
resumeTransferOperation(TransferProto.ResumeTransferOperationRequest request, StreamObserver<Empty> responseObserver)
public void resumeTransferOperation(TransferProto.ResumeTransferOperationRequest request, StreamObserver<Empty> responseObserver)
Resumes a transfer operation that is paused.
Parameters
runTransferJob(TransferProto.RunTransferJobRequest request, StreamObserver<Operation> responseObserver)
public void runTransferJob(TransferProto.RunTransferJobRequest request, StreamObserver<Operation> responseObserver)
Attempts to start a new TransferOperation for the current TransferJob. A
TransferJob has a maximum of one active TransferOperation. If this method
is called while a TransferOperation is active, an error wil be returned.
Parameters
updateTransferJob(TransferProto.UpdateTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
public void updateTransferJob(TransferProto.UpdateTransferJobRequest request, StreamObserver<TransferTypes.TransferJob> responseObserver)
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).
Parameters