Class EnvironmentsGrpc.EnvironmentsBlockingStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractBlockingStub<EnvironmentsGrpc.EnvironmentsBlockingStub>
-
- com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsGrpc.EnvironmentsBlockingStub
-
- Enclosing class:
- EnvironmentsGrpc
public static final class EnvironmentsGrpc.EnvironmentsBlockingStub extends io.grpc.stub.AbstractBlockingStub<EnvironmentsGrpc.EnvironmentsBlockingStub>
A stub to allow clients to do synchronous rpc calls to service Environments.Managed Apache Airflow Environments.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected EnvironmentsGrpc.EnvironmentsBlockingStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.longrunning.Operation
checkUpgrade(CheckUpgradeRequest request)
Check if an upgrade operation on the environment will succeed.com.google.longrunning.Operation
createEnvironment(CreateEnvironmentRequest request)
Create a new environment.com.google.longrunning.Operation
databaseFailover(DatabaseFailoverRequest request)
Triggers database failover (only for highly resilient environments).com.google.longrunning.Operation
deleteEnvironment(DeleteEnvironmentRequest request)
Delete an environment.ExecuteAirflowCommandResponse
executeAirflowCommand(ExecuteAirflowCommandRequest request)
Executes Airflow CLI command.FetchDatabasePropertiesResponse
fetchDatabaseProperties(FetchDatabasePropertiesRequest request)
Fetches database properties.Environment
getEnvironment(GetEnvironmentRequest request)
Get an existing environment.ListEnvironmentsResponse
listEnvironments(ListEnvironmentsRequest request)
List environments.com.google.longrunning.Operation
loadSnapshot(LoadSnapshotRequest request)
Loads a snapshot of a Cloud Composer environment.PollAirflowCommandResponse
pollAirflowCommand(PollAirflowCommandRequest request)
Polls Airflow CLI command execution and fetches logs.com.google.longrunning.Operation
restartWebServer(RestartWebServerRequest request)
Restart Airflow web server.com.google.longrunning.Operation
saveSnapshot(SaveSnapshotRequest request)
Creates a snapshots of a Cloud Composer environment.StopAirflowCommandResponse
stopAirflowCommand(StopAirflowCommandRequest request)
Stops Airflow CLI command execution.com.google.longrunning.Operation
updateEnvironment(UpdateEnvironmentRequest request)
Update an environment.
-
-
-
Method Detail
-
build
protected EnvironmentsGrpc.EnvironmentsBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<EnvironmentsGrpc.EnvironmentsBlockingStub>
-
createEnvironment
public com.google.longrunning.Operation createEnvironment(CreateEnvironmentRequest request)
Create a new environment.
-
getEnvironment
public Environment getEnvironment(GetEnvironmentRequest request)
Get an existing environment.
-
listEnvironments
public ListEnvironmentsResponse listEnvironments(ListEnvironmentsRequest request)
List environments.
-
updateEnvironment
public com.google.longrunning.Operation updateEnvironment(UpdateEnvironmentRequest request)
Update an environment.
-
deleteEnvironment
public com.google.longrunning.Operation deleteEnvironment(DeleteEnvironmentRequest request)
Delete an environment.
-
restartWebServer
public com.google.longrunning.Operation restartWebServer(RestartWebServerRequest request)
Restart Airflow web server.
-
checkUpgrade
public com.google.longrunning.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.
-
executeAirflowCommand
public ExecuteAirflowCommandResponse executeAirflowCommand(ExecuteAirflowCommandRequest request)
Executes Airflow CLI command.
-
stopAirflowCommand
public StopAirflowCommandResponse stopAirflowCommand(StopAirflowCommandRequest request)
Stops Airflow CLI command execution.
-
pollAirflowCommand
public PollAirflowCommandResponse pollAirflowCommand(PollAirflowCommandRequest request)
Polls Airflow CLI command execution and fetches logs.
-
saveSnapshot
public com.google.longrunning.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.
-
loadSnapshot
public com.google.longrunning.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.
-
databaseFailover
public com.google.longrunning.Operation databaseFailover(DatabaseFailoverRequest request)
Triggers database failover (only for highly resilient environments).
-
fetchDatabaseProperties
public FetchDatabasePropertiesResponse fetchDatabaseProperties(FetchDatabasePropertiesRequest request)
Fetches database properties.
-
-