#![cfg(feature = "cloudflare_events")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(
clippy::missing_errors_doc,
clippy::doc_markdown,
clippy::useless_format
)]
#![allow(unused_imports)]
use foundation_macros::JsonHash;
use foundation_netio::shared::client::http_client::HttpClient;
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use serde::{Deserialize, Serialize};
use super::shared::AaaApiResponseSingle;
use super::shared::AaaIdResponse;
use super::shared::AaaSchemasApiResponseCommon;
use super::shared::AaaUuid;
use super::shared::ResourceTaggingAccessApplicationId;
use super::shared::ResourceTaggingApiResponseCommon;
use super::shared::ResourceTaggingEtag;
use super::shared::ResourceTaggingIdentifier;
use super::shared::ResourceTaggingResourceId;
use super::shared::ResourceTaggingResourceName;
use super::shared::ResourceTaggingTaggedResourceObject;
use super::shared::ResourceTaggingTaggedResourceObjectAccessApplication;
use super::shared::ResourceTaggingTaggedResourceObjectAccessApplicationPolicy;
use super::shared::ResourceTaggingTaggedResourceObjectAccessApplicationPolicyBase;
use super::shared::ResourceTaggingTaggedResourceObjectAccessGroup;
use super::shared::ResourceTaggingTaggedResourceObjectAccount;
use super::shared::ResourceTaggingTaggedResourceObjectAccountLevelBase;
use super::shared::ResourceTaggingTaggedResourceObjectAiGateway;
use super::shared::ResourceTaggingTaggedResourceObjectAlertingPolicy;
use super::shared::ResourceTaggingTaggedResourceObjectAlertingWebhook;
use super::shared::ResourceTaggingTaggedResourceObjectApiGatewayOperation;
use super::shared::ResourceTaggingTaggedResourceObjectCloudflaredTunnel;
use super::shared::ResourceTaggingTaggedResourceObjectCustomCertificate;
use super::shared::ResourceTaggingTaggedResourceObjectCustomHostname;
use super::shared::ResourceTaggingTaggedResourceObjectD1Database;
use super::shared::ResourceTaggingTaggedResourceObjectDnsRecord;
use super::shared::ResourceTaggingTaggedResourceObjectDurableObjectNamespace;
use super::shared::ResourceTaggingTaggedResourceObjectGatewayList;
use super::shared::ResourceTaggingTaggedResourceObjectGatewayRule;
use super::shared::ResourceTaggingTaggedResourceObjectImage;
use super::shared::ResourceTaggingTaggedResourceObjectKvNamespace;
use super::shared::ResourceTaggingTaggedResourceObjectManagedClientCertificate;
use super::shared::ResourceTaggingTaggedResourceObjectQueue;
use super::shared::ResourceTaggingTaggedResourceObjectR2Bucket;
use super::shared::ResourceTaggingTaggedResourceObjectResourceShare;
use super::shared::ResourceTaggingTaggedResourceObjectStreamLiveInput;
use super::shared::ResourceTaggingTaggedResourceObjectStreamVideo;
use super::shared::ResourceTaggingTaggedResourceObjectWorker;
use super::shared::ResourceTaggingTaggedResourceObjectWorkerVersion;
use super::shared::ResourceTaggingTaggedResourceObjectWorkerVersionBase;
use super::shared::ResourceTaggingTaggedResourceObjectZone;
use super::shared::ResourceTaggingTaggedResourceObjectZoneLevelBase;
use super::shared::ResourceTaggingTaggedResourceResponseSingle;
use super::shared::ResourceTaggingTags;
use super::shared::ResourceTaggingWorkerId;
use super::shared::ResourceTaggingZoneId;
use super::shared::ApiResponse;
pub type AaaAlertBody = String;
pub type AaaAlertsResponseCollection = super::shared::ApiEnvelope<Option<serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaApiResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result_info: Option<AaaSchemasResultInfo>,
pub success: bool,
}
pub type AaaComponentsSchemasDescription = String;
pub type AaaComponentsSchemasMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type AaaComponentsSchemasName = String;
pub type AaaComponentsSchemasResponseCollection =
super::shared::ApiEnvelope<Option<Vec<AaaPagerduty>>>;
pub type AaaComponentsSchemasType = String;
pub type AaaCreatedAt = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaHistory {
pub alert_body: Option<String>,
pub alert_type: Option<String>,
pub description: Option<String>,
pub id: Option<String>,
pub mechanism: Option<String>,
pub mechanism_type: Option<String>,
pub name: Option<String>,
pub policy_id: Option<String>,
pub sent: Option<String>,
}
pub type AaaHistoryComponentsSchemasResponseCollection =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess2<Option<Vec<AaaHistory>>>;
pub type AaaLastFailure = String;
pub type AaaLastSuccess = String;
pub type AaaMechanism = String;
pub type AaaMechanismType = String;
pub type AaaName = String;
pub type AaaPagerduty = super::shared::IdNameObject;
pub type AaaPolicyId = String;
pub type AaaSchemasAlertType = String;
pub type AaaSchemasName = String;
pub type AaaSchemasResponseCollection = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type AaaSchemasResultInfo = super::shared::FirewallResultInfoShape;
pub type AaaSchemasSingleResponse = super::shared::ApiEnvelope<Option<AaaWebhooks>>;
pub type AaaSecret = String;
pub type AaaSensitiveIdResponse =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
pub type AaaSent = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilence {
pub created_at: Option<String>,
pub end_time: Option<String>,
pub id: Option<String>,
pub policy_id: Option<String>,
pub start_time: Option<String>,
pub updated_at: Option<String>,
}
pub type AaaSilenceComponentsSchemasResponseCollection =
super::shared::ApiEnvelope<Option<AaaSilence>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceCreateRequest {
pub end_time: Option<String>,
pub policy_id: Option<String>,
pub start_time: Option<String>,
}
pub type AaaSilenceId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceUpdateRequest {
pub end_time: Option<String>,
pub id: Option<String>,
pub start_time: Option<String>,
}
pub type AaaSilencesComponentsSchemasResponseCollection =
super::shared::ApiEnvelope<Option<Vec<AaaSilence>>>;
pub type AaaToken = String;
pub type AaaUrl = String;
pub type AaaWebhookId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaWebhooks {
pub created_at: Option<String>,
pub id: Option<String>,
pub last_failure: Option<String>,
pub last_success: Option<String>,
pub name: Option<String>,
pub secret: Option<String>,
#[serde(rename = "type")]
pub r#type: Option<String>,
pub url: Option<String>,
}
pub type AaaWebhooksComponentsSchemasResponseCollection =
super::shared::ApiEnvelope<Option<Vec<AaaWebhooks>>>;
pub type NotificationWebhooksCreateAWebhookRequest = super::shared::NameSecretUrlObject;
pub type NotificationWebhooksUpdateAWebhookRequest = super::shared::NameSecretUrlObject;
pub type ResourceTaggingAccountResourceTypeBaseEnum = String;
pub type ResourceTaggingAccountResourceTypeWorkerVersionEnum = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingCursorResultInfo {
pub count: Option<i64>,
pub cursor: Option<String>,
}
pub type ResourceTaggingDeleteTagsRequestAccountLevel = serde_json::Value;
pub type ResourceTaggingDeleteTagsRequestAccountLevelBase =
super::shared::ResourceIdResourceTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingDeleteTagsRequestAccountLevelWorkerVersion {
pub resource_id: String,
pub resource_type: String,
pub worker_id: String,
}
pub type ResourceTaggingMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type ResourceTaggingSetTagsRequestAccountLevel = serde_json::Value;
pub type ResourceTaggingSetTagsRequestAccountLevelBase =
super::shared::ResourceIdResourceTypeTagsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingSetTagsRequestAccountLevelWorkerVersion {
pub resource_id: String,
pub resource_type: String,
pub tags: Option<serde_json::Value>,
pub worker_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingTagKeysResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<String>>,
pub result_info: Option<ResourceTaggingCursorResultInfo>,
pub success: bool,
}
pub type ResourceTaggingTagValuesResponseCollection = ResourceTaggingTagKeysResponseCollection;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingTaggedResourceResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<serde_json::Value>>,
pub result_info: Option<ResourceTaggingCursorResultInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceResponse {
pub errors: Vec<WorSendEventWorkflowInstanceResponseErrorsItem>,
pub messages: Vec<WorSendEventWorkflowInstanceResponseMessagesItem>,
pub result: Option<serde_json::Value>,
pub result_info: Option<WorSendEventWorkflowInstanceResponseResultInfo>,
pub success: bool,
}
pub type WorSendEventWorkflowInstanceResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorSendEventWorkflowInstanceResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorSendEventWorkflowInstanceResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
pub type NotificationAlertTypesGetAlertTypesArgs = super::shared::AccountIdArgs;
pub type NotificationMechanismEligibilityGetDeliveryMechanismEligibilityArgs =
super::shared::AccountIdArgs;
pub type NotificationDestinationsWithPagerDutyListPagerDutyServicesArgs =
super::shared::AccountIdArgs;
pub type NotificationDestinationsWithPagerDutyDeletePagerDutyServicesArgs =
super::shared::AccountIdArgs;
pub type NotificationDestinationsWithPagerDutyConnectPagerDutyArgs = super::shared::AccountIdArgs;
pub type NotificationWebhooksListWebhooksArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksCreateAWebhookArgs {
pub account_id: String,
pub body: NotificationWebhooksCreateAWebhookRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksGetAWebhookArgs {
pub account_id: String,
pub webhook_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksUpdateAWebhookArgs {
pub webhook_id: String,
pub account_id: String,
pub body: NotificationWebhooksUpdateAWebhookRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksDeleteAWebhookArgs {
pub webhook_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationHistoryListHistoryArgs {
pub account_id: String,
pub per_page: Option<String>,
pub before: Option<String>,
pub page: Option<String>,
pub since: Option<String>,
}
pub type NotificationSilencesListSilencesArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesCreateSilencesArgs {
pub account_id: String,
pub body: Vec<AaaSilenceCreateRequest>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesUpdateSilencesArgs {
pub account_id: String,
pub body: Vec<AaaSilenceUpdateRequest>,
}
pub type NotificationSilencesGetSilenceArgs = super::shared::AccountIdSilenceIdArgs;
pub type NotificationSilencesDeleteSilencesArgs = super::shared::AccountIdSilenceIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsGetArgs {
pub account_id: String,
pub resource_id: Option<String>,
pub resource_type: Option<String>,
pub worker_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsSetArgs {
pub account_id: String,
pub body: ResourceTaggingSetTagsRequestAccountLevel,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsDeleteArgs {
pub account_id: String,
pub body: ResourceTaggingDeleteTagsRequestAccountLevel,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListKeysArgs {
pub account_id: String,
pub cursor: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListArgs {
pub account_id: String,
pub r#type: Vec<String>,
pub tag: Vec<String>,
pub cursor: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListValuesArgs {
pub account_id: String,
pub tag_key: String,
pub r#type: Option<String>,
pub cursor: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceArgs {
pub workflow_name: String,
pub instance_id: String,
pub event_type: String,
pub account_id: String,
}
pub async fn notification_alert_types_get_alert_types_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationAlertTypesGetAlertTypesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaAlertsResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/alerting/v3/available_alerts", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_mechanism_eligibility_get_delivery_mechanism_eligibility_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationMechanismEligibilityGetDeliveryMechanismEligibilityArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/eligible",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_destinations_with_pager_duty_list_pager_duty_services_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationDestinationsWithPagerDutyListPagerDutyServicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/pagerduty",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_destinations_with_pager_duty_delete_pager_duty_services_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationDestinationsWithPagerDutyDeletePagerDutyServicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/pagerduty",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_destinations_with_pager_duty_connect_pager_duty_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationDestinationsWithPagerDutyConnectPagerDutyArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSensitiveIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/pagerduty/connect",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_webhooks_list_webhooks_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationWebhooksListWebhooksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaWebhooksComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/webhooks",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_webhooks_create_a_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationWebhooksCreateAWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/webhooks",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_webhooks_get_a_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationWebhooksGetAWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/webhooks/{}",
args.account_id, args.webhook_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_webhooks_update_a_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationWebhooksUpdateAWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/webhooks/{}",
args.account_id, args.webhook_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_webhooks_delete_a_webhook_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationWebhooksDeleteAWebhookArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/destinations/webhooks/{}",
args.account_id, args.webhook_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_history_list_history_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationHistoryListHistoryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaHistoryComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/alerting/v3/history", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("before", args.before.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("since", args.since.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_silences_list_silences_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationSilencesListSilencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSilencesComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/alerting/v3/silences", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_silences_create_silences_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationSilencesCreateSilencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/alerting/v3/silences", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_silences_update_silences_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationSilencesUpdateSilencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSilencesComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/alerting/v3/silences", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_silences_get_silence_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationSilencesGetSilenceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSilenceComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/silences/{}",
args.account_id, args.silence_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn notification_silences_delete_silences_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NotificationSilencesDeleteSilencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaSchemasApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/alerting/v3/silences/{}",
args.account_id, args.silence_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tags_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ResourceTaggingTaggedResourceResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("resource_id", args.resource_id.as_deref());
builder = builder.query("resource_type", args.resource_type.as_deref());
builder = builder.query("worker_id", args.worker_id.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tags_set_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsSetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ResourceTaggingTaggedResourceResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tags_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn tags_list_keys_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsListKeysArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ResourceTaggingTagKeysResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags/keys", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("cursor", args.cursor.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tags_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ResourceTaggingTaggedResourceResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags/resources", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
for value in &args.r#type {
builder = builder.query("type", Some(value.as_str()));
}
for value in &args.tag {
builder = builder.query("tag", Some(value.as_str()));
}
builder = builder.query("cursor", args.cursor.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tags_list_values_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TagsListValuesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ResourceTaggingTagValuesResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tags/values/{}", args.account_id, args.tag_key,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("type", args.r#type.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn wor_send_event_workflow_instance_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorSendEventWorkflowInstanceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorSendEventWorkflowInstanceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/{}/events/{}",
args.account_id, args.workflow_name, args.instance_id, args.event_type,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}