Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Interface EnvironmentsGrpc.AsyncService (1.39.0)

public static interface EnvironmentsGrpc.AsyncService

Managed Apache Airflow Environments.

Methods

checkUpgrade(CheckUpgradeRequest request, StreamObserver<Operation> responseObserver)

public default void checkUpgrade(CheckUpgradeRequest request, 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.

Parameters
Name	Description
`request`	`CheckUpgradeRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createEnvironment(CreateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public default void createEnvironment(CreateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Create a new environment.

Parameters
Name	Description
`request`	`CreateEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createUserWorkloadsConfigMap(CreateUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

public default void createUserWorkloadsConfigMap(CreateUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

Creates a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`CreateUserWorkloadsConfigMapRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsConfigMap>`

createUserWorkloadsSecret(CreateUserWorkloadsSecretRequest request, StreamObserver<UserWorkloadsSecret> responseObserver)

public default void createUserWorkloadsSecret(CreateUserWorkloadsSecretRequest request, StreamObserver<UserWorkloadsSecret> responseObserver)

Creates a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`CreateUserWorkloadsSecretRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsSecret>`

databaseFailover(DatabaseFailoverRequest request, StreamObserver<Operation> responseObserver)

public default void databaseFailover(DatabaseFailoverRequest request, StreamObserver<Operation> responseObserver)

Triggers database failover (only for highly resilient environments).

Parameters
Name	Description
`request`	`DatabaseFailoverRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteEnvironment(DeleteEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public default void deleteEnvironment(DeleteEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Delete an environment.

Parameters
Name	Description
`request`	`DeleteEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteUserWorkloadsConfigMap(DeleteUserWorkloadsConfigMapRequest request, StreamObserver<Empty> responseObserver)

public default void deleteUserWorkloadsConfigMap(DeleteUserWorkloadsConfigMapRequest request, StreamObserver<Empty> responseObserver)

Deletes a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`DeleteUserWorkloadsConfigMapRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

deleteUserWorkloadsSecret(DeleteUserWorkloadsSecretRequest request, StreamObserver<Empty> responseObserver)

public default void deleteUserWorkloadsSecret(DeleteUserWorkloadsSecretRequest request, StreamObserver<Empty> responseObserver)

Deletes a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`DeleteUserWorkloadsSecretRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

executeAirflowCommand(ExecuteAirflowCommandRequest request, StreamObserver<ExecuteAirflowCommandResponse> responseObserver)

public default void executeAirflowCommand(ExecuteAirflowCommandRequest request, StreamObserver<ExecuteAirflowCommandResponse> responseObserver)

Executes Airflow CLI command.

Parameters
Name	Description
`request`	`ExecuteAirflowCommandRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ExecuteAirflowCommandResponse>`

fetchDatabaseProperties(FetchDatabasePropertiesRequest request, StreamObserver<FetchDatabasePropertiesResponse> responseObserver)

public default void fetchDatabaseProperties(FetchDatabasePropertiesRequest request, StreamObserver<FetchDatabasePropertiesResponse> responseObserver)

Fetches database properties.

Parameters
Name	Description
`request`	`FetchDatabasePropertiesRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<FetchDatabasePropertiesResponse>`

getEnvironment(GetEnvironmentRequest request, StreamObserver<Environment> responseObserver)

public default void getEnvironment(GetEnvironmentRequest request, StreamObserver<Environment> responseObserver)

Get an existing environment.

Parameters
Name	Description
`request`	`GetEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Environment>`

getUserWorkloadsConfigMap(GetUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

public default void getUserWorkloadsConfigMap(GetUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

Gets an existing user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`GetUserWorkloadsConfigMapRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsConfigMap>`

getUserWorkloadsSecret(GetUserWorkloadsSecretRequest request, StreamObserver<UserWorkloadsSecret> responseObserver)

public default void getUserWorkloadsSecret(GetUserWorkloadsSecretRequest request, 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-..* and newer.

Parameters
Name	Description
`request`	`GetUserWorkloadsSecretRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsSecret>`

listEnvironments(ListEnvironmentsRequest request, StreamObserver<ListEnvironmentsResponse> responseObserver)

public default void listEnvironments(ListEnvironmentsRequest request, StreamObserver<ListEnvironmentsResponse> responseObserver)

List environments.

Parameters
Name	Description
`request`	`ListEnvironmentsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListEnvironmentsResponse>`

listUserWorkloadsConfigMaps(ListUserWorkloadsConfigMapsRequest request, StreamObserver<ListUserWorkloadsConfigMapsResponse> responseObserver)

public default void listUserWorkloadsConfigMaps(ListUserWorkloadsConfigMapsRequest request, StreamObserver<ListUserWorkloadsConfigMapsResponse> responseObserver)

Lists user workloads ConfigMaps. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`ListUserWorkloadsConfigMapsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListUserWorkloadsConfigMapsResponse>`

listUserWorkloadsSecrets(ListUserWorkloadsSecretsRequest request, StreamObserver<ListUserWorkloadsSecretsResponse> responseObserver)

public default void listUserWorkloadsSecrets(ListUserWorkloadsSecretsRequest request, StreamObserver<ListUserWorkloadsSecretsResponse> responseObserver)

Lists user workloads Secrets. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`ListUserWorkloadsSecretsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListUserWorkloadsSecretsResponse>`

listWorkloads(ListWorkloadsRequest request, StreamObserver<ListWorkloadsResponse> responseObserver)

public default void listWorkloads(ListWorkloadsRequest request, 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-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`ListWorkloadsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListWorkloadsResponse>`

loadSnapshot(LoadSnapshotRequest request, StreamObserver<Operation> responseObserver)

public default void loadSnapshot(LoadSnapshotRequest request, 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.

Parameters
Name	Description
`request`	`LoadSnapshotRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

pollAirflowCommand(PollAirflowCommandRequest request, StreamObserver<PollAirflowCommandResponse> responseObserver)

public default void pollAirflowCommand(PollAirflowCommandRequest request, StreamObserver<PollAirflowCommandResponse> responseObserver)

Polls Airflow CLI command execution and fetches logs.

Parameters
Name	Description
`request`	`PollAirflowCommandRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<PollAirflowCommandResponse>`

restartWebServer(RestartWebServerRequest request, StreamObserver<Operation> responseObserver)

public default void restartWebServer(RestartWebServerRequest request, StreamObserver<Operation> responseObserver)

Restart Airflow web server.

Parameters
Name	Description
`request`	`RestartWebServerRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

saveSnapshot(SaveSnapshotRequest request, StreamObserver<Operation> responseObserver)

public default void saveSnapshot(SaveSnapshotRequest request, 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.

Parameters
Name	Description
`request`	`SaveSnapshotRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

stopAirflowCommand(StopAirflowCommandRequest request, StreamObserver<StopAirflowCommandResponse> responseObserver)

public default void stopAirflowCommand(StopAirflowCommandRequest request, StreamObserver<StopAirflowCommandResponse> responseObserver)

Stops Airflow CLI command execution.

Parameters
Name	Description
`request`	`StopAirflowCommandRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<StopAirflowCommandResponse>`

updateEnvironment(UpdateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

public default void updateEnvironment(UpdateEnvironmentRequest request, StreamObserver<Operation> responseObserver)

Update an environment.

Parameters
Name	Description
`request`	`UpdateEnvironmentRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateUserWorkloadsConfigMap(UpdateUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

public default void updateUserWorkloadsConfigMap(UpdateUserWorkloadsConfigMapRequest request, StreamObserver<UserWorkloadsConfigMap> responseObserver)

Updates a user workloads ConfigMap. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`UpdateUserWorkloadsConfigMapRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsConfigMap>`

updateUserWorkloadsSecret(UpdateUserWorkloadsSecretRequest request, StreamObserver<UserWorkloadsSecret> responseObserver)

public default void updateUserWorkloadsSecret(UpdateUserWorkloadsSecretRequest request, StreamObserver<UserWorkloadsSecret> responseObserver)

Updates a user workloads Secret. This method is supported for Cloud Composer environments in versions composer-3..-airflow-..* and newer.

Parameters
Name	Description
`request`	`UpdateUserWorkloadsSecretRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<UserWorkloadsSecret>`