use crate::Result;
#[derive(Clone, Debug)]
pub struct SecurityCenterManagement<T>
where
T: super::stub::SecurityCenterManagement + std::fmt::Debug + Send + Sync,
{
inner: T,
duration: gaxi::observability::DurationMetric,
}
impl<T> SecurityCenterManagement<T>
where
T: super::stub::SecurityCenterManagement + std::fmt::Debug + Send + Sync,
{
pub fn new(inner: T) -> Self {
Self {
inner,
duration: gaxi::observability::DurationMetric::new(&info::INSTRUMENTATION_CLIENT_INFO),
}
}
}
impl<T> super::stub::SecurityCenterManagement for SecurityCenterManagement<T>
where
T: super::stub::SecurityCenterManagement + std::fmt::Debug + Send + Sync,
{
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_effective_security_health_analytics_custom_modules(
&self,
req: crate::model::ListEffectiveSecurityHealthAnalyticsCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<
crate::Response<crate::model::ListEffectiveSecurityHealthAnalyticsCustomModulesResponse>,
> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_effective_security_health_analytics_custom_modules",
self.inner.list_effective_security_health_analytics_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_effective_security_health_analytics_custom_module(
&self,
req: crate::model::GetEffectiveSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::EffectiveSecurityHealthAnalyticsCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_effective_security_health_analytics_custom_module",
self.inner.get_effective_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_security_health_analytics_custom_modules(
&self,
req: crate::model::ListSecurityHealthAnalyticsCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListSecurityHealthAnalyticsCustomModulesResponse>>
{
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_security_health_analytics_custom_modules",
self.inner.list_security_health_analytics_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_descendant_security_health_analytics_custom_modules(
&self,
req: crate::model::ListDescendantSecurityHealthAnalyticsCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<
crate::Response<crate::model::ListDescendantSecurityHealthAnalyticsCustomModulesResponse>,
> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_descendant_security_health_analytics_custom_modules",
self.inner.list_descendant_security_health_analytics_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_security_health_analytics_custom_module(
&self,
req: crate::model::GetSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SecurityHealthAnalyticsCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_security_health_analytics_custom_module",
self.inner.get_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_security_health_analytics_custom_module(
&self,
req: crate::model::CreateSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SecurityHealthAnalyticsCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::create_security_health_analytics_custom_module",
self.inner.create_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_security_health_analytics_custom_module(
&self,
req: crate::model::UpdateSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SecurityHealthAnalyticsCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::update_security_health_analytics_custom_module",
self.inner.update_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_security_health_analytics_custom_module(
&self,
req: crate::model::DeleteSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::delete_security_health_analytics_custom_module",
self.inner.delete_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn simulate_security_health_analytics_custom_module(
&self,
req: crate::model::SimulateSecurityHealthAnalyticsCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SimulateSecurityHealthAnalyticsCustomModuleResponse>>
{
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::simulate_security_health_analytics_custom_module",
self.inner.simulate_security_health_analytics_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_effective_event_threat_detection_custom_modules(
&self,
req: crate::model::ListEffectiveEventThreatDetectionCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListEffectiveEventThreatDetectionCustomModulesResponse>>
{
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_effective_event_threat_detection_custom_modules",
self.inner.list_effective_event_threat_detection_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_effective_event_threat_detection_custom_module(
&self,
req: crate::model::GetEffectiveEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::EffectiveEventThreatDetectionCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_effective_event_threat_detection_custom_module",
self.inner.get_effective_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_event_threat_detection_custom_modules(
&self,
req: crate::model::ListEventThreatDetectionCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListEventThreatDetectionCustomModulesResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_event_threat_detection_custom_modules",
self.inner.list_event_threat_detection_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_descendant_event_threat_detection_custom_modules(
&self,
req: crate::model::ListDescendantEventThreatDetectionCustomModulesRequest,
options: crate::RequestOptions,
) -> Result<
crate::Response<crate::model::ListDescendantEventThreatDetectionCustomModulesResponse>,
> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_descendant_event_threat_detection_custom_modules",
self.inner.list_descendant_event_threat_detection_custom_modules(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_event_threat_detection_custom_module(
&self,
req: crate::model::GetEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::EventThreatDetectionCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_event_threat_detection_custom_module",
self.inner.get_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn create_event_threat_detection_custom_module(
&self,
req: crate::model::CreateEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::EventThreatDetectionCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::create_event_threat_detection_custom_module",
self.inner.create_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_event_threat_detection_custom_module(
&self,
req: crate::model::UpdateEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::EventThreatDetectionCustomModule>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::update_event_threat_detection_custom_module",
self.inner.update_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn delete_event_threat_detection_custom_module(
&self,
req: crate::model::DeleteEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<()>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::delete_event_threat_detection_custom_module",
self.inner.delete_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn validate_event_threat_detection_custom_module(
&self,
req: crate::model::ValidateEventThreatDetectionCustomModuleRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ValidateEventThreatDetectionCustomModuleResponse>>
{
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::validate_event_threat_detection_custom_module",
self.inner.validate_event_threat_detection_custom_module(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_security_center_service(
&self,
req: crate::model::GetSecurityCenterServiceRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SecurityCenterService>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_security_center_service",
self.inner.get_security_center_service(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_security_center_services(
&self,
req: crate::model::ListSecurityCenterServicesRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::ListSecurityCenterServicesResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_security_center_services",
self.inner.list_security_center_services(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn update_security_center_service(
&self,
req: crate::model::UpdateSecurityCenterServiceRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<crate::model::SecurityCenterService>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::update_security_center_service",
self.inner.update_security_center_service(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn list_locations(
&self,
req: google_cloud_location::model::ListLocationsRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_location::model::ListLocationsResponse>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::list_locations",
self.inner.list_locations(req, options));
pending.await
}
#[tracing::instrument(level = tracing::Level::DEBUG, ret)]
async fn get_location(
&self,
req: google_cloud_location::model::GetLocationRequest,
options: crate::RequestOptions,
) -> Result<crate::Response<google_cloud_location::model::Location>> {
let (_span, pending) = gaxi::client_request_signals!(
metric: self.duration.clone(),
info: *info::INSTRUMENTATION_CLIENT_INFO,
method: "client::SecurityCenterManagement::get_location",
self.inner.get_location(req, options));
pending.await
}
}
pub(crate) mod info {
const NAME: &str = env!("CARGO_PKG_NAME");
const VERSION: &str = env!("CARGO_PKG_VERSION");
pub(crate) static INSTRUMENTATION_CLIENT_INFO: std::sync::LazyLock<
gaxi::options::InstrumentationClientInfo,
> = std::sync::LazyLock::new(|| {
let mut info = gaxi::options::InstrumentationClientInfo::default();
info.service_name = "securitycentermanagement";
info.client_version = VERSION;
info.client_artifact = NAME;
info.default_host = "securitycentermanagement";
info
});
}