foundation_deployment_cloudflare 0.1.1

//! Auto-generated API module for cloudflare events.
//!
//! Generated by `cargo run --bin ewe_platform gen_api`.
//! DO NOT EDIT MANUALLY.
//!
//! Feature flag: `cloudflare_events `

#![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_netio::{DynNetClient, PreparedRequestBuilder};
use foundation_netio::shared::client::http_client::HttpClient;
use serde::{Deserialize, Serialize};
use foundation_macros::JsonHash;

// Import shared types used by this module
use super::shared::AaaIdResponse;
use super::shared::ResourceTaggingTaggedResourceResponseSingle;
use super::shared::AaaApiResponseSingle;
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::ResourceTaggingTags;
use super::shared::ResourceTaggingWorkerId;
use super::shared::ResourceTaggingZoneId;

use super::shared::ApiResponse;

// =============================================================================
// TYPE DECLARATIONS
// =============================================================================

/// `AaaAlertBody` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAlertBody {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaAlertsResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAlertsResponseCollection {
    /// `result` property.
    pub result: Option<serde_json::Value>,
}

/// `AaaApiResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaApiResponseCollection {
    /// `result_info` property.
    pub result_info: Option<AaaSchemasResultInfo>,
}

/// `AaaComponentsSchemasDescription` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaComponentsSchemasDescription {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaComponentsSchemasMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaComponentsSchemasMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaComponentsSchemasName` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaComponentsSchemasName {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaComponentsSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaComponentsSchemasResponseCollection {
    /// `result` property.
    pub result: Option<Vec<AaaPagerduty>>,
}

/// `AaaComponentsSchemasType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaComponentsSchemasType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaCreatedAt` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaCreatedAt {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaHistory` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaHistory {
    /// alert_body property.
    pub alert_body: Option<AaaAlertBody>,
    /// alert_type property.
    pub alert_type: Option<AaaSchemasAlertType>,
    /// description property.
    pub description: Option<AaaComponentsSchemasDescription>,
    /// id property.
    pub id: Option<AaaUuid>,
    /// mechanism property.
    pub mechanism: Option<AaaMechanism>,
    /// mechanism_type property.
    pub mechanism_type: Option<AaaMechanismType>,
    /// name property.
    pub name: Option<AaaSchemasName>,
    /// policy_id property.
    pub policy_id: Option<AaaPolicyId>,
    /// sent property.
    pub sent: Option<AaaSent>,
}

/// `AaaHistoryComponentsSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaHistoryComponentsSchemasResponseCollection {
    /// `result` property.
    pub result: Option<Vec<AaaHistory>>,
    /// `result_info` property.
    pub result_info: Option<serde_json::Value>,
}

/// `AaaLastFailure` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaLastFailure {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaLastSuccess` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaLastSuccess {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaMechanism` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaMechanism {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaMechanismType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaMechanismType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaName` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaName {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaPagerduty` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaPagerduty {
    /// id property.
    pub id: Option<AaaUuid>,
    /// name property.
    pub name: Option<AaaName>,
}

/// `AaaPolicyId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaPolicyId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSchemasAlertType` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasAlertType {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSchemasName` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasName {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasResponseCollection {
    /// `result` property.
    pub result: Option<serde_json::Value>,
}

/// `AaaSchemasResultInfo` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasResultInfo {
    /// count property.
    pub count: Option<f64>,
    /// page property.
    pub page: Option<f64>,
    /// per_page property.
    pub per_page: Option<f64>,
    /// total_count property.
    pub total_count: Option<f64>,
}

/// `AaaSchemasSingleResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSchemasSingleResponse {
    /// `result` property.
    pub result: Option<AaaWebhooks>,
}

/// `AaaSecret` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSecret {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSensitiveIdResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSensitiveIdResponse {
    /// `result` property.
    pub result: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `AaaSent` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSent {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSilence` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilence {
    /// created_at property.
    pub created_at: Option<String>,
    /// end_time property.
    pub end_time: Option<String>,
    /// id property.
    pub id: Option<AaaSilenceId>,
    /// policy_id property.
    pub policy_id: Option<AaaPolicyId>,
    /// start_time property.
    pub start_time: Option<String>,
    /// updated_at property.
    pub updated_at: Option<String>,
}

/// `AaaSilenceComponentsSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceComponentsSchemasResponseCollection {
    /// `result` property.
    pub result: Option<AaaSilence>,
}

/// `AaaSilenceCreateRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceCreateRequest {
    /// end_time property.
    pub end_time: Option<String>,
    /// policy_id property.
    pub policy_id: Option<AaaPolicyId>,
    /// start_time property.
    pub start_time: Option<String>,
}

