#[derive(Clone, PartialEq, ::prost::Message)]
pub struct AclEntry {
#[prost(string, tag = "1")]
pub value: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub expiration_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "3")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ApiWarning {
#[prost(enumeration = "api_warning::SqlApiWarningCode", tag = "1")]
pub code: i32,
#[prost(string, tag = "2")]
pub message: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub region: ::prost::alloc::string::String,
}
pub mod api_warning {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlApiWarningCode {
Unspecified = 0,
RegionUnreachable = 1,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupRetentionSettings {
#[prost(enumeration = "backup_retention_settings::RetentionUnit", tag = "1")]
pub retention_unit: i32,
#[prost(message, optional, tag = "2")]
pub retained_backups: ::core::option::Option<i32>,
}
pub mod backup_retention_settings {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RetentionUnit {
Unspecified = 0,
Count = 1,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupConfiguration {
#[prost(string, tag = "1")]
pub start_time: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub enabled: ::core::option::Option<bool>,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub binary_log_enabled: ::core::option::Option<bool>,
#[prost(message, optional, tag = "5")]
pub replication_log_archiving_enabled: ::core::option::Option<bool>,
#[prost(string, tag = "6")]
pub location: ::prost::alloc::string::String,
#[prost(message, optional, tag = "7")]
pub point_in_time_recovery_enabled: ::core::option::Option<bool>,
#[prost(message, optional, tag = "9")]
pub transaction_log_retention_days: ::core::option::Option<i32>,
#[prost(message, optional, tag = "10")]
pub backup_retention_settings: ::core::option::Option<BackupRetentionSettings>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupRun {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(enumeration = "SqlBackupRunStatus", tag = "2")]
pub status: i32,
#[prost(message, optional, tag = "3")]
pub enqueued_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(int64, tag = "4")]
pub id: i64,
#[prost(message, optional, tag = "5")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "6")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "7")]
pub error: ::core::option::Option<OperationError>,
#[prost(enumeration = "SqlBackupRunType", tag = "8")]
pub r#type: i32,
#[prost(string, tag = "9")]
pub description: ::prost::alloc::string::String,
#[prost(message, optional, tag = "10")]
pub window_start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "11")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "12")]
pub self_link: ::prost::alloc::string::String,
#[prost(string, tag = "13")]
pub location: ::prost::alloc::string::String,
#[prost(message, optional, tag = "16")]
pub disk_encryption_configuration: ::core::option::Option<DiskEncryptionConfiguration>,
#[prost(message, optional, tag = "17")]
pub disk_encryption_status: ::core::option::Option<DiskEncryptionStatus>,
#[prost(enumeration = "SqlBackupKind", tag = "19")]
pub backup_kind: i32,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupRunsListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<BackupRun>,
#[prost(string, tag = "3")]
pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BinLogCoordinates {
#[prost(string, tag = "1")]
pub bin_log_file_name: ::prost::alloc::string::String,
#[prost(int64, tag = "2")]
pub bin_log_position: i64,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct BackupContext {
#[prost(int64, tag = "1")]
pub backup_id: i64,
#[prost(string, tag = "2")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CloneContext {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(int64, tag = "2")]
pub pitr_timestamp_ms: i64,
#[prost(string, tag = "3")]
pub destination_instance_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub bin_log_coordinates: ::core::option::Option<BinLogCoordinates>,
#[prost(message, optional, tag = "5")]
pub point_in_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Database {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub charset: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub collation: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub etag: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "7")]
pub self_link: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub project: ::prost::alloc::string::String,
#[prost(oneof = "database::DatabaseDetails", tags = "9")]
pub database_details: ::core::option::Option<database::DatabaseDetails>,
}
pub mod database {
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DatabaseDetails {
#[prost(message, tag = "9")]
SqlserverDatabaseDetails(super::SqlServerDatabaseDetails),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlServerDatabaseDetails {
#[prost(int32, tag = "1")]
pub compatibility_level: i32,
#[prost(string, tag = "2")]
pub recovery_model: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DatabaseFlags {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub value: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DatabaseInstance {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(enumeration = "database_instance::SqlInstanceState", tag = "2")]
pub state: i32,
#[prost(enumeration = "SqlDatabaseVersion", tag = "3")]
pub database_version: i32,
#[prost(message, optional, tag = "4")]
pub settings: ::core::option::Option<Settings>,
#[prost(string, tag = "5")]
pub etag: ::prost::alloc::string::String,
#[prost(message, optional, tag = "6")]
pub failover_replica: ::core::option::Option<database_instance::SqlFailoverReplica>,
#[prost(string, tag = "7")]
pub master_instance_name: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "8")]
pub replica_names: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[deprecated]
#[prost(message, optional, tag = "9")]
pub max_disk_size: ::core::option::Option<i64>,
#[deprecated]
#[prost(message, optional, tag = "10")]
pub current_disk_size: ::core::option::Option<i64>,
#[prost(message, repeated, tag = "11")]
pub ip_addresses: ::prost::alloc::vec::Vec<IpMapping>,
#[prost(message, optional, tag = "12")]
pub server_ca_cert: ::core::option::Option<SslCert>,
#[prost(enumeration = "SqlInstanceType", tag = "13")]
pub instance_type: i32,
#[prost(string, tag = "14")]
pub project: ::prost::alloc::string::String,
#[deprecated]
#[prost(string, tag = "15")]
pub ipv6_address: ::prost::alloc::string::String,
#[prost(string, tag = "16")]
pub service_account_email_address: ::prost::alloc::string::String,
#[prost(message, optional, tag = "17")]
pub on_premises_configuration: ::core::option::Option<OnPremisesConfiguration>,
#[prost(message, optional, tag = "18")]
pub replica_configuration: ::core::option::Option<ReplicaConfiguration>,
#[prost(enumeration = "SqlBackendType", tag = "19")]
pub backend_type: i32,
#[prost(string, tag = "20")]
pub self_link: ::prost::alloc::string::String,
#[prost(enumeration = "SqlSuspensionReason", repeated, tag = "21")]
pub suspension_reason: ::prost::alloc::vec::Vec<i32>,
#[prost(string, tag = "22")]
pub connection_name: ::prost::alloc::string::String,
#[prost(string, tag = "23")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "24")]
pub region: ::prost::alloc::string::String,
#[prost(string, tag = "25")]
pub gce_zone: ::prost::alloc::string::String,
#[prost(string, tag = "34")]
pub secondary_gce_zone: ::prost::alloc::string::String,
#[prost(message, optional, tag = "26")]
pub disk_encryption_configuration: ::core::option::Option<DiskEncryptionConfiguration>,
#[prost(message, optional, tag = "27")]
pub disk_encryption_status: ::core::option::Option<DiskEncryptionStatus>,
#[prost(string, tag = "29")]
pub root_password: ::prost::alloc::string::String,
#[prost(message, optional, tag = "30")]
pub scheduled_maintenance: ::core::option::Option<database_instance::SqlScheduledMaintenance>,
#[prost(message, optional, tag = "35")]
pub satisfies_pzs: ::core::option::Option<bool>,
#[prost(message, optional, tag = "38")]
pub out_of_disk_report: ::core::option::Option<database_instance::SqlOutOfDiskReport>,
}
pub mod database_instance {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlFailoverReplica {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub available: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlScheduledMaintenance {
#[prost(message, optional, tag = "1")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[deprecated]
#[prost(bool, tag = "2")]
pub can_defer: bool,
#[prost(bool, tag = "3")]
pub can_reschedule: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlOutOfDiskReport {
#[prost(enumeration = "sql_out_of_disk_report::SqlOutOfDiskState", optional, tag = "1")]
pub sql_out_of_disk_state: ::core::option::Option<i32>,
#[prost(int32, optional, tag = "2")]
pub sql_min_recommended_increase_size_gb: ::core::option::Option<i32>,
}
pub mod sql_out_of_disk_report {
#[derive(
Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration,
)]
#[repr(i32)]
pub enum SqlOutOfDiskState {
Unspecified = 0,
Normal = 1,
SoftShutdown = 2,
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlInstanceState {
Unspecified = 0,
Runnable = 1,
Suspended = 2,
PendingDelete = 3,
PendingCreate = 4,
Maintenance = 5,
Failed = 6,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DatabasesListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<Database>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DemoteMasterConfiguration {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub mysql_replica_configuration: ::core::option::Option<DemoteMasterMySqlReplicaConfiguration>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DemoteMasterContext {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub verify_gtid_consistency: ::core::option::Option<bool>,
#[prost(string, tag = "3")]
pub master_instance_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub replica_configuration: ::core::option::Option<DemoteMasterConfiguration>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DemoteMasterMySqlReplicaConfiguration {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub username: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub password: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub client_key: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub client_certificate: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub ca_certificate: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ExportContext {
#[prost(string, tag = "1")]
pub uri: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "2")]
pub databases: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub sql_export_options: ::core::option::Option<export_context::SqlExportOptions>,
#[prost(message, optional, tag = "5")]
pub csv_export_options: ::core::option::Option<export_context::SqlCsvExportOptions>,
#[prost(enumeration = "SqlFileType", tag = "6")]
pub file_type: i32,
#[prost(message, optional, tag = "8")]
pub offload: ::core::option::Option<bool>,
}
pub mod export_context {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlCsvExportOptions {
#[prost(string, tag = "1")]
pub select_query: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlExportOptions {
#[prost(string, repeated, tag = "1")]
pub tables: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "2")]
pub schema_only: ::core::option::Option<bool>,
#[prost(message, optional, tag = "3")]
pub mysql_export_options: ::core::option::Option<sql_export_options::MysqlExportOptions>,
}
pub mod sql_export_options {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MysqlExportOptions {
#[prost(message, optional, tag = "1")]
pub master_data: ::core::option::Option<i32>,
}
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FailoverContext {
#[prost(int64, tag = "1")]
pub settings_version: i64,
#[prost(string, tag = "2")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Flag {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(enumeration = "SqlFlagType", tag = "2")]
pub r#type: i32,
#[prost(enumeration = "SqlDatabaseVersion", repeated, tag = "3")]
pub applies_to: ::prost::alloc::vec::Vec<i32>,
#[prost(string, repeated, tag = "4")]
pub allowed_string_values: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(message, optional, tag = "5")]
pub min_value: ::core::option::Option<i64>,
#[prost(message, optional, tag = "6")]
pub max_value: ::core::option::Option<i64>,
#[prost(message, optional, tag = "7")]
pub requires_restart: ::core::option::Option<bool>,
#[prost(string, tag = "8")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "9")]
pub in_beta: ::core::option::Option<bool>,
#[prost(int64, repeated, tag = "10")]
pub allowed_int_values: ::prost::alloc::vec::Vec<i64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlagsListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<Flag>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ImportContext {
#[prost(string, tag = "1")]
pub uri: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub database: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
#[prost(enumeration = "SqlFileType", tag = "4")]
pub file_type: i32,
#[prost(message, optional, tag = "5")]
pub csv_import_options: ::core::option::Option<import_context::SqlCsvImportOptions>,
#[prost(string, tag = "6")]
pub import_user: ::prost::alloc::string::String,
#[prost(message, optional, tag = "7")]
pub bak_import_options: ::core::option::Option<import_context::SqlBakImportOptions>,
}
pub mod import_context {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlCsvImportOptions {
#[prost(string, tag = "1")]
pub table: ::prost::alloc::string::String,
#[prost(string, repeated, tag = "2")]
pub columns: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlBakImportOptions {
#[prost(message, optional, tag = "1")]
pub encryption_options: ::core::option::Option<sql_bak_import_options::EncryptionOptions>,
}
pub mod sql_bak_import_options {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EncryptionOptions {
#[prost(string, tag = "1")]
pub cert_path: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub pvk_path: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub pvk_password: ::prost::alloc::string::String,
}
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesCloneRequest {
#[prost(message, optional, tag = "1")]
pub clone_context: ::core::option::Option<CloneContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesDemoteMasterRequest {
#[prost(message, optional, tag = "1")]
pub demote_master_context: ::core::option::Option<DemoteMasterContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesExportRequest {
#[prost(message, optional, tag = "1")]
pub export_context: ::core::option::Option<ExportContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesFailoverRequest {
#[prost(message, optional, tag = "1")]
pub failover_context: ::core::option::Option<FailoverContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesImportRequest {
#[prost(message, optional, tag = "1")]
pub import_context: ::core::option::Option<ImportContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub warnings: ::prost::alloc::vec::Vec<ApiWarning>,
#[prost(message, repeated, tag = "3")]
pub items: ::prost::alloc::vec::Vec<DatabaseInstance>,
#[prost(string, tag = "4")]
pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesListServerCasResponse {
#[prost(message, repeated, tag = "1")]
pub certs: ::prost::alloc::vec::Vec<SslCert>,
#[prost(string, tag = "2")]
pub active_version: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesRestoreBackupRequest {
#[prost(message, optional, tag = "1")]
pub restore_backup_context: ::core::option::Option<RestoreBackupContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesRotateServerCaRequest {
#[prost(message, optional, tag = "1")]
pub rotate_server_ca_context: ::core::option::Option<RotateServerCaContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InstancesTruncateLogRequest {
#[prost(message, optional, tag = "1")]
pub truncate_log_context: ::core::option::Option<TruncateLogContext>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesVerifyExternalSyncSettingsResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub errors: ::prost::alloc::vec::Vec<SqlExternalSyncSettingError>,
#[prost(message, repeated, tag = "3")]
pub warnings: ::prost::alloc::vec::Vec<SqlExternalSyncSettingError>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlExternalSyncSettingError {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(
enumeration = "sql_external_sync_setting_error::SqlExternalSyncSettingErrorType",
tag = "2"
)]
pub r#type: i32,
#[prost(string, tag = "3")]
pub detail: ::prost::alloc::string::String,
}
pub mod sql_external_sync_setting_error {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlExternalSyncSettingErrorType {
Unspecified = 0,
ConnectionFailure = 1,
BinlogNotEnabled = 2,
IncompatibleDatabaseVersion = 3,
ReplicaAlreadySetup = 4,
InsufficientPrivilege = 5,
UnsupportedMigrationType = 6,
NoPglogicalInstalled = 7,
PglogicalNodeAlreadyExists = 8,
InvalidWalLevel = 9,
InvalidSharedPreloadLibrary = 10,
InsufficientMaxReplicationSlots = 11,
InsufficientMaxWalSenders = 12,
InsufficientMaxWorkerProcesses = 13,
UnsupportedExtensions = 14,
InvalidRdsLogicalReplication = 15,
InvalidLoggingSetup = 16,
InvalidDbParam = 17,
UnsupportedGtidMode = 18,
SqlserverAgentNotRunning = 19,
UnsupportedTableDefinition = 20,
UnsupportedDefiner = 21,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IpConfiguration {
#[prost(message, optional, tag = "1")]
pub ipv4_enabled: ::core::option::Option<bool>,
#[prost(string, tag = "2")]
pub private_network: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub require_ssl: ::core::option::Option<bool>,
#[prost(message, repeated, tag = "4")]
pub authorized_networks: ::prost::alloc::vec::Vec<AclEntry>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IpMapping {
#[prost(enumeration = "SqlIpAddressType", tag = "1")]
pub r#type: i32,
#[prost(string, tag = "2")]
pub ip_address: ::prost::alloc::string::String,
#[prost(message, optional, tag = "3")]
pub time_to_retire: ::core::option::Option<::prost_types::Timestamp>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LocationPreference {
#[deprecated]
#[prost(string, tag = "1")]
pub follow_gae_application: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub zone: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub secondary_zone: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MaintenanceWindow {
#[prost(message, optional, tag = "1")]
pub hour: ::core::option::Option<i32>,
#[prost(message, optional, tag = "2")]
pub day: ::core::option::Option<i32>,
#[prost(enumeration = "SqlUpdateTrack", tag = "3")]
pub update_track: i32,
#[prost(string, tag = "4")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DenyMaintenancePeriod {
#[prost(string, tag = "1")]
pub start_date: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub end_date: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub time: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InsightsConfig {
#[prost(bool, tag = "1")]
pub query_insights_enabled: bool,
#[prost(bool, tag = "2")]
pub record_client_address: bool,
#[prost(bool, tag = "3")]
pub record_application_tags: bool,
#[prost(message, optional, tag = "4")]
pub query_string_length: ::core::option::Option<i32>,
#[prost(message, optional, tag = "5")]
pub query_plans_per_minute: ::core::option::Option<i32>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct MySqlReplicaConfiguration {
#[prost(string, tag = "1")]
pub dump_file_path: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub username: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub password: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub connect_retry_interval: ::core::option::Option<i32>,
#[prost(message, optional, tag = "5")]
pub master_heartbeat_period: ::core::option::Option<i64>,
#[prost(string, tag = "6")]
pub ca_certificate: ::prost::alloc::string::String,
#[prost(string, tag = "7")]
pub client_certificate: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub client_key: ::prost::alloc::string::String,
#[prost(string, tag = "9")]
pub ssl_cipher: ::prost::alloc::string::String,
#[prost(message, optional, tag = "10")]
pub verify_server_certificate: ::core::option::Option<bool>,
#[prost(string, tag = "11")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OnPremisesConfiguration {
#[prost(string, tag = "1")]
pub host_port: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub username: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub password: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub ca_certificate: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub client_certificate: ::prost::alloc::string::String,
#[prost(string, tag = "7")]
pub client_key: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub dump_file_path: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiskEncryptionConfiguration {
#[prost(string, tag = "1")]
pub kms_key_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DiskEncryptionStatus {
#[prost(string, tag = "1")]
pub kms_key_version_name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub kind: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Operation {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub target_link: ::prost::alloc::string::String,
#[prost(enumeration = "operation::SqlOperationStatus", tag = "3")]
pub status: i32,
#[prost(string, tag = "4")]
pub user: ::prost::alloc::string::String,
#[prost(message, optional, tag = "5")]
pub insert_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "6")]
pub start_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "7")]
pub end_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "8")]
pub error: ::core::option::Option<OperationErrors>,
#[prost(enumeration = "operation::SqlOperationType", tag = "9")]
pub operation_type: i32,
#[prost(message, optional, tag = "10")]
pub import_context: ::core::option::Option<ImportContext>,
#[prost(message, optional, tag = "11")]
pub export_context: ::core::option::Option<ExportContext>,
#[prost(message, optional, tag = "17")]
pub backup_context: ::core::option::Option<BackupContext>,
#[prost(string, tag = "12")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "13")]
pub target_id: ::prost::alloc::string::String,
#[prost(string, tag = "14")]
pub self_link: ::prost::alloc::string::String,
#[prost(string, tag = "15")]
pub target_project: ::prost::alloc::string::String,
}
pub mod operation {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlOperationType {
Unspecified = 0,
Import = 1,
Export = 2,
Create = 3,
Update = 4,
Delete = 5,
Restart = 6,
Backup = 7,
Snapshot = 8,
BackupVolume = 9,
DeleteVolume = 10,
RestoreVolume = 11,
InjectUser = 12,
Clone = 14,
StopReplica = 15,
StartReplica = 16,
PromoteReplica = 17,
CreateReplica = 18,
CreateUser = 19,
DeleteUser = 20,
UpdateUser = 21,
CreateDatabase = 22,
DeleteDatabase = 23,
UpdateDatabase = 24,
Failover = 25,
DeleteBackup = 26,
RecreateReplica = 27,
TruncateLog = 28,
DemoteMaster = 29,
Maintenance = 30,
EnablePrivateIp = 31,
DeferMaintenance = 32,
CreateClone = 33,
RescheduleMaintenance = 34,
StartExternalSync = 35,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlOperationStatus {
Unspecified = 0,
Pending = 1,
Running = 2,
Done = 3,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OperationError {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub code: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub message: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OperationErrors {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub errors: ::prost::alloc::vec::Vec<OperationError>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OperationsListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<Operation>,
#[prost(string, tag = "3")]
pub next_page_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReplicaConfiguration {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub mysql_replica_configuration: ::core::option::Option<MySqlReplicaConfiguration>,
#[prost(message, optional, tag = "3")]
pub failover_target: ::core::option::Option<bool>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RestoreBackupContext {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(int64, tag = "2")]
pub backup_run_id: i64,
#[prost(string, tag = "3")]
pub instance_id: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RotateServerCaContext {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub next_version: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Settings {
#[prost(message, optional, tag = "1")]
pub settings_version: ::core::option::Option<i64>,
#[deprecated]
#[prost(string, repeated, tag = "2")]
pub authorized_gae_applications: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
#[prost(string, tag = "3")]
pub tier: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub kind: ::prost::alloc::string::String,
#[prost(map = "string, string", tag = "5")]
pub user_labels:
::std::collections::HashMap<::prost::alloc::string::String, ::prost::alloc::string::String>,
#[prost(enumeration = "SqlAvailabilityType", tag = "6")]
pub availability_type: i32,
#[prost(enumeration = "SqlPricingPlan", tag = "7")]
pub pricing_plan: i32,
#[deprecated]
#[prost(enumeration = "SqlReplicationType", tag = "8")]
pub replication_type: i32,
#[prost(message, optional, tag = "9")]
pub storage_auto_resize_limit: ::core::option::Option<i64>,
#[prost(enumeration = "settings::SqlActivationPolicy", tag = "10")]
pub activation_policy: i32,
#[prost(message, optional, tag = "11")]
pub ip_configuration: ::core::option::Option<IpConfiguration>,
#[prost(message, optional, tag = "12")]
pub storage_auto_resize: ::core::option::Option<bool>,
#[prost(message, optional, tag = "13")]
pub location_preference: ::core::option::Option<LocationPreference>,
#[prost(message, repeated, tag = "14")]
pub database_flags: ::prost::alloc::vec::Vec<DatabaseFlags>,
#[prost(enumeration = "SqlDataDiskType", tag = "15")]
pub data_disk_type: i32,
#[prost(message, optional, tag = "16")]
pub maintenance_window: ::core::option::Option<MaintenanceWindow>,
#[prost(message, optional, tag = "17")]
pub backup_configuration: ::core::option::Option<BackupConfiguration>,
#[prost(message, optional, tag = "18")]
pub database_replication_enabled: ::core::option::Option<bool>,
#[deprecated]
#[prost(message, optional, tag = "19")]
pub crash_safe_replication_enabled: ::core::option::Option<bool>,
#[prost(message, optional, tag = "20")]
pub data_disk_size_gb: ::core::option::Option<i64>,
#[prost(message, optional, tag = "22")]
pub active_directory_config: ::core::option::Option<SqlActiveDirectoryConfig>,
#[prost(string, tag = "23")]
pub collation: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "24")]
pub deny_maintenance_periods: ::prost::alloc::vec::Vec<DenyMaintenancePeriod>,
#[prost(message, optional, tag = "25")]
pub insights_config: ::core::option::Option<InsightsConfig>,
}
pub mod settings {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlActivationPolicy {
Unspecified = 0,
Always = 1,
Never = 2,
OnDemand = 3,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCert {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub cert_serial_number: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub cert: ::prost::alloc::string::String,
#[prost(message, optional, tag = "4")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "5")]
pub common_name: ::prost::alloc::string::String,
#[prost(message, optional, tag = "6")]
pub expiration_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "7")]
pub sha1_fingerprint: ::prost::alloc::string::String,
#[prost(string, tag = "8")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "9")]
pub self_link: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCertDetail {
#[prost(message, optional, tag = "1")]
pub cert_info: ::core::option::Option<SslCert>,
#[prost(string, tag = "2")]
pub cert_private_key: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCertsCreateEphemeralRequest {
#[prost(string, tag = "1")]
pub public_key: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub access_token: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCertsInsertRequest {
#[prost(string, tag = "1")]
pub common_name: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesRescheduleMaintenanceRequestBody {
#[prost(message, optional, tag = "3")]
pub reschedule:
::core::option::Option<sql_instances_reschedule_maintenance_request_body::Reschedule>,
}
pub mod sql_instances_reschedule_maintenance_request_body {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Reschedule {
#[prost(enumeration = "RescheduleType", tag = "1")]
pub reschedule_type: i32,
#[prost(message, optional, tag = "2")]
pub schedule_time: ::core::option::Option<::prost_types::Timestamp>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum RescheduleType {
Unspecified = 0,
Immediate = 1,
NextAvailableWindow = 2,
SpecificTime = 3,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCertsInsertResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub operation: ::core::option::Option<Operation>,
#[prost(message, optional, tag = "3")]
pub server_ca_cert: ::core::option::Option<SslCert>,
#[prost(message, optional, tag = "4")]
pub client_cert: ::core::option::Option<SslCertDetail>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SslCertsListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<SslCert>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TruncateLogContext {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub log_type: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlActiveDirectoryConfig {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub domain: ::prost::alloc::string::String,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlFileType {
Unspecified = 0,
Sql = 1,
Csv = 2,
Bak = 4,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlBackupRunStatus {
Unspecified = 0,
Enqueued = 1,
Overdue = 2,
Running = 3,
Failed = 4,
Successful = 5,
Skipped = 6,
DeletionPending = 7,
DeletionFailed = 8,
Deleted = 9,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlBackupRunType {
Unspecified = 0,
Automated = 1,
OnDemand = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlBackupKind {
Unspecified = 0,
Snapshot = 1,
Physical = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlBackendType {
Unspecified = 0,
FirstGen = 1,
SecondGen = 2,
External = 3,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlIpAddressType {
Unspecified = 0,
Primary = 1,
Outgoing = 2,
Private = 3,
Migrated1stGen = 4,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlInstanceType {
Unspecified = 0,
CloudSqlInstance = 1,
OnPremisesInstance = 2,
ReadReplicaInstance = 3,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlDatabaseVersion {
Unspecified = 0,
Mysql51 = 2,
Mysql55 = 3,
Mysql56 = 5,
Mysql57 = 6,
Postgres96 = 9,
Postgres11 = 10,
Sqlserver2017Standard = 11,
Sqlserver2017Enterprise = 14,
Sqlserver2017Express = 15,
Sqlserver2017Web = 16,
Postgres10 = 18,
Postgres12 = 19,
Mysql80 = 20,
Postgres13 = 23,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlSuspensionReason {
Unspecified = 0,
BillingIssue = 2,
LegalIssue = 3,
OperationalIssue = 4,
KmsKeyIssue = 5,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlPricingPlan {
Unspecified = 0,
Package = 1,
PerUse = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlReplicationType {
Unspecified = 0,
Synchronous = 1,
Asynchronous = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlDataDiskType {
Unspecified = 0,
PdSsd = 1,
PdHdd = 2,
ObsoleteLocalSsd = 3,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlAvailabilityType {
Unspecified = 0,
Zonal = 1,
Regional = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlUpdateTrack {
Unspecified = 0,
Canary = 1,
Stable = 2,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlFlagType {
Unspecified = 0,
Boolean = 1,
String = 2,
Integer = 3,
None = 4,
MysqlTimezoneOffset = 5,
Float = 6,
RepeatedString = 7,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlBackupRunsDeleteRequest {
#[prost(int64, tag = "1")]
pub id: i64,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlBackupRunsGetRequest {
#[prost(int64, tag = "1")]
pub id: i64,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlBackupRunsInsertRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<BackupRun>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlBackupRunsListRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub max_results: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlDatabasesDeleteRequest {
#[prost(string, tag = "1")]
pub database: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlDatabasesGetRequest {
#[prost(string, tag = "1")]
pub database: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlDatabasesInsertRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<Database>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlDatabasesListRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlDatabasesUpdateRequest {
#[prost(string, tag = "1")]
pub database: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<Database>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlFlagsListRequest {
#[prost(string, tag = "1")]
pub database_version: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesAddServerCaRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesCloneRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesCloneRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesDeleteRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesDemoteMasterRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesDemoteMasterRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesExportRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesExportRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesFailoverRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesFailoverRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesGetRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesImportRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesImportRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesInsertRequest {
#[prost(string, tag = "1")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<DatabaseInstance>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesListRequest {
#[prost(string, tag = "1")]
pub filter: ::prost::alloc::string::String,
#[prost(uint32, tag = "2")]
pub max_results: u32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesListServerCasRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesPatchRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<DatabaseInstance>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesPromoteReplicaRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesResetSslConfigRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesRestartRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesRestoreBackupRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesRestoreBackupRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesRotateServerCaRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesRotateServerCaRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesStartReplicaRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesStopReplicaRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesTruncateLogRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<InstancesTruncateLogRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesUpdateRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<DatabaseInstance>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesRescheduleMaintenanceRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<SqlInstancesRescheduleMaintenanceRequestBody>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesVerifyExternalSyncSettingsRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(bool, tag = "3")]
pub verify_connection_only: bool,
#[prost(
enumeration = "sql_instances_verify_external_sync_settings_request::ExternalSyncMode",
tag = "4"
)]
pub sync_mode: i32,
}
pub mod sql_instances_verify_external_sync_settings_request {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum ExternalSyncMode {
Unspecified = 0,
Online = 1,
Offline = 2,
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesStartExternalSyncRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(
enumeration = "sql_instances_verify_external_sync_settings_request::ExternalSyncMode",
tag = "3"
)]
pub sync_mode: i32,
#[prost(bool, tag = "4")]
pub skip_verification: bool,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlOperationsGetRequest {
#[prost(string, tag = "1")]
pub operation: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlOperationsListRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(uint32, tag = "2")]
pub max_results: u32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlInstancesCreateEphemeralCertRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<SslCertsCreateEphemeralRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlSslCertsDeleteRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub sha1_fingerprint: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlSslCertsGetRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub sha1_fingerprint: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlSslCertsInsertRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<SslCertsInsertRequest>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlSslCertsListRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[doc = r" Generated client implementations."]
pub mod sql_backup_runs_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlBackupRunsServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlBackupRunsServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlBackupRunsServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlBackupRunsServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Deletes the backup taken by a backup run."]
pub async fn delete(
&mut self,
request: impl tonic::IntoRequest<super::SqlBackupRunsDeleteRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlBackupRunsService/Delete",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Retrieves a resource containing information about a backup run."]
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::SqlBackupRunsGetRequest>,
) -> Result<tonic::Response<super::BackupRun>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlBackupRunsService/Get",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Creates a new backup run on demand. This method is applicable only to"]
#[doc = " Second Generation instances."]
pub async fn insert(
&mut self,
request: impl tonic::IntoRequest<super::SqlBackupRunsInsertRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlBackupRunsService/Insert",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists all backup runs associated with a given instance and configuration in"]
#[doc = " the reverse chronological order of the backup initiation time."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlBackupRunsListRequest>,
) -> Result<tonic::Response<super::BackupRunsListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlBackupRunsService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[doc = r" Generated client implementations."]
pub mod sql_databases_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlDatabasesServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlDatabasesServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlDatabasesServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlDatabasesServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Deletes a database from a Cloud SQL instance."]
pub async fn delete(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesDeleteRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/Delete",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Retrieves a resource containing information about a database inside a Cloud"]
#[doc = " SQL instance."]
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesGetRequest>,
) -> Result<tonic::Response<super::Database>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/Get",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Inserts a resource containing information about a database inside a Cloud"]
#[doc = " SQL instance."]
pub async fn insert(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesInsertRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/Insert",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists databases in the specified Cloud SQL instance."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesListRequest>,
) -> Result<tonic::Response<super::DatabasesListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Partially updates a resource containing information about a database inside"]
#[doc = " a Cloud SQL instance. This method supports patch semantics."]
pub async fn patch(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesUpdateRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/Patch",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Updates a resource containing information about a database inside a Cloud"]
#[doc = " SQL instance."]
pub async fn update(
&mut self,
request: impl tonic::IntoRequest<super::SqlDatabasesUpdateRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlDatabasesService/Update",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[doc = r" Generated client implementations."]
pub mod sql_flags_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlFlagsServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlFlagsServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlFlagsServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlFlagsServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " List all available database flags for Cloud SQL instances."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlFlagsListRequest>,
) -> Result<tonic::Response<super::FlagsListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlFlagsService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[doc = r" Generated client implementations."]
pub mod sql_instances_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlInstancesServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlInstancesServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlInstancesServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlInstancesServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Add a new trusted Certificate Authority (CA) version for the specified"]
#[doc = " instance. Required to prepare for a certificate rotation. If a CA version"]
#[doc = " was previously added but never used in a certificate rotation, this"]
#[doc = " operation replaces that version. There cannot be more than one CA version"]
#[doc = " waiting to be rotated in."]
pub async fn add_server_ca(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesAddServerCaRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/AddServerCa",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Creates a Cloud SQL instance as a clone of the source instance. Using this"]
#[doc = " operation might cause your instance to restart."]
pub async fn clone(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesCloneRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Clone",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Deletes a Cloud SQL instance."]
pub async fn delete(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesDeleteRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Delete",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Demotes the stand-alone instance to be a Cloud SQL read replica for an"]
#[doc = " external database server."]
pub async fn demote_master(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesDemoteMasterRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/DemoteMaster",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Exports data from a Cloud SQL instance to a Cloud Storage bucket as a SQL"]
#[doc = " dump or CSV file."]
pub async fn export(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesExportRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Export",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Failover the instance to its failover replica instance. Using this"]
#[doc = " operation might cause your instance to restart."]
pub async fn failover(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesFailoverRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Failover",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Retrieves a resource containing information about a Cloud SQL instance."]
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesGetRequest>,
) -> Result<tonic::Response<super::DatabaseInstance>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Get",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Imports data into a Cloud SQL instance from a SQL dump or CSV file in"]
#[doc = " Cloud Storage."]
pub async fn import(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesImportRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Import",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Creates a new Cloud SQL instance."]
pub async fn insert(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesInsertRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Insert",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists instances under a given project."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesListRequest>,
) -> Result<tonic::Response<super::InstancesListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists all of the trusted Certificate Authorities (CAs) for the specified"]
#[doc = " instance. There can be up to three CAs listed: the CA that was used to sign"]
#[doc = " the certificate that is currently in use, a CA that has been added but not"]
#[doc = " yet used to sign a certificate, and a CA used to sign a certificate that"]
#[doc = " has previously rotated out."]
pub async fn list_server_cas(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesListServerCasRequest>,
) -> Result<tonic::Response<super::InstancesListServerCasResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/ListServerCas",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Updates settings of a Cloud SQL instance."]
#[doc = " This method supports patch semantics."]
pub async fn patch(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesPatchRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Patch",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Promotes the read replica instance to be a stand-alone Cloud SQL instance."]
#[doc = " Using this operation might cause your instance to restart."]
pub async fn promote_replica(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesPromoteReplicaRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/PromoteReplica",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Deletes all client certificates and generates a new server SSL certificate"]
#[doc = " for the instance."]
pub async fn reset_ssl_config(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesResetSslConfigRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/ResetSslConfig",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Restarts a Cloud SQL instance."]
pub async fn restart(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesRestartRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Restart",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Restores a backup of a Cloud SQL instance. Using this operation might cause"]
#[doc = " your instance to restart."]
pub async fn restore_backup(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesRestoreBackupRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/RestoreBackup",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Rotates the server certificate to one signed by the Certificate Authority"]
#[doc = " (CA) version previously added with the addServerCA method."]
pub async fn rotate_server_ca(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesRotateServerCaRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/RotateServerCa",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Starts the replication in the read replica instance."]
pub async fn start_replica(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesStartReplicaRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/StartReplica",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Stops the replication in the read replica instance."]
pub async fn stop_replica(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesStopReplicaRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/StopReplica",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Truncate MySQL general and slow query log tables"]
#[doc = " MySQL only."]
pub async fn truncate_log(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesTruncateLogRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/TruncateLog",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Updates settings of a Cloud SQL instance. Using this operation might cause"]
#[doc = " your instance to restart."]
pub async fn update(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesUpdateRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/Update",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Generates a short-lived X509 certificate containing the provided public key"]
#[doc = " and signed by a private key specific to the target instance. Users may use"]
#[doc = " the certificate to authenticate as themselves when connecting to the"]
#[doc = " database."]
pub async fn create_ephemeral(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesCreateEphemeralCertRequest>,
) -> Result<tonic::Response<super::SslCert>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/CreateEphemeral",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Reschedules the maintenance on the given instance."]
pub async fn reschedule_maintenance(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesRescheduleMaintenanceRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/RescheduleMaintenance",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Verify External primary instance external sync settings."]
pub async fn verify_external_sync_settings(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesVerifyExternalSyncSettingsRequest>,
) -> Result<
tonic::Response<super::SqlInstancesVerifyExternalSyncSettingsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/VerifyExternalSyncSettings",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Start External primary instance migration."]
pub async fn start_external_sync(
&mut self,
request: impl tonic::IntoRequest<super::SqlInstancesStartExternalSyncRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlInstancesService/StartExternalSync",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[doc = r" Generated client implementations."]
pub mod sql_operations_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlOperationsServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlOperationsServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlOperationsServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlOperationsServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Retrieves an instance operation that has been performed on an instance."]
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::SqlOperationsGetRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlOperationsService/Get",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists all instance operations that have been performed on the given Cloud"]
#[doc = " SQL instance in the reverse chronological order of the start time."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlOperationsListRequest>,
) -> Result<tonic::Response<super::OperationsListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlOperationsService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[doc = r" Generated client implementations."]
pub mod sql_ssl_certs_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlSslCertsServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlSslCertsServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlSslCertsServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlSslCertsServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Deletes the SSL certificate. For First Generation instances, the"]
#[doc = " certificate remains valid until the instance is restarted."]
pub async fn delete(
&mut self,
request: impl tonic::IntoRequest<super::SqlSslCertsDeleteRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlSslCertsService/Delete",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Retrieves a particular SSL certificate. Does not include the private key"]
#[doc = " (required for usage). The private key must be saved from the response to"]
#[doc = " initial creation."]
pub async fn get(
&mut self,
request: impl tonic::IntoRequest<super::SqlSslCertsGetRequest>,
) -> Result<tonic::Response<super::SslCert>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlSslCertsService/Get",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Creates an SSL certificate and returns it along with the private key and"]
#[doc = " server certificate authority. The new certificate will not be usable until"]
#[doc = " the instance is restarted."]
pub async fn insert(
&mut self,
request: impl tonic::IntoRequest<super::SqlSslCertsInsertRequest>,
) -> Result<tonic::Response<super::SslCertsInsertResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlSslCertsService/Insert",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists all of the current SSL certificates for the instance."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlSslCertsListRequest>,
) -> Result<tonic::Response<super::SslCertsListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlSslCertsService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlTiersListRequest {
#[prost(string, tag = "1")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TiersListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<Tier>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Tier {
#[prost(string, tag = "1")]
pub tier: ::prost::alloc::string::String,
#[prost(int64, tag = "2")]
pub ram: i64,
#[prost(string, tag = "3")]
pub kind: ::prost::alloc::string::String,
#[prost(int64, tag = "4")]
pub disk_quota: i64,
#[prost(string, repeated, tag = "5")]
pub region: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[doc = r" Generated client implementations."]
pub mod sql_tiers_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[doc = " Service for providing machine types (tiers) for Cloud SQL."]
#[derive(Debug, Clone)]
pub struct SqlTiersServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlTiersServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlTiersServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlTiersServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Lists all available machine types (tiers) for Cloud SQL, for example,"]
#[doc = " db-custom-1-3840. For related information, see <a"]
#[doc = " href=\"/sql/pricing\">Pricing</a>."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlTiersListRequest>,
) -> Result<tonic::Response<super::TiersListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlTiersService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlUsersDeleteRequest {
#[prost(string, tag = "1")]
pub host: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlUsersUpdateRequest {
#[prost(string, tag = "1")]
pub host: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<User>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlUsersInsertRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
#[prost(message, optional, tag = "100")]
pub body: ::core::option::Option<User>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlUsersListRequest {
#[prost(string, tag = "1")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub project: ::prost::alloc::string::String,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct User {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub password: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub etag: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "5")]
pub host: ::prost::alloc::string::String,
#[prost(string, tag = "6")]
pub instance: ::prost::alloc::string::String,
#[prost(string, tag = "7")]
pub project: ::prost::alloc::string::String,
#[prost(enumeration = "user::SqlUserType", tag = "8")]
pub r#type: i32,
#[prost(oneof = "user::UserDetails", tags = "9")]
pub user_details: ::core::option::Option<user::UserDetails>,
}
pub mod user {
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum SqlUserType {
BuiltIn = 0,
CloudIamUser = 1,
CloudIamServiceAccount = 2,
}
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum UserDetails {
#[prost(message, tag = "9")]
SqlserverUserDetails(super::SqlServerUserDetails),
}
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SqlServerUserDetails {
#[prost(bool, tag = "1")]
pub disabled: bool,
#[prost(string, repeated, tag = "2")]
pub server_roles: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UsersListResponse {
#[prost(string, tag = "1")]
pub kind: ::prost::alloc::string::String,
#[prost(message, repeated, tag = "2")]
pub items: ::prost::alloc::vec::Vec<User>,
#[prost(string, tag = "3")]
pub next_page_token: ::prost::alloc::string::String,
}
#[doc = r" Generated client implementations."]
pub mod sql_users_service_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct SqlUsersServiceClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> SqlUsersServiceClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::ResponseBody: Body + Send + 'static,
T::Error: Into<StdError>,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> SqlUsersServiceClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<http::Request<tonic::body::BoxBody>>>::Error:
Into<StdError> + Send + Sync,
{
SqlUsersServiceClient::new(InterceptedService::new(inner, interceptor))
}
#[doc = r" Compress requests with `gzip`."]
#[doc = r""]
#[doc = r" This requires the server to support it otherwise it might respond with an"]
#[doc = r" error."]
pub fn send_gzip(mut self) -> Self {
self.inner = self.inner.send_gzip();
self
}
#[doc = r" Enable decompressing responses with `gzip`."]
pub fn accept_gzip(mut self) -> Self {
self.inner = self.inner.accept_gzip();
self
}
#[doc = " Deletes a user from a Cloud SQL instance."]
pub async fn delete(
&mut self,
request: impl tonic::IntoRequest<super::SqlUsersDeleteRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlUsersService/Delete",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Creates a new user in a Cloud SQL instance."]
pub async fn insert(
&mut self,
request: impl tonic::IntoRequest<super::SqlUsersInsertRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlUsersService/Insert",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Lists users in the specified Cloud SQL instance."]
pub async fn list(
&mut self,
request: impl tonic::IntoRequest<super::SqlUsersListRequest>,
) -> Result<tonic::Response<super::UsersListResponse>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlUsersService/List",
);
self.inner.unary(request.into_request(), path, codec).await
}
#[doc = " Updates an existing user in a Cloud SQL instance."]
pub async fn update(
&mut self,
request: impl tonic::IntoRequest<super::SqlUsersUpdateRequest>,
) -> Result<tonic::Response<super::Operation>, tonic::Status> {
self.inner.ready().await.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.cloud.sql.v1beta4.SqlUsersService/Update",
);
self.inner.unary(request.into_request(), path, codec).await
}
}
}