Class: Google::Cloud::Orchestration::Airflow::Service::V1::Environments::Rest::ServiceStub
- Inherits:
-
Object
- Object
- Google::Cloud::Orchestration::Airflow::Service::V1::Environments::Rest::ServiceStub
- Defined in:
- lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb
Overview
REST service stub for the Environments service. Service stub contains baseline method implementations including transcoding, making the REST call, and deserialing the response.
Instance Method Summary collapse
-
#create_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the create_environment REST call.
-
#database_failover(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the database_failover REST call.
-
#delete_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the delete_environment REST call.
-
#endpoint ⇒ String
The effective endpoint.
-
#execute_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::ExecuteAirflowCommandResponse
Baseline implementation for the execute_airflow_command REST call.
-
#fetch_database_properties(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::FetchDatabasePropertiesResponse
Baseline implementation for the fetch_database_properties REST call.
-
#get_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::Environment
Baseline implementation for the get_environment REST call.
-
#initialize(endpoint:, endpoint_template:, universe_domain:, credentials:) ⇒ ServiceStub
constructor
A new instance of ServiceStub.
-
#list_environments(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::ListEnvironmentsResponse
Baseline implementation for the list_environments REST call.
-
#load_snapshot(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the load_snapshot REST call.
-
#poll_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::PollAirflowCommandResponse
Baseline implementation for the poll_airflow_command REST call.
-
#save_snapshot(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the save_snapshot REST call.
-
#stop_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::StopAirflowCommandResponse
Baseline implementation for the stop_airflow_command REST call.
-
#universe_domain ⇒ String
The effective universe domain.
-
#update_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the update_environment REST call.
Constructor Details
#initialize(endpoint:, endpoint_template:, universe_domain:, credentials:) ⇒ ServiceStub
Returns a new instance of ServiceStub.
35 36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 35 def initialize endpoint:, endpoint_template:, universe_domain:, credentials: # These require statements are intentionally placed here to initialize # the REST modules only when it's required. require "gapic/rest" @client_stub = ::Gapic::Rest::ClientStub.new endpoint: endpoint, endpoint_template: endpoint_template, universe_domain: universe_domain, credentials: credentials, numeric_enums: true, raise_faraday_errors: false end |
Instance Method Details
#create_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the create_environment REST call
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 80 def create_environment request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_create_environment_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#database_failover(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the database_failover REST call
460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 460 def database_failover request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_database_failover_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#delete_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the delete_environment REST call
232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 232 def delete_environment request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_delete_environment_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#endpoint ⇒ String
The effective endpoint
62 63 64 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 62 def endpoint @client_stub.endpoint end |
#execute_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::ExecuteAirflowCommandResponse
Baseline implementation for the execute_airflow_command REST call
270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 270 def execute_airflow_command request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_execute_airflow_command_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::ExecuteAirflowCommandResponse.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#fetch_database_properties(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::FetchDatabasePropertiesResponse
Baseline implementation for the fetch_database_properties REST call
498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 498 def fetch_database_properties request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_fetch_database_properties_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::FetchDatabasePropertiesResponse.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#get_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::Environment
Baseline implementation for the get_environment REST call
118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 118 def get_environment request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_get_environment_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::Environment.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#list_environments(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::ListEnvironmentsResponse
Baseline implementation for the list_environments REST call
156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 156 def list_environments request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_list_environments_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::ListEnvironmentsResponse.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#load_snapshot(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the load_snapshot REST call
422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 422 def load_snapshot request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_load_snapshot_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#poll_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::PollAirflowCommandResponse
Baseline implementation for the poll_airflow_command REST call
346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 346 def poll_airflow_command request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_poll_airflow_command_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::PollAirflowCommandResponse.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#save_snapshot(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the save_snapshot REST call
384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 384 def save_snapshot request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_save_snapshot_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#stop_airflow_command(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Cloud::Orchestration::Airflow::Service::V1::StopAirflowCommandResponse
Baseline implementation for the stop_airflow_command REST call
308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 308 def stop_airflow_command request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_stop_airflow_command_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Cloud::Orchestration::Airflow::Service::V1::StopAirflowCommandResponse.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |
#universe_domain ⇒ String
The effective universe domain
53 54 55 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 53 def universe_domain @client_stub.universe_domain end |
#update_environment(request_pb, options = nil) {|result, operation| ... } ⇒ ::Google::Longrunning::Operation
Baseline implementation for the update_environment REST call
194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 |
# File 'lib/google/cloud/orchestration/airflow/service/v1/environments/rest/service_stub.rb', line 194 def update_environment request_pb, = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? verb, uri, query_string_params, body = ServiceStub.transcode_update_environment_request request_pb query_string_params = if query_string_params.any? query_string_params.to_h { |p| p.split "=", 2 } else {} end response = @client_stub.make_http_request( verb, uri: uri, body: body || "", params: query_string_params, options: ) operation = ::Gapic::Rest::TransportOperation.new response result = ::Google::Longrunning::Operation.decode_json response.body, ignore_unknown_fields: true yield result, operation if block_given? result end |