Package com.google.cloud.orchestration.airflow.service.v1beta1

Class EnvironmentsGrpc.EnvironmentsStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<EnvironmentsGrpc.EnvironmentsStub>
com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsGrpc.EnvironmentsStub
Enclosing class:
EnvironmentsGrpc
public static final class EnvironmentsGrpc.EnvironmentsStub extends io.grpc.stub.AbstractAsyncStub<EnvironmentsGrpc.EnvironmentsStub>
A stub to allow clients to do asynchronous rpc calls to service Environments. 
 Managed Apache Airflow Environments.

  • Method Details

    • build

      protected EnvironmentsGrpc.EnvironmentsStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<EnvironmentsGrpc.EnvironmentsStub>

    • createEnvironment

      public void createEnvironment(CreateEnvironmentRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Create a new environment.

    • getEnvironment

      public void getEnvironment(GetEnvironmentRequest request, io.grpc.stub.StreamObserver<Environment> responseObserver)
       Get an existing environment.

    • listEnvironments

      public void listEnvironments(ListEnvironmentsRequest request, io.grpc.stub.StreamObserver<ListEnvironmentsResponse> responseObserver)
       List environments.

    • updateEnvironment

      public void updateEnvironment(UpdateEnvironmentRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Update an environment.

    • deleteEnvironment

      public void deleteEnvironment(DeleteEnvironmentRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Delete an environment.

    • restartWebServer

      public void restartWebServer(RestartWebServerRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Restart Airflow web server.

    • checkUpgrade

      public void checkUpgrade(CheckUpgradeRequest request, io.grpc.stub.StreamObserver<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

      public void executeAirflowCommand(ExecuteAirflowCommandRequest request, io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse> responseObserver)
       Executes Airflow CLI command.

    • stopAirflowCommand

      public void stopAirflowCommand(StopAirflowCommandRequest request, io.grpc.stub.StreamObserver<StopAirflowCommandResponse> responseObserver)
       Stops Airflow CLI command execution.

    • pollAirflowCommand

      public void pollAirflowCommand(PollAirflowCommandRequest request, io.grpc.stub.StreamObserver<PollAirflowCommandResponse> responseObserver)
       Polls Airflow CLI command execution and fetches logs.

    • listWorkloads

      public void listWorkloads(ListWorkloadsRequest request, io.grpc.stub.StreamObserver<ListWorkloadsResponse> responseObserver)
       Lists workloads in a Cloud Composer environment. Workload is a unit that
 runs a single Composer component.
 This method is supported for Cloud Composer environments in versions
 composer-2.*.*-airflow-*.*.* and newer.

    • createUserWorkloadsSecret

      public void createUserWorkloadsSecret(CreateUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Creates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsSecret

      public void getUserWorkloadsSecret(GetUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Gets an existing user workloads Secret.
 Values of the "data" field in the response are cleared.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • listUserWorkloadsSecrets

      public void listUserWorkloadsSecrets(ListUserWorkloadsSecretsRequest request, io.grpc.stub.StreamObserver<ListUserWorkloadsSecretsResponse> responseObserver)
       Lists user workloads Secrets.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsSecret

      public void updateUserWorkloadsSecret(UpdateUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<UserWorkloadsSecret> responseObserver)
       Updates a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsSecret

      public void deleteUserWorkloadsSecret(DeleteUserWorkloadsSecretRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a user workloads Secret.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • createUserWorkloadsConfigMap

      public void createUserWorkloadsConfigMap(CreateUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Creates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • getUserWorkloadsConfigMap

      public void getUserWorkloadsConfigMap(GetUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Gets an existing user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • listUserWorkloadsConfigMaps

      public void listUserWorkloadsConfigMaps(ListUserWorkloadsConfigMapsRequest request, io.grpc.stub.StreamObserver<ListUserWorkloadsConfigMapsResponse> responseObserver)
       Lists user workloads ConfigMaps.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • updateUserWorkloadsConfigMap

      public void updateUserWorkloadsConfigMap(UpdateUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<UserWorkloadsConfigMap> responseObserver)
       Updates a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • deleteUserWorkloadsConfigMap

      public void deleteUserWorkloadsConfigMap(DeleteUserWorkloadsConfigMapRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
       Deletes a user workloads ConfigMap.
 This method is supported for Cloud Composer environments in versions
 composer-3-airflow-*.*.*-build.* and newer.

    • saveSnapshot

      public void saveSnapshot(SaveSnapshotRequest request, io.grpc.stub.StreamObserver<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

      public void loadSnapshot(LoadSnapshotRequest request, io.grpc.stub.StreamObserver<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

      public void databaseFailover(DatabaseFailoverRequest request, io.grpc.stub.StreamObserver<Operation> responseObserver)
       Triggers database failover (only for highly resilient environments).

    • fetchDatabaseProperties

      public void fetchDatabaseProperties(FetchDatabasePropertiesRequest request, io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse> responseObserver)
       Fetches database properties.