/// `AaaSilenceId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaSilenceUpdateRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilenceUpdateRequest {
    /// end_time property.
    pub end_time: Option<String>,
    /// id property.
    pub id: Option<AaaSilenceId>,
    /// start_time property.
    pub start_time: Option<String>,
}

/// `AaaSilencesComponentsSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaSilencesComponentsSchemasResponseCollection {
    /// `result` property.
    pub result: Option<Vec<AaaSilence>>,
}

/// `AaaToken` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaToken {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaUrl` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaUrl {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaWebhookId` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaWebhookId {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `AaaWebhooks` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaWebhooks {
    /// created_at property.
    pub created_at: Option<AaaCreatedAt>,
    /// id property.
    pub id: Option<AaaWebhookId>,
    /// last_failure property.
    pub last_failure: Option<AaaLastFailure>,
    /// last_success property.
    pub last_success: Option<AaaLastSuccess>,
    /// name property.
    pub name: Option<AaaComponentsSchemasName>,
    /// secret property.
    pub secret: Option<AaaSecret>,
    /// type property.
    #[serde(rename = "type")]
    pub r#type: Option<AaaComponentsSchemasType>,
    /// url property.
    pub url: Option<AaaUrl>,
}

/// `AaaWebhooksComponentsSchemasResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaWebhooksComponentsSchemasResponseCollection {
    /// `result` property.
    pub result: Option<Vec<AaaWebhooks>>,
}

/// `NotificationWebhooksCreateAWebhookRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NotificationWebhooksCreateAWebhookRequest {
    /// name property.
    pub name: AaaComponentsSchemasName,
    /// secret property.
    pub secret: Option<AaaSecret>,
    /// url property.
    pub url: AaaUrl,
}

/// `NotificationWebhooksUpdateAWebhookRequest` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NotificationWebhooksUpdateAWebhookRequest {
    /// name property.
    pub name: AaaComponentsSchemasName,
    /// secret property.
    pub secret: Option<AaaSecret>,
    /// url property.
    pub url: AaaUrl,
}

/// `ResourceTaggingAccountResourceTypeBaseEnum` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingAccountResourceTypeBaseEnum {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `ResourceTaggingAccountResourceTypeWorkerVersionEnum` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingAccountResourceTypeWorkerVersionEnum {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `ResourceTaggingCursorResultInfo` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingCursorResultInfo {
    /// count property.
    pub count: Option<i64>,
    /// cursor property.
    pub cursor: Option<String>,
}

/// `ResourceTaggingDeleteTagsRequestAccountLevel` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingDeleteTagsRequestAccountLevel {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `ResourceTaggingDeleteTagsRequestAccountLevelBase` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingDeleteTagsRequestAccountLevelBase {
    /// resource_id property.
    pub resource_id: ResourceTaggingResourceId,
    /// resource_type property.
    pub resource_type: ResourceTaggingAccountResourceTypeBaseEnum,
}

/// `ResourceTaggingDeleteTagsRequestAccountLevelWorkerVersion` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingDeleteTagsRequestAccountLevelWorkerVersion {
    /// `resource_type` property.
    pub resource_type: Option<ResourceTaggingAccountResourceTypeWorkerVersionEnum>,
    /// `worker_id` property.
    pub worker_id: ResourceTaggingWorkerId,
}

/// `ResourceTaggingMessages` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingMessages {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `ResourceTaggingSetTagsRequestAccountLevel` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingSetTagsRequestAccountLevel {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `ResourceTaggingSetTagsRequestAccountLevelBase` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingSetTagsRequestAccountLevelBase {
    /// `tags` property.
    pub tags: Option<ResourceTaggingTags>,
}

/// `ResourceTaggingSetTagsRequestAccountLevelWorkerVersion` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingSetTagsRequestAccountLevelWorkerVersion {
    /// `tags` property.
    pub tags: Option<ResourceTaggingTags>,
}

/// `ResourceTaggingTagKeysResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingTagKeysResponseCollection {
    /// `result` property.
    pub result: Option<Vec<String>>,
    /// `result_info` property.
    pub result_info: Option<ResourceTaggingCursorResultInfo>,
}

/// `ResourceTaggingTagValuesResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingTagValuesResponseCollection {
    /// `result` property.
    pub result: Option<Vec<String>>,
    /// `result_info` property.
    pub result_info: Option<ResourceTaggingCursorResultInfo>,
}

/// `ResourceTaggingTaggedResourceResponseCollection` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceTaggingTaggedResourceResponseCollection {
    /// `result` property.
    pub result: Option<Vec<ResourceTaggingTaggedResourceObject>>,
    /// `result_info` property.
    pub result_info: Option<ResourceTaggingCursorResultInfo>,
}

