#![cfg(feature = "cloudflare_logs")]
#![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::AaaAuditLogsResponseCollection;
use super::shared::AaaResultInfo;
use super::shared::LogpushApiResponseCommon;
use super::shared::LogpushApiResponseSingle;
use super::shared::LogpushDataset;
use super::shared::LogpushDestinationConf;
use super::shared::LogpushDestinationExistsResponse;
use super::shared::LogpushEnabled;
use super::shared::LogpushErrorMessage;
use super::shared::LogpushFrequency;
use super::shared::LogpushGetOwnershipResponse;
use super::shared::LogpushId;
use super::shared::LogpushKind;
use super::shared::LogpushLastComplete;
use super::shared::LogpushLastError;
use super::shared::LogpushLogpullOptions;
use super::shared::LogpushLogpushFieldResponseCollection;
use super::shared::LogpushLogpushJob;
use super::shared::LogpushLogpushJobResponseCollection;
use super::shared::LogpushLogpushJobResponseSingle;
use super::shared::LogpushMaxUploadBytes;
use super::shared::LogpushMaxUploadIntervalSeconds;
use super::shared::LogpushMaxUploadRecords;
use super::shared::LogpushName;
use super::shared::LogpushOutputOptions;
use super::shared::LogpushValidateOwnershipResponse;
use super::shared::LogpushValidateResponse;
use super::shared::ApiResponse;
pub type AaaAuditLogAction = super::shared::ApiEnvelopeDescriptionTimeType<Option<String>>;
pub type AaaAuditLogRaw = super::shared::AaaAuditLogRawShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogsV2 {
pub account: Option<std::collections::HashMap<String, serde_json::Value>>,
pub action: Option<AaaAuditLogAction>,
pub actor: Option<serde_json::Value>,
pub id: Option<String>,
#[serde(rename = "raw")]
pub r#raw: Option<AaaAuditLogRaw>,
pub resource: Option<std::collections::HashMap<String, serde_json::Value>>,
pub zone: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AaaAuditLogsV2ResponseCollection {
pub errors: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub result: Option<Vec<AaaAuditLogsV2>>,
pub result_info: Option<AaaResultInfo>,
pub success: Option<bool>,
}
pub type AaaSchemasIdentifier = String;
pub type AaaSchemasMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type DeleteAccountsAccountIdLogpushJobsJobIdResponse =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
pub type DeleteAccountsAccountIdLogpushValidateDestinationExistsRequest =
super::shared::DestinationConfObject;
pub type DeleteAccountsAccountIdLogpushValidateDestinationRequest =
super::shared::DestinationConfObject;
pub type DeleteAccountsAccountIdLogsControlCmbConfigResponse =
super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type DlpApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type DlpApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type DlpMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type DlpPayloadLogGetResponse = super::shared::ApiEnvelope<Option<DlpPayloadLogSetting>>;
pub type DlpPayloadLogPutResponse = super::shared::ApiEnvelope<Option<DlpPayloadLogSetting>>;
pub type DlpPayloadLogSetting = super::shared::MaskingLevelPublicKeyUpdatedAtObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DlpPayloadLogSettingUpdateLegacy {
pub masking_level: Option<serde_json::Value>,
pub public_key: Option<String>,
}
pub type LogcontrolAllowOutOfRegionAccess = bool;
pub type LogcontrolApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type LogcontrolApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LogcontrolCmbConfig {
pub allow_out_of_region_access: Option<bool>,
pub regions: Option<String>,
}
pub type LogcontrolCmbConfigResponseSingle =
super::shared::ApiEnvelope<Option<LogcontrolCmbConfig>>;
pub type LogcontrolMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type LogcontrolRegions = String;
pub type LogpushFilter = String;
pub type LogpushMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type LogpushOwnershipChallenge = String;
pub type McnAccountId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSync {
pub description: String,
pub destination_id: String,
pub destination_type: String,
pub errors: Option<serde_json::Value>,
pub id: String,
pub includes_discoveries_until: Option<String>,
pub last_attempted_update_at: Option<String>,
pub last_successful_update_at: Option<String>,
pub last_user_update_at: String,
pub name: String,
pub policy: String,
pub update_mode: String,
}
pub type McnCatalogSyncDestinationId = String;
pub type McnCatalogSyncDestinationType = String;
pub type McnCatalogSyncId = String;
pub type McnCatalogSyncUpdateMode = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncsPrebuiltPoliciesResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: Vec<McnCatalogSyncsPrebuiltPolicy>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCatalogSyncsPrebuiltPolicy {
pub applicable_destinations: Vec<String>,
pub policy_description: String,
pub policy_name: String,
pub policy_string: String,
}
pub type McnCloudPlatformClient = super::shared::ClientTypeIdNameObject;
pub type McnCloudType = String;
pub type McnCost = super::shared::CurrencyMonthlyCostObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCreateCatalogSyncRequest {
pub description: Option<String>,
pub destination_type: String,
pub name: String,
pub policy: Option<String>,
pub update_mode: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnCreateCatalogSyncResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: McnCatalogSync,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnDeleteCatalogSyncResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: McnDeletedCatalogSync,
pub success: bool,
}
pub type McnDeletedCatalogSync = super::shared::IdObject2;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnError {
pub code: i64,
pub documentation_url: Option<String>,
pub message: String,
pub meta: Option<McnErrorMeta>,
pub source: Option<McnErrorSource>,
}
pub type McnErrorMeta = super::shared::McnErrorMetaShape;
pub type McnErrorSource = super::shared::ParameterParameterValueIndexPointerObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnGoodResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnGoodResponseCollection {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result_info: Option<McnResultInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnListItem {
pub item_type: String,
pub list: Vec<serde_json::Value>,
}
pub type McnPlatformClientId = String;
pub type McnPolicyResult = String;
pub type McnProviderId = String;
pub type McnReadAccountCatalogSyncResponse = McnCreateCatalogSyncResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountCatalogSyncsResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: Vec<McnCatalogSync>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountResourceResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: McnResourceDetails,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnReadAccountResourcesResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: Vec<McnResourceDetails>,
pub result_info: Option<McnResultInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnRefreshCatalogSyncResponse {
pub errors: Vec<McnError>,
pub messages: Vec<McnError>,
pub result: String,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetails {
pub account_id: String,
pub cloud_type: String,
pub config: serde_json::Value,
pub deployment_provider: String,
pub id: String,
pub managed: bool,
pub managed_by: Option<Vec<McnCloudPlatformClient>>,
pub monthly_cost_estimate: McnCost,
pub name: String,
pub native_id: String,
pub observations: serde_json::Value,
pub provider_ids: Vec<String>,
pub provider_names_by_id: serde_json::Value,
pub region: String,
pub resource_group: String,
pub resource_type: String,
pub sections: Vec<McnResourceDetailsSection>,
pub state: serde_json::Value,
pub tags: serde_json::Value,
pub updated_at: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetailsSection {
pub help_text: Option<String>,
pub hidden_items: Vec<McnResourceDetailsSectionItem>,
pub name: String,
pub visible_items: Vec<McnResourceDetailsSectionItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourceDetailsSectionItem {
#[serde(rename = "helpText")]
pub help_text: Option<String>,
pub name: Option<String>,
pub value: Option<serde_json::Value>,
}
pub type McnResourceId = String;
pub type McnResourcePreview = super::shared::McnResourcePreviewShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcePreviewItem {
pub item_type: String,
pub resource_preview: McnResourcePreview,
}
pub type McnResourceType = String;
pub type McnResourcesCatalogPolicyPreview = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResourcesCatalogPolicyPreviewRequest {
pub policy: String,
}
pub type McnResourcesCatalogPolicyPreviewResponse = McnRefreshCatalogSyncResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResponse {
pub messages: Vec<McnError>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnResponseCollection {
pub messages: Vec<McnError>,
pub result_info: Option<McnResultInfo>,
pub success: bool,
}
pub type McnResultInfo = super::shared::TeamsDevicesPaginationInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnStringItem {
pub item_type: String,
pub string: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnUpdateCatalogSyncRequest {
pub description: Option<String>,
pub name: Option<String>,
pub policy: Option<String>,
pub update_mode: Option<String>,
}
pub type McnUpdateCatalogSyncResponse = McnCreateCatalogSyncResponse;
pub type McnYamlDiff = super::shared::McnYamlDiffShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnYamlDiffItem {
pub item_type: String,
pub yaml_diff: McnYamlDiff,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct McnYamlItem {
pub item_type: String,
pub yaml: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushJobsRequest {
pub dataset: Option<String>,
pub destination_conf: String,
pub enabled: Option<bool>,
pub filter: Option<String>,
pub frequency: Option<String>,
pub kind: Option<String>,
pub logpull_options: Option<String>,
pub max_upload_bytes: Option<i64>,
pub max_upload_interval_seconds: Option<i64>,
pub max_upload_records: Option<i64>,
pub name: Option<String>,
pub output_options: Option<LogpushOutputOptions>,
pub ownership_challenge: Option<String>,
}
pub type PostAccountsAccountIdLogpushOwnershipRequest = super::shared::DestinationConfObject;
pub type PostAccountsAccountIdLogpushOwnershipValidateRequest =
super::shared::DestinationConfOwnershipChallengeObject;
pub type PostAccountsAccountIdLogpushValidateOriginRequest = super::shared::LogpullOptionsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PutAccountsAccountIdLogpushJobsJobIdRequest {
pub destination_conf: Option<String>,
pub enabled: Option<bool>,
pub filter: Option<String>,
pub frequency: Option<String>,
pub kind: Option<String>,
pub logpull_options: Option<String>,
pub max_upload_bytes: Option<i64>,
pub max_upload_interval_seconds: Option<i64>,
pub max_upload_records: Option<i64>,
pub name: Option<String>,
pub output_options: Option<LogpushOutputOptions>,
pub ownership_challenge: Option<String>,
}
pub type R2SlurperApiV4Error = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type R2SlurperApiV4Message = Vec<String>;
pub type R2SlurperApiV4Success = super::shared::ErrorsMessagesSuccessObject2;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperJobLogResponse {
#[serde(rename = "createdAt")]
pub created_at: Option<String>,
pub job: Option<String>,
#[serde(rename = "logType")]
pub log_type: Option<String>,
pub message: Option<String>,
#[serde(rename = "objectKey")]
pub object_key: Option<String>,
}
pub type SlurperGetJobLogsResponse =
super::shared::ApiEnvelope3<Option<Vec<R2SlurperJobLogResponse>>>;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AuditLogsGetAccountAuditLogsArgs {
pub account_id: String,
pub id: Option<String>,
pub export: Option<String>,
pub action_type: Option<String>,
pub actor_ip: Option<String>,
pub actor_email: Option<String>,
pub since: Option<String>,
pub before: Option<String>,
pub zone_name: Option<String>,
pub direction: Option<String>,
pub per_page: Option<String>,
pub page: Option<String>,
pub hide_user_logs: Option<String>,
}
pub type DlpPayloadLogGetArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DlpPayloadLogPutArgs {
pub account_id: String,
pub body: DlpPayloadLogSettingUpdateLegacy,
}
pub type GetAccountsAccountIdLogpushDatasetsDatasetIdFieldsArgs =
super::shared::DatasetIdAccountIdArgs;
pub type GetAccountsAccountIdLogpushDatasetsDatasetIdJobsArgs =
super::shared::DatasetIdAccountIdArgs;
pub type GetAccountsAccountIdLogpushJobsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushJobsArgs {
pub account_id: String,
pub body: PostAccountsAccountIdLogpushJobsRequest,
}
pub type GetAccountsAccountIdLogpushJobsJobIdArgs = super::shared::JobIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PutAccountsAccountIdLogpushJobsJobIdArgs {
pub job_id: String,
pub account_id: String,
pub body: PutAccountsAccountIdLogpushJobsJobIdRequest,
}
pub type DeleteAccountsAccountIdLogpushJobsJobIdArgs = super::shared::JobIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipArgs {
pub account_id: String,
pub body: PostAccountsAccountIdLogpushOwnershipRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushOwnershipValidateArgs {
pub account_id: String,
pub body: PostAccountsAccountIdLogpushOwnershipValidateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationArgs {
pub account_id: String,
pub body: DeleteAccountsAccountIdLogpushValidateDestinationRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteAccountsAccountIdLogpushValidateDestinationExistsArgs {
pub account_id: String,
pub body: DeleteAccountsAccountIdLogpushValidateDestinationExistsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogpushValidateOriginArgs {
pub account_id: String,
pub body: PostAccountsAccountIdLogpushValidateOriginRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AuditLogsV2GetAccountAuditLogsArgs {
pub account_id: String,
pub account_name: Vec<String>,
pub action_result: Vec<String>,
pub action_type: Vec<String>,
pub actor_context: Vec<String>,
pub actor_email: Vec<String>,
pub actor_id: Vec<String>,
pub actor_ip_address: Vec<String>,
pub actor_token_id: Vec<String>,
pub actor_token_name: Vec<String>,
pub actor_type: Vec<String>,
pub audit_log_id: Vec<String>,
pub id: Vec<String>,
pub raw_cf_ray_id: Vec<String>,
pub raw_method: Vec<String>,
pub raw_status_code: Vec<String>,
pub raw_uri: Vec<String>,
pub resource_id: Vec<String>,
pub resource_product: Vec<String>,
pub resource_type: Vec<String>,
pub resource_scope: Vec<String>,
pub zone_id: Vec<String>,
pub zone_name: Vec<String>,
pub account_name_not: Vec<String>,
pub action_result_not: Vec<String>,
pub action_type_not: Vec<String>,
pub actor_context_not: Vec<String>,
pub actor_email_not: Vec<String>,
pub actor_id_not: Vec<String>,
pub actor_ip_address_not: Vec<String>,
pub actor_token_id_not: Vec<String>,
pub actor_token_name_not: Vec<String>,
pub actor_type_not: Vec<String>,
pub audit_log_id_not: Vec<String>,
pub id_not: Vec<String>,
pub raw_cf_ray_id_not: Vec<String>,
pub raw_method_not: Vec<String>,
pub raw_status_code_not: Vec<String>,
pub raw_uri_not: Vec<String>,
pub resource_id_not: Vec<String>,
pub resource_product_not: Vec<String>,
pub resource_type_not: Vec<String>,
pub resource_scope_not: Vec<String>,
pub zone_id_not: Vec<String>,
pub zone_name_not: Vec<String>,
pub since: Option<String>,
pub before: Option<String>,
pub direction: Option<String>,
pub limit: Option<String>,
pub cursor: Option<String>,
}
pub type GetAccountsAccountIdLogsControlCmbConfigArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostAccountsAccountIdLogsControlCmbConfigArgs {
pub account_id: String,
pub body: LogcontrolCmbConfig,
}
pub type DeleteAccountsAccountIdLogsControlCmbConfigArgs = super::shared::AccountIdArgs;
pub type CatalogSyncsListArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsCreateArgs {
pub account_id: String,
pub body: McnCreateCatalogSyncRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsPrebuiltPoliciesListArgs {
pub account_id: String,
pub destination_type: Option<String>,
}
pub type CatalogSyncsReadArgs = super::shared::AccountIdSyncIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsUpdateArgs {
pub account_id: String,
pub sync_id: String,
pub body: McnUpdateCatalogSyncRequest,
}
pub type CatalogSyncsPatchArgs = CatalogSyncsUpdateArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CatalogSyncsDeleteArgs {
pub account_id: String,
pub sync_id: String,
pub delete_destination: Option<String>,
}
pub type CatalogSyncsRefreshArgs = super::shared::AccountIdSyncIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogListArgs {
pub account_id: String,
pub provider_id: Option<String>,
pub resource_type: Vec<String>,
pub resource_id: Vec<String>,
pub region: Option<String>,
pub resource_group: Option<String>,
pub managed: Option<String>,
pub search: Vec<String>,
pub order_by: Option<String>,
pub desc: Option<String>,
pub per_page: Option<String>,
pub page: Option<String>,
pub cloudflare: Option<String>,
pub v2: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogExportArgs {
pub account_id: String,
pub provider_id: Option<String>,
pub resource_type: Vec<String>,
pub resource_id: Vec<String>,
pub region: Option<String>,
pub resource_group: Option<String>,
pub search: Vec<String>,
pub order_by: Option<String>,
pub desc: Option<String>,
pub v2: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogPolicyPreviewArgs {
pub account_id: String,
pub body: McnResourcesCatalogPolicyPreviewRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ResourcesCatalogReadArgs {
pub account_id: String,
pub resource_id: String,
pub v2: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SlurperGetJobLogsArgs {
pub account_id: String,
pub job_id: String,
pub limit: Option<String>,
pub offset: Option<String>,
}
pub async fn audit_logs_get_account_audit_logs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AuditLogsGetAccountAuditLogsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaAuditLogsResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/audit_logs", 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("id", args.id.as_deref());
builder = builder.query("export", args.export.as_deref());
builder = builder.query("action.type", args.action_type.as_deref());
builder = builder.query("actor.ip", args.actor_ip.as_deref());
builder = builder.query("actor.email", args.actor_email.as_deref());
builder = builder.query("since", args.since.as_deref());
builder = builder.query("before", args.before.as_deref());
builder = builder.query("zone.name", args.zone_name.as_deref());
builder = builder.query("direction", args.direction.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("hide_user_logs", args.hide_user_logs.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dlp_payload_log_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DlpPayloadLogGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpPayloadLogGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/payload_log", 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 dlp_payload_log_put_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DlpPayloadLogPutArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DlpPayloadLogPutResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dlp/payload_log", 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 get_accounts_account_id_logpush_datasets_dataset_id_fields_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountsAccountIdLogpushDatasetsDatasetIdFieldsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushFieldResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/logpush/datasets/{}/fields",
args.account_id, args.dataset_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 get_accounts_account_id_logpush_datasets_dataset_id_jobs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountsAccountIdLogpushDatasetsDatasetIdJobsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/logpush/datasets/{}/jobs",
args.account_id, args.dataset_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 get_accounts_account_id_logpush_jobs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountsAccountIdLogpushJobsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/jobs", 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 post_accounts_account_id_logpush_jobs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostAccountsAccountIdLogpushJobsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/jobs", 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 get_accounts_account_id_logpush_jobs_job_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountsAccountIdLogpushJobsJobIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/jobs/{}", args.account_id, args.job_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 put_accounts_account_id_logpush_jobs_job_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PutAccountsAccountIdLogpushJobsJobIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushLogpushJobResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/jobs/{}", args.account_id, args.job_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 delete_accounts_account_id_logpush_jobs_job_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteAccountsAccountIdLogpushJobsJobIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteAccountsAccountIdLogpushJobsJobIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/jobs/{}", args.account_id, args.job_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 post_accounts_account_id_logpush_ownership_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostAccountsAccountIdLogpushOwnershipArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushGetOwnershipResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/ownership", 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 post_accounts_account_id_logpush_ownership_validate_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostAccountsAccountIdLogpushOwnershipValidateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateOwnershipResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/ownership/validate", 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 delete_accounts_account_id_logpush_validate_destination_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteAccountsAccountIdLogpushValidateDestinationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/validate/destination", 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 delete_accounts_account_id_logpush_validate_destination_exists_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteAccountsAccountIdLogpushValidateDestinationExistsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushDestinationExistsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/logpush/validate/destination/exists",
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 post_accounts_account_id_logpush_validate_origin_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostAccountsAccountIdLogpushValidateOriginArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogpushValidateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logpush/validate/origin", 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 audit_logs_v2_get_account_audit_logs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AuditLogsV2GetAccountAuditLogsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AaaAuditLogsV2ResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logs/audit", 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.account_name {
builder = builder.query("account_name", Some(value.as_str()));
}
for value in &args.action_result {
builder = builder.query("action_result", Some(value.as_str()));
}
for value in &args.action_type {
builder = builder.query("action_type", Some(value.as_str()));
}
for value in &args.actor_context {
builder = builder.query("actor_context", Some(value.as_str()));
}
for value in &args.actor_email {
builder = builder.query("actor_email", Some(value.as_str()));
}
for value in &args.actor_id {
builder = builder.query("actor_id", Some(value.as_str()));
}
for value in &args.actor_ip_address {
builder = builder.query("actor_ip_address", Some(value.as_str()));
}
for value in &args.actor_token_id {
builder = builder.query("actor_token_id", Some(value.as_str()));
}
for value in &args.actor_token_name {
builder = builder.query("actor_token_name", Some(value.as_str()));
}
for value in &args.actor_type {
builder = builder.query("actor_type", Some(value.as_str()));
}
for value in &args.audit_log_id {
builder = builder.query("audit_log_id", Some(value.as_str()));
}
for value in &args.id {
builder = builder.query("id", Some(value.as_str()));
}
for value in &args.raw_cf_ray_id {
builder = builder.query("raw_cf_ray_id", Some(value.as_str()));
}
for value in &args.raw_method {
builder = builder.query("raw_method", Some(value.as_str()));
}
for value in &args.raw_status_code {
builder = builder.query("raw_status_code", Some(value.as_str()));
}
for value in &args.raw_uri {
builder = builder.query("raw_uri", Some(value.as_str()));
}
for value in &args.resource_id {
builder = builder.query("resource_id", Some(value.as_str()));
}
for value in &args.resource_product {
builder = builder.query("resource_product", Some(value.as_str()));
}
for value in &args.resource_type {
builder = builder.query("resource_type", Some(value.as_str()));
}
for value in &args.resource_scope {
builder = builder.query("resource_scope", Some(value.as_str()));
}
for value in &args.zone_id {
builder = builder.query("zone_id", Some(value.as_str()));
}
for value in &args.zone_name {
builder = builder.query("zone_name", Some(value.as_str()));
}
for value in &args.account_name_not {
builder = builder.query("account_name.not", Some(value.as_str()));
}
for value in &args.action_result_not {
builder = builder.query("action_result.not", Some(value.as_str()));
}
for value in &args.action_type_not {
builder = builder.query("action_type.not", Some(value.as_str()));
}
for value in &args.actor_context_not {
builder = builder.query("actor_context.not", Some(value.as_str()));
}
for value in &args.actor_email_not {
builder = builder.query("actor_email.not", Some(value.as_str()));
}
for value in &args.actor_id_not {
builder = builder.query("actor_id.not", Some(value.as_str()));
}
for value in &args.actor_ip_address_not {
builder = builder.query("actor_ip_address.not", Some(value.as_str()));
}
for value in &args.actor_token_id_not {
builder = builder.query("actor_token_id.not", Some(value.as_str()));
}
for value in &args.actor_token_name_not {
builder = builder.query("actor_token_name.not", Some(value.as_str()));
}
for value in &args.actor_type_not {
builder = builder.query("actor_type.not", Some(value.as_str()));
}
for value in &args.audit_log_id_not {
builder = builder.query("audit_log_id.not", Some(value.as_str()));
}
for value in &args.id_not {
builder = builder.query("id.not", Some(value.as_str()));
}
for value in &args.raw_cf_ray_id_not {
builder = builder.query("raw_cf_ray_id.not", Some(value.as_str()));
}
for value in &args.raw_method_not {
builder = builder.query("raw_method.not", Some(value.as_str()));
}
for value in &args.raw_status_code_not {
builder = builder.query("raw_status_code.not", Some(value.as_str()));
}
for value in &args.raw_uri_not {
builder = builder.query("raw_uri.not", Some(value.as_str()));
}
for value in &args.resource_id_not {
builder = builder.query("resource_id.not", Some(value.as_str()));
}
for value in &args.resource_product_not {
builder = builder.query("resource_product.not", Some(value.as_str()));
}
for value in &args.resource_type_not {
builder = builder.query("resource_type.not", Some(value.as_str()));
}
for value in &args.resource_scope_not {
builder = builder.query("resource_scope.not", Some(value.as_str()));
}
for value in &args.zone_id_not {
builder = builder.query("zone_id.not", Some(value.as_str()));
}
for value in &args.zone_name_not {
builder = builder.query("zone_name.not", Some(value.as_str()));
}
builder = builder.query("since", args.since.as_deref());
builder = builder.query("before", args.before.as_deref());
builder = builder.query("direction", args.direction.as_deref());
builder = builder.query("limit", args.limit.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 get_accounts_account_id_logs_control_cmb_config_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountsAccountIdLogsControlCmbConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogcontrolCmbConfigResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logs/control/cmb/config", 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 post_accounts_account_id_logs_control_cmb_config_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostAccountsAccountIdLogsControlCmbConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LogcontrolCmbConfigResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logs/control/cmb/config", 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 delete_accounts_account_id_logs_control_cmb_config_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteAccountsAccountIdLogsControlCmbConfigArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteAccountsAccountIdLogsControlCmbConfigResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/logs/control/cmb/config", 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 catalog_syncs_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountCatalogSyncsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cloud/catalog-syncs", 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 catalog_syncs_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnCreateCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cloud/catalog-syncs", 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 catalog_syncs_prebuilt_policies_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsPrebuiltPoliciesListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnCatalogSyncsPrebuiltPoliciesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/prebuilt-policies",
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("destination_type", args.destination_type.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn catalog_syncs_read_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsReadArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/{}",
args.account_id, args.sync_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 catalog_syncs_update_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnUpdateCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/{}",
args.account_id, args.sync_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 catalog_syncs_patch_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsPatchArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnUpdateCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/{}",
args.account_id, args.sync_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::patch(&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 catalog_syncs_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnDeleteCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/{}",
args.account_id, args.sync_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.query("delete_destination", args.delete_destination.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn catalog_syncs_refresh_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CatalogSyncsRefreshArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnRefreshCatalogSyncResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/catalog-syncs/{}/refresh",
args.account_id, args.sync_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 resources_catalog_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ResourcesCatalogListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountResourcesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cloud/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("provider_id", args.provider_id.as_deref());
for value in &args.resource_type {
builder = builder.query("resource_type", Some(value.as_str()));
}
for value in &args.resource_id {
builder = builder.query("resource_id", Some(value.as_str()));
}
builder = builder.query("region", args.region.as_deref());
builder = builder.query("resource_group", args.resource_group.as_deref());
builder = builder.query("managed", args.managed.as_deref());
for value in &args.search {
builder = builder.query("search", Some(value.as_str()));
}
builder = builder.query("order_by", args.order_by.as_deref());
builder = builder.query("desc", args.desc.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("cloudflare", args.cloudflare.as_deref());
builder = builder.query("v2", args.v2.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn resources_catalog_export_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ResourcesCatalogExportArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cloud/resources/export", 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("provider_id", args.provider_id.as_deref());
for value in &args.resource_type {
builder = builder.query("resource_type", Some(value.as_str()));
}
for value in &args.resource_id {
builder = builder.query("resource_id", Some(value.as_str()));
}
builder = builder.query("region", args.region.as_deref());
builder = builder.query("resource_group", args.resource_group.as_deref());
for value in &args.search {
builder = builder.query("search", Some(value.as_str()));
}
builder = builder.query("order_by", args.order_by.as_deref());
builder = builder.query("desc", args.desc.as_deref());
builder = builder.query("v2", args.v2.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_bytes(client.into(), builder.build()).await
}
pub async fn resources_catalog_policy_preview_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ResourcesCatalogPolicyPreviewArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnResourcesCatalogPolicyPreviewResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/resources/policy-preview",
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 resources_catalog_read_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ResourcesCatalogReadArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<McnReadAccountResourceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cloud/resources/{}",
args.account_id, args.resource_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("v2", args.v2.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn slurper_get_job_logs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SlurperGetJobLogsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<SlurperGetJobLogsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/slurper/jobs/{}/logs",
args.account_id, args.job_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("limit", args.limit.as_deref());
builder = builder.query("offset", args.offset.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}