view release on metacpan or  search on metacpan

lib/Google/Cloud/Orchestration/Airflow/Service/V1/Environments.pm  view on Meta::CPAN

=cut

use Moo;
use Google::Auth;
use Google::gRPC::Client;

has credentials => ( is => 'ro', default => sub { Google::Auth->default() } );
has target      => ( is => 'ro', default => 'orchestration.googleapis.com:443' );

has _grpc_client => (
    is => 'ro',
    lazy => 1,
    builder => sub {
        my $self = shift;
        return Google::gRPC::Client->new(
            target     => $self->target,
            auth_token => $self->credentials->get_token(),
        );
    }
);

sub create_environment {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::CreateEnvironmentRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'CreateEnvironment',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub get_environment {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::GetEnvironmentRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'GetEnvironment',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::Environment',
    });
}

sub list_environments {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListEnvironmentsRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'ListEnvironments',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListEnvironmentsResponse',
    });
}

sub update_environment {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UpdateEnvironmentRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'UpdateEnvironment',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub delete_environment {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::DeleteEnvironmentRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'DeleteEnvironment',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub execute_airflow_command {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ExecuteAirflowCommandRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'ExecuteAirflowCommand',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ExecuteAirflowCommandResponse',
    });
}

sub stop_airflow_command {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::StopAirflowCommandRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'StopAirflowCommand',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::StopAirflowCommandResponse',
    });
}

sub poll_airflow_command {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::PollAirflowCommandRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'PollAirflowCommand',
        request        => $req,

lib/Google/Cloud/Orchestration/Airflow/Service/V1/Environments.pm  view on Meta::CPAN

    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'ListWorkloads',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListWorkloadsResponse',
    });
}

sub check_upgrade {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::CheckUpgradeRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'CheckUpgrade',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub create_user_workloads_secret {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::CreateUserWorkloadsSecretRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'CreateUserWorkloadsSecret',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsSecret',
    });
}

sub get_user_workloads_secret {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::GetUserWorkloadsSecretRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'GetUserWorkloadsSecret',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsSecret',
    });
}

sub list_user_workloads_secrets {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListUserWorkloadsSecretsRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'ListUserWorkloadsSecrets',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListUserWorkloadsSecretsResponse',
    });
}

sub update_user_workloads_secret {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UpdateUserWorkloadsSecretRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'UpdateUserWorkloadsSecret',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsSecret',
    });
}

sub delete_user_workloads_secret {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::DeleteUserWorkloadsSecretRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'DeleteUserWorkloadsSecret',
        request        => $req,
        response_class => 'Google::Protobuf::Empty::Empty',
    });
}

sub create_user_workloads_config_map {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::CreateUserWorkloadsConfigMapRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'CreateUserWorkloadsConfigMap',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsConfigMap',
    });
}

sub get_user_workloads_config_map {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::GetUserWorkloadsConfigMapRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'GetUserWorkloadsConfigMap',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsConfigMap',
    });
}

sub list_user_workloads_config_maps {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListUserWorkloadsConfigMapsRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'ListUserWorkloadsConfigMaps',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::ListUserWorkloadsConfigMapsResponse',
    });
}

sub update_user_workloads_config_map {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UpdateUserWorkloadsConfigMapRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'UpdateUserWorkloadsConfigMap',
        request        => $req,
        response_class => 'Google::Cloud::Orchestration::Airflow::Service::V1::Environments::UserWorkloadsConfigMap',
    });
}

sub delete_user_workloads_config_map {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::DeleteUserWorkloadsConfigMapRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'DeleteUserWorkloadsConfigMap',
        request        => $req,
        response_class => 'Google::Protobuf::Empty::Empty',
    });
}

sub save_snapshot {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::SaveSnapshotRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'SaveSnapshot',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub load_snapshot {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::LoadSnapshotRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'LoadSnapshot',
        request        => $req,
        response_class => 'Google::Longrunning::Operations::Operation',
    });
}

sub database_failover {
    my ($self, $args) = @_;
    my $req = ref($args) eq 'HASH'
        ? Google::Cloud::Orchestration::Airflow::Service::V1::Environments::DatabaseFailoverRequest->new($args)
        : $args;
    return $self->_grpc_client->call({
        service        => 'google.cloud.orchestration.airflow.service.v1.Environments',
        method         => 'DatabaseFailover',
        request        => $req,