/// `WorSendEventWorkflowInstanceResponse` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceResponse {
    /// errors property.
    pub errors: Vec<WorSendEventWorkflowInstanceResponseErrorsItem>,
    /// messages property.
    pub messages: Vec<WorSendEventWorkflowInstanceResponseMessagesItem>,
    /// result property.
    pub result: Option<serde_json::Value>,
    /// result_info property.
    pub result_info: Option<WorSendEventWorkflowInstanceResponseResultInfo>,
    /// success property.
    pub success: bool,
}

/// `WorSendEventWorkflowInstanceResponseErrorsItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceResponseErrorsItem {
    /// code property.
    pub code: f64,
    /// message property.
    pub message: String,
}

/// `WorSendEventWorkflowInstanceResponseMessagesItem` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceResponseMessagesItem {
    /// code property.
    pub code: f64,
    /// message property.
    pub message: String,
}

/// `WorSendEventWorkflowInstanceResponseResultInfo` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceResponseResultInfo {
    /// count property.
    pub count: f64,
    /// cursor property.
    pub cursor: Option<String>,
    /// page property.
    pub page: Option<f64>,
    /// per_page property.
    pub per_page: f64,
    /// total_count property.
    pub total_count: f64,
}

// =============================================================================
// ARGS TYPES (per-endpoint)
// =============================================================================

/// Arguments for [`notification-alert-types-get-alert-types_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationAlertTypesGetAlertTypesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-mechanism-eligibility-get-delivery-mechanism-eligibility_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationMechanismEligibilityGetDeliveryMechanismEligibilityArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-destinations-with-pager-duty-list-pager-duty-services_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationDestinationsWithPagerDutyListPagerDutyServicesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-destinations-with-pager-duty-delete-pager-duty-services_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationDestinationsWithPagerDutyDeletePagerDutyServicesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-destinations-with-pager-duty-connect-pager-duty_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationDestinationsWithPagerDutyConnectPagerDutyArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-webhooks-list-webhooks_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksListWebhooksArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-webhooks-create-a-webhook_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksCreateAWebhookArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: NotificationWebhooksCreateAWebhookRequest,
}

/// Arguments for [`notification-webhooks-get-a-webhook_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksGetAWebhookArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `webhook_id`.
    pub webhook_id: String,
}

/// Arguments for [`notification-webhooks-update-a-webhook_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksUpdateAWebhookArgs {
    /// Path parameter: `webhook_id`.
    pub webhook_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: NotificationWebhooksUpdateAWebhookRequest,
}

/// Arguments for [`notification-webhooks-delete-a-webhook_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationWebhooksDeleteAWebhookArgs {
    /// Path parameter: `webhook_id`.
    pub webhook_id: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-history-list-history_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationHistoryListHistoryArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `per_page`.
    pub per_page: Option<String>,
    /// Query parameter: `before`.
    pub before: Option<String>,
    /// Query parameter: `page`.
    pub page: Option<String>,
    /// Query parameter: `since`.
    pub since: Option<String>,
}

/// Arguments for [`notification-silences-list-silences_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesListSilencesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
}

/// Arguments for [`notification-silences-create-silences_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesCreateSilencesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: Vec<AaaSilenceCreateRequest>,
}

/// Arguments for [`notification-silences-update-silences_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesUpdateSilencesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: Vec<AaaSilenceUpdateRequest>,
}

/// Arguments for [`notification-silences-get-silence_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesGetSilenceArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `silence_id`.
    pub silence_id: String,
}

/// Arguments for [`notification-silences-delete-silences_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NotificationSilencesDeleteSilencesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `silence_id`.
    pub silence_id: String,
}

/// Arguments for [`tags-get_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsGetArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `resource_id`.
    pub resource_id: Option<String>,
    /// Query parameter: `resource_type`.
    pub resource_type: Option<String>,
    /// Query parameter: `worker_id`.
    pub worker_id: Option<String>,
}

/// Arguments for [`tags-set_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsSetArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: ResourceTaggingSetTagsRequestAccountLevel,
}

/// Arguments for [`tags-delete_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsDeleteArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Request body.
    pub body: ResourceTaggingDeleteTagsRequestAccountLevel,
}

/// Arguments for [`tags-list-keys_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListKeysArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `cursor`.
    pub cursor: Option<String>,
}

/// Arguments for [`tags-list_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Query parameter: `type`.
    pub r#type: Option<String>,
    /// Query parameter: `tag`.
    pub tag: Option<String>,
    /// Query parameter: `cursor`.
    pub cursor: Option<String>,
}

/// Arguments for [`tags-list-values_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TagsListValuesArgs {
    /// Path parameter: `account_id`.
    pub account_id: String,
    /// Path parameter: `tag_key`.
    pub tag_key: String,
    /// Query parameter: `type`.
    pub r#type: Option<String>,
    /// Query parameter: `cursor`.
    pub cursor: Option<String>,
}

