public static final class EnvironmentsGrpc.EnvironmentsBlockingStub extends AbstractBlockingStub<EnvironmentsGrpc.EnvironmentsBlockingStub>
Managed Apache Airflow Environments.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
EnvironmentsGrpc.EnvironmentsBlockingStub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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 EnvironmentsGrpc.EnvironmentsBlockingStub 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)
checkUpgrade(CheckUpgradeRequest request)
public Operation checkUpgrade(CheckUpgradeRequest request)
Check if an upgrade operation on the environment will succeed.
In case of problems detailed info can be found in the returned Operation.
createEnvironment(CreateEnvironmentRequest request)
public Operation createEnvironment(CreateEnvironmentRequest request)
Create a new environment.
deleteEnvironment(DeleteEnvironmentRequest request)
public Operation deleteEnvironment(DeleteEnvironmentRequest request)
Parameter
Returns
getEnvironment(GetEnvironmentRequest request)
public Environment getEnvironment(GetEnvironmentRequest request)
Get an existing environment.
listEnvironments(ListEnvironmentsRequest request)
public ListEnvironmentsResponse listEnvironments(ListEnvironmentsRequest request)
Parameter
Returns
loadSnapshot(LoadSnapshotRequest request)
public Operation loadSnapshot(LoadSnapshotRequest request)
Loads a snapshot of a Cloud Composer environment.
As a result of this operation, a snapshot of environment's specified in
LoadSnapshotRequest is loaded into the environment.
restartWebServer(RestartWebServerRequest request)
public Operation restartWebServer(RestartWebServerRequest request)
Restart Airflow web server.
saveSnapshot(SaveSnapshotRequest request)
public Operation saveSnapshot(SaveSnapshotRequest request)
Creates a snapshots of a Cloud Composer environment.
As a result of this operation, snapshot of environment's state is stored
in a location specified in the SaveSnapshotRequest.
updateEnvironment(UpdateEnvironmentRequest request)
public Operation updateEnvironment(UpdateEnvironmentRequest request)
Parameter
Returns
