Interface EnvironmentsGrpc.AsyncService
-
- All Known Implementing Classes:
EnvironmentsGrpc.EnvironmentsImplBase
- Enclosing class:
- EnvironmentsGrpc
public static interface EnvironmentsGrpc.AsyncService
Managed Apache Airflow Environments.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default void
checkUpgrade(CheckUpgradeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Check if an upgrade operation on the environment will succeed.default void
createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Create a new environment.default void
databaseFailover(DatabaseFailoverRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Triggers database failover (only for highly resilient environments).default void
deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete an environment.default void
executeAirflowCommand(ExecuteAirflowCommandRequest request, io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)
Executes Airflow CLI command.default void
fetchDatabaseProperties(FetchDatabasePropertiesRequest request, io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)
Fetches database properties.default void
getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)
Get an existing environment.default void
listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)
List environments.default void
loadSnapshot(LoadSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Loads a snapshot of a Cloud Composer environment.default void
pollAirflowCommand(PollAirflowCommandRequest request, io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)
Polls Airflow CLI command execution and fetches logs.default void
restartWebServer(RestartWebServerRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Restart Airflow web server.default void
saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Creates a snapshots of a Cloud Composer environment.default void
stopAirflowCommand(StopAirflowCommandRequest request, io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)
Stops Airflow CLI command execution.default void
updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update an environment.
-
-
-
Method Detail
-
createEnvironment
default void createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Create a new environment.
-
getEnvironment
default void getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)
Get an existing environment.
-
listEnvironments
default void listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)
List environments.
-
updateEnvironment
default void updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Update an environment.
-
deleteEnvironment
default void deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Delete an environment.
-
restartWebServer
default void restartWebServer(RestartWebServerRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Restart Airflow web server.
-
checkUpgrade
default void checkUpgrade(CheckUpgradeRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Check if an upgrade operation on the environment will succeed. In case of problems detailed info can be found in the returned Operation.
-
executeAirflowCommand
default void executeAirflowCommand(ExecuteAirflowCommandRequest request, io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)
Executes Airflow CLI command.
-
stopAirflowCommand
default void stopAirflowCommand(StopAirflowCommandRequest request, io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)
Stops Airflow CLI command execution.
-
pollAirflowCommand
default void pollAirflowCommand(PollAirflowCommandRequest request, io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)
Polls Airflow CLI command execution and fetches logs.
-
saveSnapshot
default void saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
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
default void loadSnapshot(LoadSnapshotRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
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
default void databaseFailover(DatabaseFailoverRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Triggers database failover (only for highly resilient environments).
-
fetchDatabaseProperties
default void fetchDatabaseProperties(FetchDatabasePropertiesRequest request, io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)
Fetches database properties.
-
-