/// Arguments for [`wor-send-event-workflow-instance_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorSendEventWorkflowInstanceArgs {
    /// Path parameter: `workflow_name`.
    pub workflow_name: String,
    /// Path parameter: `instance_id`.
    pub instance_id: String,
    /// Path parameter: `event_type`.
    pub event_type: String,
    /// Path parameter: `account_id`.
    pub account_id: String,
}

// =============================================================================
// CLIENT FUNCTIONS (per-endpoint)
// =============================================================================

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/available_alerts
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/available_alerts.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_alert_types_get_alert_types_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_alert_types_get_alert_types_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaAlertsResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/destinations/eligible
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/destinations/eligible.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_mechanism_eligibility_get_delivery_mechanism_eligibility_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_mechanism_eligibility_get_delivery_mechanism_eligibility_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/destinations/pagerduty
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/destinations/pagerduty.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_destinations_with_pager_duty_list_pager_duty_services_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_destinations_with_pager_duty_list_pager_duty_services_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/alerting/v3/destinations/pagerduty
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/alerting/v3/destinations/pagerduty.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_destinations_with_pager_duty_delete_pager_duty_services_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_destinations_with_pager_duty_delete_pager_duty_services_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasApiResponseCommon = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/alerting/v3/destinations/pagerduty/connect
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/alerting/v3/destinations/pagerduty/connect.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_destinations_with_pager_duty_connect_pager_duty_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_destinations_with_pager_duty_connect_pager_duty_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSensitiveIdResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/destinations/webhooks
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/destinations/webhooks.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_webhooks_list_webhooks_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_webhooks_list_webhooks_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaWebhooksComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/alerting/v3/destinations/webhooks
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/alerting/v3/destinations/webhooks.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_webhooks_create_a_webhook_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_webhooks_create_a_webhook_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaIdResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_webhooks_get_a_webhook_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_webhooks_get_a_webhook_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasSingleResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_webhooks_update_a_webhook_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_webhooks_update_a_webhook_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaIdResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/alerting/v3/destinations/webhooks/{webhook_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_webhooks_delete_a_webhook_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_webhooks_delete_a_webhook_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasApiResponseCommon = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/history
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/history.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_history_list_history_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_history_list_history_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaHistoryComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/silences
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/silences.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_silences_list_silences_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_silences_list_silences_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSilencesComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/alerting/v3/silences
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/alerting/v3/silences.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_silences_create_silences_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_silences_create_silences_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasApiResponseCommon = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/alerting/v3/silences
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/alerting/v3/silences.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_silences_update_silences_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_silences_update_silences_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSilencesComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/alerting/v3/silences/{silence_id}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/alerting/v3/silences/{silence_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_silences_get_silence_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_silences_get_silence_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSilenceComponentsSchemasResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/alerting/v3/silences/{silence_id}
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/alerting/v3/silences/{silence_id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = notification_silences_delete_silences_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn notification_silences_delete_silences_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: AaaSchemasApiResponseCommon = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/tags
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/tags.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_get_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_get_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: ResourceTaggingTaggedResourceResponseSingle = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// PUT /accounts/{account_id}/tags
// -----------------------------------------------------------------------------

/// PUT /accounts/{account_id}/tags.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_set_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_set_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: ResourceTaggingTaggedResourceResponseSingle = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// DELETE /accounts/{account_id}/tags
// -----------------------------------------------------------------------------

/// DELETE /accounts/{account_id}/tags.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_delete_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_delete_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    Ok(ApiResponse { status: status as u16, headers, body: () })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/tags/keys
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/tags/keys.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_list_keys_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_list_keys_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: ResourceTaggingTagKeysResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/tags/resources
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/tags/resources.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_list_request<F>(
    client: DynNetClient,
    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()))?;

    builder = builder.query("type", args.r#type.as_deref());
    builder = builder.query("tag", args.tag.as_deref());
    builder = builder.query("cursor", args.cursor.as_deref());

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: ResourceTaggingTaggedResourceResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /accounts/{account_id}/tags/values/{tag_key}
// -----------------------------------------------------------------------------

/// GET /accounts/{account_id}/tags/values/{tag_key}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = tags_list_values_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn tags_list_values_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: ResourceTaggingTagValuesResponseCollection = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// POST /accounts/{account_id}/workflows/{workflow_name}/instances/{instance_id}/events/{event_type}
// -----------------------------------------------------------------------------

/// POST /accounts/{account_id}/workflows/{workflow_name}/instances/{instance_id}/events/{event_type}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = wor_send_event_workflow_instance_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn wor_send_event_workflow_instance_request<F>(
    client: DynNetClient,
    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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        let error_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
        let body = (!error_bytes.is_empty())
            .then(|| String::from_utf8_lossy(&error_bytes).into_owned());
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: WorSendEventWorkflowInstanceResponse = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}