#![cfg(feature = "cloudflare_load_balancers")]
#![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;
use super::shared::LoadBalancingHealthDetails;
use super::shared::LoadBalancingIdResponse;
use super::shared::LoadBalancingMonitorReferencesResponse;
use super::shared::LoadBalancingMonitorResponseCollection;
use super::shared::LoadBalancingMonitorResponseSingle;
use super::shared::LoadBalancingPoolsReferencesResponse;
use super::shared::LoadBalancingPreviewResponse;
use super::shared::LoadBalancingPreviewResultResponse;
use super::shared::LoadBalancingSchemasIdResponse;
use super::shared::LoadBalancingSchemasResponseCollection;
use super::shared::LoadBalancingSchemasSingleResponse;
use super::shared::MagicVisibilityMnmMnmConfigSingleResponse;
use super::shared::LoadBalancingAddress;
use super::shared::LoadBalancingAllowInsecure;
use super::shared::LoadBalancingApiPaginatedResponseCollection;
use super::shared::LoadBalancingApiResponseCommon;
use super::shared::LoadBalancingApiResponseSingle;
use super::shared::LoadBalancingConsecutiveDown;
use super::shared::LoadBalancingConsecutiveUp;
use super::shared::LoadBalancingDescription;
use super::shared::LoadBalancingDisabledAt;
use super::shared::LoadBalancingEnabled;
use super::shared::LoadBalancingExpectedBody;
use super::shared::LoadBalancingExpectedCodes;
use super::shared::LoadBalancingFilterOptions;
use super::shared::LoadBalancingFollowRedirects;
use super::shared::LoadBalancingHeader;
use super::shared::LoadBalancingIdentifier;
use super::shared::LoadBalancingInterval;
use super::shared::LoadBalancingLatitude;
use super::shared::LoadBalancingLoadShedding;
use super::shared::LoadBalancingLongitude;
use super::shared::LoadBalancingMethod;
use super::shared::LoadBalancingMinimumOrigins;
use super::shared::LoadBalancingMonitor;
use super::shared::LoadBalancingMonitorEditable;
use super::shared::LoadBalancingMonitorGroupId;
use super::shared::LoadBalancingMonitorId;
use super::shared::LoadBalancingName;
use super::shared::LoadBalancingNotificationEmail;
use super::shared::LoadBalancingNotificationFilter;
use super::shared::LoadBalancingOrigin;
use super::shared::LoadBalancingOriginHealth;
use super::shared::LoadBalancingOriginPort;
use super::shared::LoadBalancingOriginSteering;
use super::shared::LoadBalancingPath;
use super::shared::LoadBalancingPool;
use super::shared::LoadBalancingPort;
use super::shared::LoadBalancingPreviewResult;
use super::shared::LoadBalancingProbeZone;
use super::shared::LoadBalancingResultInfo;
use super::shared::LoadBalancingRetries;
use super::shared::LoadBalancingSchemasDescription;
use super::shared::LoadBalancingSchemasDisabledAt;
use super::shared::LoadBalancingSchemasEnabled;
use super::shared::LoadBalancingSchemasHeader;
use super::shared::LoadBalancingSchemasIdentifier;
use super::shared::LoadBalancingSchemasName;
use super::shared::LoadBalancingTimeout;
use super::shared::LoadBalancingTimestamp;
use super::shared::LoadBalancingType;
use super::shared::LoadBalancingVirtualNetworkId;
use super::shared::LoadBalancingWeight;
use super::shared::MagicVisibilityMnmApiResponseCommon;
use super::shared::MagicVisibilityMnmApiResponseSingle;
use super::shared::MagicVisibilityMnmMnmConfig;
use super::shared::MagicVisibilityMnmMnmConfigDefaultSampling;
use super::shared::MagicVisibilityMnmMnmConfigName;
use super::shared::MagicVisibilityMnmMnmConfigRouterIp;
use super::shared::MagicVisibilityMnmMnmConfigWarpDevice;
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsCreateMonitorRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsPatchMonitorRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsPreviewMonitorRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsUpdateMonitorRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerPoolsCreatePoolRequest {
pub description: Option<LoadBalancingSchemasDescription>,
pub enabled: Option<LoadBalancingEnabled>,
pub latitude: Option<LoadBalancingLatitude>,
pub load_shedding: Option<LoadBalancingLoadShedding>,
pub longitude: Option<LoadBalancingLongitude>,
pub minimum_origins: Option<LoadBalancingMinimumOrigins>,
pub monitor: Option<LoadBalancingMonitorId>,
pub monitor_group: Option<LoadBalancingMonitorGroupId>,
pub name: LoadBalancingName,
pub notification_email: Option<LoadBalancingNotificationEmail>,
pub notification_filter: Option<LoadBalancingNotificationFilter>,
pub origin_steering: Option<LoadBalancingOriginSteering>,
pub origins: Vec<LoadBalancingOrigin>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPatchPoolRequest {
pub check_regions: Option<Vec<String>>,
pub description: Option<LoadBalancingSchemasDescription>,
pub disabled_at: Option<LoadBalancingSchemasDisabledAt>,
pub enabled: Option<LoadBalancingEnabled>,
pub latitude: Option<LoadBalancingLatitude>,
pub load_shedding: Option<LoadBalancingLoadShedding>,
pub longitude: Option<LoadBalancingLongitude>,
pub minimum_origins: Option<LoadBalancingMinimumOrigins>,
pub monitor: Option<LoadBalancingMonitorId>,
pub monitor_group: Option<LoadBalancingMonitorGroupId>,
pub name: Option<LoadBalancingName>,
pub notification_email: Option<LoadBalancingNotificationEmail>,
pub notification_filter: Option<LoadBalancingNotificationFilter>,
pub origin_steering: Option<LoadBalancingOriginSteering>,
pub origins: Option<Vec<LoadBalancingOrigin>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPatchPoolsRequest {
pub notification_email: Option<LoadBalancingPatchPoolsNotificationEmail>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPreviewPoolRequest {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerPoolsUpdatePoolRequest {
pub check_regions: Option<Vec<String>>,
pub description: Option<LoadBalancingSchemasDescription>,
pub disabled_at: Option<LoadBalancingSchemasDisabledAt>,
pub enabled: Option<LoadBalancingEnabled>,
pub latitude: Option<LoadBalancingLatitude>,
pub load_shedding: Option<LoadBalancingLoadShedding>,
pub longitude: Option<LoadBalancingLongitude>,
pub minimum_origins: Option<LoadBalancingMinimumOrigins>,
pub monitor: Option<LoadBalancingMonitorId>,
pub monitor_group: Option<LoadBalancingMonitorGroupId>,
pub name: LoadBalancingName,
pub notification_email: Option<LoadBalancingNotificationEmail>,
pub notification_filter: Option<LoadBalancingNotificationFilter>,
pub origin_steering: Option<LoadBalancingOriginSteering>,
pub origins: Vec<LoadBalancingOrigin>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccountLoadBalancerSearchSearchResourcesResponse {
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingCheckRegions {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingComponentsSchemasSingleResponse {
pub result: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingHost {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMonitorGroup {
pub created_at: Option<String>,
pub description: String,
pub id: LoadBalancingMonitorGroupId,
pub members: Vec<LoadBalancingMonitorGroupMember>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMonitorGroupMember {
pub created_at: Option<String>,
pub enabled: bool,
pub monitor_id: LoadBalancingMonitorId,
pub monitoring_only: bool,
pub must_be_healthy: bool,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMonitorGroupReferencesResponse {
pub result: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMonitorGroupResponseCollection {
pub result: Option<Vec<LoadBalancingMonitorGroup>>,
pub result_info: Option<LoadBalancingResultInfo>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingMonitorGroupSingleResponse {
pub result: Option<LoadBalancingMonitorGroup>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingNetworks {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingOrigins {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingPatchPoolsNotificationEmail {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingRegionComponentsSchemasResponseCollection {
pub result: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingResourceReference {
pub reference_type: Option<String>,
pub references: Option<Vec<serde_json::Value>>,
pub resource_id: Option<String>,
pub resource_name: Option<String>,
pub resource_type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingSearch {
pub resources: Option<Vec<LoadBalancingResourceReference>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct LoadBalancingSearchResult {
pub result: Option<LoadBalancingSearch>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationCreateAccountConfigurationRequest {
pub default_sampling: MagicVisibilityMnmMnmConfigDefaultSampling,
pub name: MagicVisibilityMnmMnmConfigName,
pub router_ips: Option<Vec<MagicVisibilityMnmMnmConfigRouterIp>>,
pub warp_devices: Option<Vec<MagicVisibilityMnmMnmConfigWarpDevice>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationUpdateAccountConfigurationFieldsRequest {
pub default_sampling: Option<MagicVisibilityMnmMnmConfigDefaultSampling>,
pub name: Option<MagicVisibilityMnmMnmConfigName>,
pub router_ips: Option<Vec<MagicVisibilityMnmMnmConfigRouterIp>>,
pub warp_devices: Option<Vec<MagicVisibilityMnmMnmConfigWarpDevice>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationUpdateAnEntireAccountConfigurationRequest {
pub default_sampling: MagicVisibilityMnmMnmConfigDefaultSampling,
pub name: MagicVisibilityMnmMnmConfigName,
pub router_ips: Option<Vec<MagicVisibilityMnmMnmConfigRouterIp>>,
pub warp_devices: Option<Vec<MagicVisibilityMnmMnmConfigWarpDevice>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitApiResponseCommon {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitCheckType {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitEndpointHealthCheck {
pub check_type: MagicTransitCheckType,
pub endpoint: String,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitEndpointHealthCheckResponse {
pub id: Option<MagicTransitUuid>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitEndpointHealthCheckResponseSingle {
pub result: Option<MagicTransitEndpointHealthCheckResponse>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTransitUuid {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityMnmMessages {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityMnmMnmConfigRouterIps {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityMnmMnmConfigWarpDevices {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityMnmMnmVpcFlowsSingleResponse {
pub result: Option<MagicVisibilityMnmMnmVpcFlowsToken>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityMnmMnmVpcFlowsToken {
#[serde(flatten)]
pub data: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DiagnosticsEndpointHealthcheckListArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DiagnosticsEndpointHealthcheckCreateArgs {
pub account_id: String,
pub body: MagicTransitEndpointHealthCheck,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DiagnosticsEndpointHealthcheckGetArgs {
pub account_id: String,
pub id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DiagnosticsEndpointHealthcheckUpdateArgs {
pub account_id: String,
pub id: String,
pub body: MagicTransitEndpointHealthCheck,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DiagnosticsEndpointHealthcheckDeleteArgs {
pub account_id: String,
pub id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsListMonitorGroupsArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsCreateMonitorGroupArgs {
pub account_id: String,
pub body: LoadBalancingMonitorGroup,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsMonitorGroupDetailsArgs {
pub monitor_group_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsUpdateMonitorGroupArgs {
pub monitor_group_id: String,
pub account_id: String,
pub body: LoadBalancingMonitorGroup,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsPatchMonitorGroupArgs {
pub monitor_group_id: String,
pub account_id: String,
pub body: LoadBalancingMonitorGroup,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsDeleteMonitorGroupArgs {
pub monitor_group_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorGroupsListMonitorGroupReferencesArgs {
pub monitor_group_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsListMonitorsArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsCreateMonitorArgs {
pub account_id: String,
pub body: AccountLoadBalancerMonitorsCreateMonitorRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsMonitorDetailsArgs {
pub monitor_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsUpdateMonitorArgs {
pub monitor_id: String,
pub account_id: String,
pub body: AccountLoadBalancerMonitorsUpdateMonitorRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsPatchMonitorArgs {
pub monitor_id: String,
pub account_id: String,
pub body: AccountLoadBalancerMonitorsPatchMonitorRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsDeleteMonitorArgs {
pub monitor_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsPreviewMonitorArgs {
pub monitor_id: String,
pub account_id: String,
pub body: AccountLoadBalancerMonitorsPreviewMonitorRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsListMonitorReferencesArgs {
pub monitor_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsListPoolsArgs {
pub account_id: String,
pub monitor: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsCreatePoolArgs {
pub account_id: String,
pub body: AccountLoadBalancerPoolsCreatePoolRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPatchPoolsArgs {
pub account_id: String,
pub body: AccountLoadBalancerPoolsPatchPoolsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPoolDetailsArgs {
pub pool_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsUpdatePoolArgs {
pub pool_id: String,
pub account_id: String,
pub body: AccountLoadBalancerPoolsUpdatePoolRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPatchPoolArgs {
pub pool_id: String,
pub account_id: String,
pub body: AccountLoadBalancerPoolsPatchPoolRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsDeletePoolArgs {
pub pool_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPoolHealthDetailsArgs {
pub pool_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsPreviewPoolArgs {
pub pool_id: String,
pub account_id: String,
pub body: AccountLoadBalancerPoolsPreviewPoolRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerPoolsListPoolReferencesArgs {
pub pool_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerMonitorsPreviewResultArgs {
pub preview_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct LoadBalancerRegionsListRegionsArgs {
pub account_id: String,
pub subdivision_code: Option<String>,
pub subdivision_code_a2: Option<String>,
pub country_code_a2: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct LoadBalancerRegionsGetRegionArgs {
pub region_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountLoadBalancerSearchSearchResourcesArgs {
pub account_id: String,
pub query: Option<String>,
pub references: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationListAccountConfigurationArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationCreateAccountConfigurationArgs {
pub account_id: String,
pub body: MagicNetworkMonitoringConfigurationCreateAccountConfigurationRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationUpdateAnEntireAccountConfigurationArgs {
pub account_id: String,
pub body: MagicNetworkMonitoringConfigurationUpdateAnEntireAccountConfigurationRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationUpdateAccountConfigurationFieldsArgs {
pub account_id: String,
pub body: MagicNetworkMonitoringConfigurationUpdateAccountConfigurationFieldsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringConfigurationDeleteAccountConfigurationArgs {
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicNetworkMonitoringVpcFlowsGenerateAuthenticationTokenArgs {
pub account_id: String,
}
pub async fn diagnostics_endpoint_healthcheck_list_request<F>(
client: DynNetClient,
args: &DiagnosticsEndpointHealthcheckListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTransitEndpointHealthCheckResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/diagnostics/endpoint-healthchecks",
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: MagicTransitEndpointHealthCheckResponseSingle = 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 })
}
pub async fn diagnostics_endpoint_healthcheck_create_request<F>(
client: DynNetClient,
args: &DiagnosticsEndpointHealthcheckCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTransitEndpointHealthCheckResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/diagnostics/endpoint-healthchecks",
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: MagicTransitEndpointHealthCheckResponseSingle = 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 })
}
pub async fn diagnostics_endpoint_healthcheck_get_request<F>(
client: DynNetClient,
args: &DiagnosticsEndpointHealthcheckGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTransitEndpointHealthCheckResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/diagnostics/endpoint-healthchecks/{}",
args.account_id,
args.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: MagicTransitEndpointHealthCheckResponseSingle = 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 })
}
pub async fn diagnostics_endpoint_healthcheck_update_request<F>(
client: DynNetClient,
args: &DiagnosticsEndpointHealthcheckUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTransitEndpointHealthCheckResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/diagnostics/endpoint-healthchecks/{}",
args.account_id,
args.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: MagicTransitEndpointHealthCheckResponseSingle = 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 })
}
pub async fn diagnostics_endpoint_healthcheck_delete_request<F>(
client: DynNetClient,
args: &DiagnosticsEndpointHealthcheckDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTransitApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/diagnostics/endpoint-healthchecks/{}",
args.account_id,
args.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: MagicTransitApiResponseCommon = 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 })
}
pub async fn account_load_balancer_monitor_groups_list_monitor_groups_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsListMonitorGroupsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups",
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: LoadBalancingMonitorGroupResponseCollection = 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 })
}
pub async fn account_load_balancer_monitor_groups_create_monitor_group_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsCreateMonitorGroupArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups",
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: LoadBalancingMonitorGroupSingleResponse = 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 })
}
pub async fn account_load_balancer_monitor_groups_monitor_group_details_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsMonitorGroupDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups/{}",
args.account_id,
args.monitor_group_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: LoadBalancingMonitorGroupSingleResponse = 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 })
}
pub async fn account_load_balancer_monitor_groups_update_monitor_group_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsUpdateMonitorGroupArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups/{}",
args.account_id,
args.monitor_group_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: LoadBalancingMonitorGroupSingleResponse = 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 })
}
pub async fn account_load_balancer_monitor_groups_patch_monitor_group_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsPatchMonitorGroupArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups/{}",
args.account_id,
args.monitor_group_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);
}
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: LoadBalancingMonitorGroupSingleResponse = 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 })
}
pub async fn account_load_balancer_monitor_groups_delete_monitor_group_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsDeleteMonitorGroupArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups/{}",
args.account_id,
args.monitor_group_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: LoadBalancingMonitorGroupSingleResponse = 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 })
}
pub async fn account_load_balancer_monitor_groups_list_monitor_group_references_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorGroupsListMonitorGroupReferencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorGroupReferencesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitor_groups/{}/references",
args.account_id,
args.monitor_group_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: LoadBalancingMonitorGroupReferencesResponse = 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 })
}
pub async fn account_load_balancer_monitors_list_monitors_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsListMonitorsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors",
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: LoadBalancingMonitorResponseCollection = 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 })
}
pub async fn account_load_balancer_monitors_create_monitor_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsCreateMonitorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors",
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: LoadBalancingMonitorResponseSingle = 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 })
}
pub async fn account_load_balancer_monitors_monitor_details_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsMonitorDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}",
args.account_id,
args.monitor_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: LoadBalancingMonitorResponseSingle = 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 })
}
pub async fn account_load_balancer_monitors_update_monitor_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsUpdateMonitorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}",
args.account_id,
args.monitor_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: LoadBalancingMonitorResponseSingle = 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 })
}
pub async fn account_load_balancer_monitors_patch_monitor_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsPatchMonitorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}",
args.account_id,
args.monitor_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);
}
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: LoadBalancingMonitorResponseSingle = 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 })
}
pub async fn account_load_balancer_monitors_delete_monitor_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsDeleteMonitorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}",
args.account_id,
args.monitor_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: LoadBalancingIdResponse = 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 })
}
pub async fn account_load_balancer_monitors_preview_monitor_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsPreviewMonitorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingPreviewResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}/preview",
args.account_id,
args.monitor_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: LoadBalancingPreviewResponse = 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 })
}
pub async fn account_load_balancer_monitors_list_monitor_references_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsListMonitorReferencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingMonitorReferencesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/monitors/{}/references",
args.account_id,
args.monitor_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: LoadBalancingMonitorReferencesResponse = 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 })
}
pub async fn account_load_balancer_pools_list_pools_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsListPoolsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools",
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("monitor", args.monitor.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: LoadBalancingSchemasResponseCollection = 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 })
}
pub async fn account_load_balancer_pools_create_pool_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsCreatePoolArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools",
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: LoadBalancingSchemasSingleResponse = 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 })
}
pub async fn account_load_balancer_pools_patch_pools_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsPatchPoolsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools",
args.account_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);
}
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: LoadBalancingSchemasResponseCollection = 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 })
}
pub async fn account_load_balancer_pools_pool_details_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsPoolDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}",
args.account_id,
args.pool_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: LoadBalancingSchemasSingleResponse = 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 })
}
pub async fn account_load_balancer_pools_update_pool_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsUpdatePoolArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}",
args.account_id,
args.pool_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: LoadBalancingSchemasSingleResponse = 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 })
}
pub async fn account_load_balancer_pools_patch_pool_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsPatchPoolArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}",
args.account_id,
args.pool_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);
}
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: LoadBalancingSchemasSingleResponse = 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 })
}
pub async fn account_load_balancer_pools_delete_pool_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsDeletePoolArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingSchemasIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}",
args.account_id,
args.pool_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: LoadBalancingSchemasIdResponse = 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 })
}
pub async fn account_load_balancer_pools_pool_health_details_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsPoolHealthDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingHealthDetails>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}/health",
args.account_id,
args.pool_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: LoadBalancingHealthDetails = 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 })
}
pub async fn account_load_balancer_pools_preview_pool_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsPreviewPoolArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingPreviewResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}/preview",
args.account_id,
args.pool_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: LoadBalancingPreviewResponse = 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 })
}
pub async fn account_load_balancer_pools_list_pool_references_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerPoolsListPoolReferencesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingPoolsReferencesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/pools/{}/references",
args.account_id,
args.pool_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: LoadBalancingPoolsReferencesResponse = 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 })
}
pub async fn account_load_balancer_monitors_preview_result_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerMonitorsPreviewResultArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingPreviewResultResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/preview/{}",
args.account_id,
args.preview_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: LoadBalancingPreviewResultResponse = 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 })
}
pub async fn load_balancer_regions_list_regions_request<F>(
client: DynNetClient,
args: &LoadBalancerRegionsListRegionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingRegionComponentsSchemasResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/regions",
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("subdivision_code", args.subdivision_code.as_deref());
builder = builder.query("subdivision_code_a2", args.subdivision_code_a2.as_deref());
builder = builder.query("country_code_a2", args.country_code_a2.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: LoadBalancingRegionComponentsSchemasResponseCollection = 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 })
}
pub async fn load_balancer_regions_get_region_request<F>(
client: DynNetClient,
args: &LoadBalancerRegionsGetRegionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<LoadBalancingComponentsSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/regions/{}",
args.account_id,
args.region_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: LoadBalancingComponentsSchemasSingleResponse = 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 })
}
pub async fn account_load_balancer_search_search_resources_request<F>(
client: DynNetClient,
args: &AccountLoadBalancerSearchSearchResourcesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AccountLoadBalancerSearchSearchResourcesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/load_balancers/search",
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("query", args.query.as_deref());
builder = builder.query("references", args.references.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.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: AccountLoadBalancerSearchSearchResourcesResponse = 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 })
}
pub async fn magic_network_monitoring_configuration_list_account_configuration_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringConfigurationListAccountConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmConfigSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/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);
}
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: MagicVisibilityMnmMnmConfigSingleResponse = 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 })
}
pub async fn magic_network_monitoring_configuration_create_account_configuration_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringConfigurationCreateAccountConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmConfigSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/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);
}
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: MagicVisibilityMnmMnmConfigSingleResponse = 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 })
}
pub async fn magic_network_monitoring_configuration_update_an_entire_account_configuration_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringConfigurationUpdateAnEntireAccountConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmConfigSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/config",
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: MagicVisibilityMnmMnmConfigSingleResponse = 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 })
}
pub async fn magic_network_monitoring_configuration_update_account_configuration_fields_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringConfigurationUpdateAccountConfigurationFieldsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmConfigSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/config",
args.account_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);
}
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: MagicVisibilityMnmMnmConfigSingleResponse = 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 })
}
pub async fn magic_network_monitoring_configuration_delete_account_configuration_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringConfigurationDeleteAccountConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmConfigSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/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);
}
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: MagicVisibilityMnmMnmConfigSingleResponse = 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 })
}
pub async fn magic_network_monitoring_vpc_flows_generate_authentication_token_request<F>(
client: DynNetClient,
args: &MagicNetworkMonitoringVpcFlowsGenerateAuthenticationTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityMnmMnmVpcFlowsSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/mnm/vpc-flows/token",
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: MagicVisibilityMnmMnmVpcFlowsSingleResponse = 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 })
}