#![allow(rustdoc::redundant_explicit_links)]
#![allow(rustdoc::broken_intra_doc_links)]
#[derive(Clone, Debug)]
pub struct SqlBackupRunsService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlBackupRunsService>,
}
impl SqlBackupRunsService {
pub fn builder() -> super::builder::sql_backup_runs_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_backup_runs_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlBackupRunsService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlBackupRunsService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlBackupRunsService> {
super::transport::SqlBackupRunsService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlBackupRunsService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlBackupRunsService::new)
}
pub fn delete(&self) -> super::builder::sql_backup_runs_service::Delete {
super::builder::sql_backup_runs_service::Delete::new(self.inner.clone())
}
pub fn get(&self) -> super::builder::sql_backup_runs_service::Get {
super::builder::sql_backup_runs_service::Get::new(self.inner.clone())
}
pub fn insert(&self) -> super::builder::sql_backup_runs_service::Insert {
super::builder::sql_backup_runs_service::Insert::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_backup_runs_service::List {
super::builder::sql_backup_runs_service::List::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlBackupsService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlBackupsService>,
}
impl SqlBackupsService {
pub fn builder() -> super::builder::sql_backups_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_backups_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlBackupsService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlBackupsService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlBackupsService> {
super::transport::SqlBackupsService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlBackupsService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlBackupsService::new)
}
pub fn create_backup(&self) -> super::builder::sql_backups_service::CreateBackup {
super::builder::sql_backups_service::CreateBackup::new(self.inner.clone())
}
pub fn get_backup(&self) -> super::builder::sql_backups_service::GetBackup {
super::builder::sql_backups_service::GetBackup::new(self.inner.clone())
}
pub fn list_backups(&self) -> super::builder::sql_backups_service::ListBackups {
super::builder::sql_backups_service::ListBackups::new(self.inner.clone())
}
pub fn update_backup(&self) -> super::builder::sql_backups_service::UpdateBackup {
super::builder::sql_backups_service::UpdateBackup::new(self.inner.clone())
}
pub fn delete_backup(&self) -> super::builder::sql_backups_service::DeleteBackup {
super::builder::sql_backups_service::DeleteBackup::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlConnectService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlConnectService>,
}
impl SqlConnectService {
pub fn builder() -> super::builder::sql_connect_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_connect_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlConnectService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlConnectService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlConnectService> {
super::transport::SqlConnectService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlConnectService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlConnectService::new)
}
pub fn get_connect_settings(&self) -> super::builder::sql_connect_service::GetConnectSettings {
super::builder::sql_connect_service::GetConnectSettings::new(self.inner.clone())
}
pub fn generate_ephemeral_cert(
&self,
) -> super::builder::sql_connect_service::GenerateEphemeralCert {
super::builder::sql_connect_service::GenerateEphemeralCert::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlDatabasesService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlDatabasesService>,
}
impl SqlDatabasesService {
pub fn builder() -> super::builder::sql_databases_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_databases_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlDatabasesService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlDatabasesService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlDatabasesService> {
super::transport::SqlDatabasesService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlDatabasesService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlDatabasesService::new)
}
pub fn delete(&self) -> super::builder::sql_databases_service::Delete {
super::builder::sql_databases_service::Delete::new(self.inner.clone())
}
pub fn get(&self) -> super::builder::sql_databases_service::Get {
super::builder::sql_databases_service::Get::new(self.inner.clone())
}
pub fn insert(&self) -> super::builder::sql_databases_service::Insert {
super::builder::sql_databases_service::Insert::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_databases_service::List {
super::builder::sql_databases_service::List::new(self.inner.clone())
}
pub fn patch(&self) -> super::builder::sql_databases_service::Patch {
super::builder::sql_databases_service::Patch::new(self.inner.clone())
}
pub fn update(&self) -> super::builder::sql_databases_service::Update {
super::builder::sql_databases_service::Update::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlFlagsService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlFlagsService>,
}
impl SqlFlagsService {
pub fn builder() -> super::builder::sql_flags_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_flags_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlFlagsService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlFlagsService>> {
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlFlagsService> {
super::transport::SqlFlagsService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlFlagsService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlFlagsService::new)
}
pub fn list(&self) -> super::builder::sql_flags_service::List {
super::builder::sql_flags_service::List::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlInstancesService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlInstancesService>,
}
impl SqlInstancesService {
pub fn builder() -> super::builder::sql_instances_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_instances_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlInstancesService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlInstancesService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlInstancesService> {
super::transport::SqlInstancesService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlInstancesService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlInstancesService::new)
}
pub fn add_server_ca(&self) -> super::builder::sql_instances_service::AddServerCa {
super::builder::sql_instances_service::AddServerCa::new(self.inner.clone())
}
pub fn add_server_certificate(
&self,
) -> super::builder::sql_instances_service::AddServerCertificate {
super::builder::sql_instances_service::AddServerCertificate::new(self.inner.clone())
}
pub fn add_entra_id_certificate(
&self,
) -> super::builder::sql_instances_service::AddEntraIdCertificate {
super::builder::sql_instances_service::AddEntraIdCertificate::new(self.inner.clone())
}
#[allow(clippy::should_implement_trait)]
pub fn clone(&self) -> super::builder::sql_instances_service::Clone {
super::builder::sql_instances_service::Clone::new(self.inner.clone())
}
pub fn delete(&self) -> super::builder::sql_instances_service::Delete {
super::builder::sql_instances_service::Delete::new(self.inner.clone())
}
pub fn demote_master(&self) -> super::builder::sql_instances_service::DemoteMaster {
super::builder::sql_instances_service::DemoteMaster::new(self.inner.clone())
}
pub fn demote(&self) -> super::builder::sql_instances_service::Demote {
super::builder::sql_instances_service::Demote::new(self.inner.clone())
}
pub fn export(&self) -> super::builder::sql_instances_service::Export {
super::builder::sql_instances_service::Export::new(self.inner.clone())
}
pub fn failover(&self) -> super::builder::sql_instances_service::Failover {
super::builder::sql_instances_service::Failover::new(self.inner.clone())
}
pub fn reencrypt(&self) -> super::builder::sql_instances_service::Reencrypt {
super::builder::sql_instances_service::Reencrypt::new(self.inner.clone())
}
pub fn get(&self) -> super::builder::sql_instances_service::Get {
super::builder::sql_instances_service::Get::new(self.inner.clone())
}
pub fn import(&self) -> super::builder::sql_instances_service::Import {
super::builder::sql_instances_service::Import::new(self.inner.clone())
}
pub fn insert(&self) -> super::builder::sql_instances_service::Insert {
super::builder::sql_instances_service::Insert::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_instances_service::List {
super::builder::sql_instances_service::List::new(self.inner.clone())
}
pub fn list_server_cas(&self) -> super::builder::sql_instances_service::ListServerCas {
super::builder::sql_instances_service::ListServerCas::new(self.inner.clone())
}
pub fn list_server_certificates(
&self,
) -> super::builder::sql_instances_service::ListServerCertificates {
super::builder::sql_instances_service::ListServerCertificates::new(self.inner.clone())
}
pub fn list_entra_id_certificates(
&self,
) -> super::builder::sql_instances_service::ListEntraIdCertificates {
super::builder::sql_instances_service::ListEntraIdCertificates::new(self.inner.clone())
}
pub fn patch(&self) -> super::builder::sql_instances_service::Patch {
super::builder::sql_instances_service::Patch::new(self.inner.clone())
}
pub fn promote_replica(&self) -> super::builder::sql_instances_service::PromoteReplica {
super::builder::sql_instances_service::PromoteReplica::new(self.inner.clone())
}
pub fn switchover(&self) -> super::builder::sql_instances_service::Switchover {
super::builder::sql_instances_service::Switchover::new(self.inner.clone())
}
pub fn reset_ssl_config(&self) -> super::builder::sql_instances_service::ResetSslConfig {
super::builder::sql_instances_service::ResetSslConfig::new(self.inner.clone())
}
pub fn restart(&self) -> super::builder::sql_instances_service::Restart {
super::builder::sql_instances_service::Restart::new(self.inner.clone())
}
pub fn restore_backup(&self) -> super::builder::sql_instances_service::RestoreBackup {
super::builder::sql_instances_service::RestoreBackup::new(self.inner.clone())
}
pub fn rotate_server_ca(&self) -> super::builder::sql_instances_service::RotateServerCa {
super::builder::sql_instances_service::RotateServerCa::new(self.inner.clone())
}
pub fn rotate_server_certificate(
&self,
) -> super::builder::sql_instances_service::RotateServerCertificate {
super::builder::sql_instances_service::RotateServerCertificate::new(self.inner.clone())
}
pub fn rotate_entra_id_certificate(
&self,
) -> super::builder::sql_instances_service::RotateEntraIdCertificate {
super::builder::sql_instances_service::RotateEntraIdCertificate::new(self.inner.clone())
}
pub fn start_replica(&self) -> super::builder::sql_instances_service::StartReplica {
super::builder::sql_instances_service::StartReplica::new(self.inner.clone())
}
pub fn stop_replica(&self) -> super::builder::sql_instances_service::StopReplica {
super::builder::sql_instances_service::StopReplica::new(self.inner.clone())
}
pub fn truncate_log(&self) -> super::builder::sql_instances_service::TruncateLog {
super::builder::sql_instances_service::TruncateLog::new(self.inner.clone())
}
pub fn update(&self) -> super::builder::sql_instances_service::Update {
super::builder::sql_instances_service::Update::new(self.inner.clone())
}
pub fn create_ephemeral(&self) -> super::builder::sql_instances_service::CreateEphemeral {
super::builder::sql_instances_service::CreateEphemeral::new(self.inner.clone())
}
pub fn reschedule_maintenance(
&self,
) -> super::builder::sql_instances_service::RescheduleMaintenance {
super::builder::sql_instances_service::RescheduleMaintenance::new(self.inner.clone())
}
pub fn verify_external_sync_settings(
&self,
) -> super::builder::sql_instances_service::VerifyExternalSyncSettings {
super::builder::sql_instances_service::VerifyExternalSyncSettings::new(self.inner.clone())
}
pub fn start_external_sync(&self) -> super::builder::sql_instances_service::StartExternalSync {
super::builder::sql_instances_service::StartExternalSync::new(self.inner.clone())
}
pub fn perform_disk_shrink(&self) -> super::builder::sql_instances_service::PerformDiskShrink {
super::builder::sql_instances_service::PerformDiskShrink::new(self.inner.clone())
}
pub fn get_disk_shrink_config(
&self,
) -> super::builder::sql_instances_service::GetDiskShrinkConfig {
super::builder::sql_instances_service::GetDiskShrinkConfig::new(self.inner.clone())
}
pub fn reset_replica_size(&self) -> super::builder::sql_instances_service::ResetReplicaSize {
super::builder::sql_instances_service::ResetReplicaSize::new(self.inner.clone())
}
pub fn get_latest_recovery_time(
&self,
) -> super::builder::sql_instances_service::GetLatestRecoveryTime {
super::builder::sql_instances_service::GetLatestRecoveryTime::new(self.inner.clone())
}
pub fn execute_sql(&self) -> super::builder::sql_instances_service::ExecuteSql {
super::builder::sql_instances_service::ExecuteSql::new(self.inner.clone())
}
pub fn acquire_ssrs_lease(&self) -> super::builder::sql_instances_service::AcquireSsrsLease {
super::builder::sql_instances_service::AcquireSsrsLease::new(self.inner.clone())
}
pub fn release_ssrs_lease(&self) -> super::builder::sql_instances_service::ReleaseSsrsLease {
super::builder::sql_instances_service::ReleaseSsrsLease::new(self.inner.clone())
}
pub fn pre_check_major_version_upgrade(
&self,
) -> super::builder::sql_instances_service::PreCheckMajorVersionUpgrade {
super::builder::sql_instances_service::PreCheckMajorVersionUpgrade::new(self.inner.clone())
}
pub fn point_in_time_restore(
&self,
) -> super::builder::sql_instances_service::PointInTimeRestore {
super::builder::sql_instances_service::PointInTimeRestore::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlOperationsService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlOperationsService>,
}
impl SqlOperationsService {
pub fn builder() -> super::builder::sql_operations_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_operations_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlOperationsService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlOperationsService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlOperationsService> {
super::transport::SqlOperationsService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlOperationsService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlOperationsService::new)
}
pub fn get(&self) -> super::builder::sql_operations_service::Get {
super::builder::sql_operations_service::Get::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_operations_service::List {
super::builder::sql_operations_service::List::new(self.inner.clone())
}
pub fn cancel(&self) -> super::builder::sql_operations_service::Cancel {
super::builder::sql_operations_service::Cancel::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlSslCertsService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlSslCertsService>,
}
impl SqlSslCertsService {
pub fn builder() -> super::builder::sql_ssl_certs_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_ssl_certs_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlSslCertsService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlSslCertsService>>
{
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlSslCertsService> {
super::transport::SqlSslCertsService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlSslCertsService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlSslCertsService::new)
}
pub fn delete(&self) -> super::builder::sql_ssl_certs_service::Delete {
super::builder::sql_ssl_certs_service::Delete::new(self.inner.clone())
}
pub fn get(&self) -> super::builder::sql_ssl_certs_service::Get {
super::builder::sql_ssl_certs_service::Get::new(self.inner.clone())
}
pub fn insert(&self) -> super::builder::sql_ssl_certs_service::Insert {
super::builder::sql_ssl_certs_service::Insert::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_ssl_certs_service::List {
super::builder::sql_ssl_certs_service::List::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlTiersService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlTiersService>,
}
impl SqlTiersService {
pub fn builder() -> super::builder::sql_tiers_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_tiers_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlTiersService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlTiersService>> {
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlTiersService> {
super::transport::SqlTiersService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlTiersService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlTiersService::new)
}
pub fn list(&self) -> super::builder::sql_tiers_service::List {
super::builder::sql_tiers_service::List::new(self.inner.clone())
}
}
#[derive(Clone, Debug)]
pub struct SqlUsersService {
inner: std::sync::Arc<dyn super::stub::dynamic::SqlUsersService>,
}
impl SqlUsersService {
pub fn builder() -> super::builder::sql_users_service::ClientBuilder {
crate::new_client_builder(super::builder::sql_users_service::client::Factory)
}
pub fn from_stub<T>(stub: T) -> Self
where
T: super::stub::SqlUsersService + 'static,
{
Self {
inner: std::sync::Arc::new(stub),
}
}
pub(crate) async fn new(
config: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<Self> {
let inner = Self::build_inner(config).await?;
Ok(Self { inner })
}
async fn build_inner(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<std::sync::Arc<dyn super::stub::dynamic::SqlUsersService>> {
if gaxi::options::tracing_enabled(&conf) {
return Ok(std::sync::Arc::new(Self::build_with_tracing(conf).await?));
}
Ok(std::sync::Arc::new(Self::build_transport(conf).await?))
}
async fn build_transport(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlUsersService> {
super::transport::SqlUsersService::new(conf).await
}
async fn build_with_tracing(
conf: gaxi::options::ClientConfig,
) -> crate::ClientBuilderResult<impl super::stub::SqlUsersService> {
Self::build_transport(conf)
.await
.map(super::tracing::SqlUsersService::new)
}
pub fn delete(&self) -> super::builder::sql_users_service::Delete {
super::builder::sql_users_service::Delete::new(self.inner.clone())
}
pub fn get(&self) -> super::builder::sql_users_service::Get {
super::builder::sql_users_service::Get::new(self.inner.clone())
}
pub fn insert(&self) -> super::builder::sql_users_service::Insert {
super::builder::sql_users_service::Insert::new(self.inner.clone())
}
pub fn list(&self) -> super::builder::sql_users_service::List {
super::builder::sql_users_service::List::new(self.inner.clone())
}
pub fn update(&self) -> super::builder::sql_users_service::Update {
super::builder::sql_users_service::Update::new(self.inner.clone())
}
}