#![cfg(feature = "cloudflare_network")]
#![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::AddressingApiResponseCommon;
use super::shared::TunnelApiResponseCommon;
use super::shared::TunnelCreatedAt;
use super::shared::TunnelDeletedAt;
use super::shared::TunnelSubnet;
use super::shared::TunnelSubnetComment;
use super::shared::TunnelSubnetId;
use super::shared::TunnelSubnetIpNetwork;
use super::shared::TunnelSubnetIsDefaultNetwork;
use super::shared::TunnelSubnetName;
use super::shared::TunnelSubnetResponseSingle;
use super::shared::TunnelSubnetType;
use super::shared::ApiResponse;
pub type AddressingApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type AddressingAsnPrependCount = i64;
pub type AddressingAutoAdvertiseWithdraw = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingBgpOnDemand {
pub advertised: Option<bool>,
pub advertised_modified_at: Option<String>,
pub on_demand_enabled: Option<bool>,
pub on_demand_locked: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingBgpPrefixCreate {
pub cidr: String,
}
pub type AddressingBgpPrefixIdentifier = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingBgpPrefixUpdateAdvertisement {
pub asn_prepend_count: Option<i64>,
pub auto_advertise_withdraw: Option<bool>,
pub on_demand: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingBgpSignalOpts {
pub enabled: Option<bool>,
pub modified_at: Option<String>,
}
pub type AddressingBgpSignalingEnabled = bool;
pub type AddressingBgpSignalingModifiedAt = String;
pub type AddressingCidr = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingIpamBgpPrefixes {
pub asn: Option<i64>,
pub asn_prepend_count: Option<i64>,
pub auto_advertise_withdraw: Option<bool>,
pub bgp_signal_opts: Option<AddressingBgpSignalOpts>,
pub cidr: Option<String>,
pub created_at: Option<String>,
pub id: Option<String>,
pub modified_at: Option<String>,
pub on_demand: Option<AddressingBgpOnDemand>,
}
pub type AddressingMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type AddressingModifiedAtNullable = String;
pub type AddressingResponseCollectionBgp =
super::shared::ApiEnvelope<Option<Vec<AddressingIpamBgpPrefixes>>>;
pub type AddressingSchemasAdvertised = bool;
pub type AddressingSchemasAsn = i64;
pub type AddressingSchemasOnDemandEnabled = bool;
pub type AddressingSchemasOnDemandLocked = bool;
pub type AddressingSingleResponseBgp =
super::shared::ApiEnvelope<Option<AddressingIpamBgpPrefixes>>;
pub type AddressingTimestamp = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflareTunnelConfigurationPutConfigurationRequest {
pub config: Option<TunnelConfig>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflareTunnelCreateACloudflareTunnelRequest {
pub config_src: Option<String>,
pub name: String,
pub tunnel_secret: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflareTunnelCreateAWarpConnectorTunnelRequest {
pub ha: Option<bool>,
pub name: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflareTunnelGetACloudflareTunnelManagementTokenRequest {
pub resources: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflareTunnelManualFailoverWarpConnectorTunnelRequest {
pub client_id: String,
}
pub type CloudflareTunnelUpdateACloudflareTunnelRequest = super::shared::NameTunnelSecretObject;
pub type CloudflareTunnelUpdateAWarpConnectorTunnelRequest = super::shared::NameTunnelSecretObject;
pub type ConnectivityServicesGetResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type ConnectivityServicesListResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<serde_json::Value>>>;
pub type ConnectivityServicesPostResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type ConnectivityServicesPutResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type CreateDexRuleResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringDexRule>>;
pub type DeleteDexRuleResponse = super::shared::ApiEnvelope<Option<bool>>;
pub type DexEndpointsHttpTestDetailsResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringHttpDetailsResponse>>;
pub type DexEndpointsHttpTestPercentilesResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringHttpDetailsPercentilesResponse>>;
pub type DexEndpointsListColosResponse =
super::shared::ApiEnvelope<Option<Vec<std::collections::HashMap<String, serde_json::Value>>>>;
pub type DexEndpointsListTestsOverviewResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringTestsResponse>>;
pub type DexEndpointsTestsUniqueDevicesResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringUniqueDevicesResponse>>;
pub type DexEndpointsTracerouteTestDetailsResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringTracerouteDetailsResponse>>;
pub type DexEndpointsTracerouteTestNetworkPathResponse = super::shared::ApiEnvelope<
Option<DigitalExperienceMonitoringTracerouteTestNetworkPathResponse>,
>;
pub type DexEndpointsTracerouteTestPercentilesResponse = super::shared::ApiEnvelope<
Option<DigitalExperienceMonitoringTracerouteDetailsPercentilesResponse>,
>;
pub type DexEndpointsTracerouteTestResultNetworkPathResponse = super::shared::ApiEnvelope<
Option<DigitalExperienceMonitoringTracerouteTestResultNetworkPathResponse>,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringAggregateStat {
#[serde(rename = "avgMs")]
pub avg_ms: Option<i64>,
#[serde(rename = "deltaPct")]
pub delta_pct: Option<f64>,
#[serde(rename = "timePeriod")]
pub time_period: DigitalExperienceMonitoringAggregateTimePeriod,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringAggregateTimePeriod {
pub units: String,
pub value: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringAggregateTimeSlot {
#[serde(rename = "avgMs")]
pub avg_ms: i64,
pub timestamp: String,
}
pub type DigitalExperienceMonitoringApiResponseCollection =
super::shared::AddressingApiResponseCollectionShape;
pub type DigitalExperienceMonitoringApiResponseCollectionCommon =
super::shared::ApiEnvelope<Option<Vec<serde_json::Value>>>;
pub type DigitalExperienceMonitoringApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type DigitalExperienceMonitoringApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type DigitalExperienceMonitoringColo = String;
pub type DigitalExperienceMonitoringColosResponse =
Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringCommandsDevicesResponse {
pub devices: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}
pub type DigitalExperienceMonitoringCpuPctByApp =
Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringCreateRuleBody {
pub description: Option<String>,
#[serde(rename = "match")]
pub r#match: String,
pub name: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDevice {
#[serde(rename = "alwaysOn")]
pub always_on: Option<bool>,
#[serde(rename = "batteryCharging")]
pub battery_charging: Option<bool>,
#[serde(rename = "batteryCycles")]
pub battery_cycles: Option<i64>,
#[serde(rename = "batteryPct")]
pub battery_pct: Option<f64>,
pub colo: String,
#[serde(rename = "connectionType")]
pub connection_type: Option<String>,
#[serde(rename = "cpuPct")]
pub cpu_pct: Option<f64>,
#[serde(rename = "cpuPctByApp")]
pub cpu_pct_by_app: Option<Vec<Vec<std::collections::HashMap<String, serde_json::Value>>>>,
#[serde(rename = "deviceId")]
pub device_id: String,
#[serde(rename = "deviceIpv4")]
pub device_ipv4: Option<DigitalExperienceMonitoringIpInfo>,
#[serde(rename = "deviceIpv6")]
pub device_ipv6: Option<DigitalExperienceMonitoringIpInfo>,
#[serde(rename = "deviceName")]
pub device_name: Option<String>,
#[serde(rename = "diskReadBps")]
pub disk_read_bps: Option<i64>,
#[serde(rename = "diskUsagePct")]
pub disk_usage_pct: Option<f64>,
#[serde(rename = "diskWriteBps")]
pub disk_write_bps: Option<i64>,
#[serde(rename = "dohSubdomain")]
pub doh_subdomain: Option<String>,
#[serde(rename = "estimatedLossPct")]
pub estimated_loss_pct: Option<f64>,
#[serde(rename = "firewallEnabled")]
pub firewall_enabled: Option<bool>,
#[serde(rename = "gatewayIpv4")]
pub gateway_ipv4: Option<DigitalExperienceMonitoringIpInfo>,
#[serde(rename = "gatewayIpv6")]
pub gateway_ipv6: Option<DigitalExperienceMonitoringIpInfo>,
#[serde(rename = "handshakeLatencyMs")]
pub handshake_latency_ms: Option<f64>,
#[serde(rename = "ispIpv4")]
pub isp_ipv4: Option<DigitalExperienceMonitoringIpInfo>,
#[serde(rename = "ispIpv6")]
pub isp_ipv6: Option<DigitalExperienceMonitoringIpInfo>,
pub metal: Option<String>,
pub mode: String,
#[serde(rename = "networkRcvdBps")]
pub network_rcvd_bps: Option<i64>,
#[serde(rename = "networkSentBps")]
pub network_sent_bps: Option<i64>,
#[serde(rename = "networkSsid")]
pub network_ssid: Option<String>,
#[serde(rename = "personEmail")]
pub person_email: Option<String>,
pub platform: String,
#[serde(rename = "ramAvailableKb")]
pub ram_available_kb: Option<i64>,
#[serde(rename = "ramUsedPct")]
pub ram_used_pct: Option<f64>,
#[serde(rename = "ramUsedPctByApp")]
pub ram_used_pct_by_app: Option<Vec<Vec<std::collections::HashMap<String, serde_json::Value>>>>,
pub status: String,
#[serde(rename = "switchLocked")]
pub switch_locked: Option<bool>,
pub timestamp: String,
pub version: String,
#[serde(rename = "wifiStrengthDbm")]
pub wifi_strength_dbm: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDeviceDexTestSchemasData {
pub host: String,
pub kind: String,
pub method: Option<String>,
}
pub type DigitalExperienceMonitoringDeviceDexTestSchemasDescription = String;
pub type DigitalExperienceMonitoringDeviceDexTestSchemasEnabled = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDeviceDexTestSchemasHttp {
pub data: DigitalExperienceMonitoringDeviceDexTestSchemasData,
pub description: Option<String>,
pub enabled: bool,
pub interval: String,
pub name: String,
pub target_policies: Option<Vec<DigitalExperienceMonitoringDexTargetPolicy>>,
pub targeted: Option<bool>,
pub test_id: Option<String>,
}
pub type DigitalExperienceMonitoringDeviceDexTestSchemasInterval = String;
pub type DigitalExperienceMonitoringDeviceDexTestSchemasName = String;
pub type DigitalExperienceMonitoringDeviceDexTestTargetPolicies =
Vec<DigitalExperienceMonitoringDexTargetPolicy>;
pub type DigitalExperienceMonitoringDexDeleteResponseCollection =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
pub type DigitalExperienceMonitoringDexResponseCollection =
super::shared::ApiEnvelope<Option<Vec<DigitalExperienceMonitoringDeviceDexTestSchemasHttp>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDexRule {
pub created_at: String,
pub description: Option<String>,
pub id: String,
#[serde(rename = "match")]
pub r#match: String,
pub name: String,
pub targeted_tests: Option<Vec<DigitalExperienceMonitoringDexTargetedTest>>,
pub updated_at: Option<String>,
}
pub type DigitalExperienceMonitoringDexSingleResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringDeviceDexTestSchemasHttp>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDexTargetPolicy {
pub default: Option<bool>,
pub id: String,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringDexTargetedTest {
pub data: DigitalExperienceMonitoringDeviceDexTestSchemasData,
pub enabled: bool,
pub name: String,
pub test_id: String,
}
pub type DigitalExperienceMonitoringFleetStatusDevicesResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<Vec<DigitalExperienceMonitoringDevice>>,
>;
pub type DigitalExperienceMonitoringFleetStatusLiveResponse =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
pub type DigitalExperienceMonitoringFleetStatusOverTimeResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<std::collections::HashMap<String, serde_json::Value>>,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringGetCommandsQuotaResponse {
pub quota: f64,
pub quota_usage: f64,
pub reset_time: String,
}
pub type DigitalExperienceMonitoringGetCommandsResponse = super::shared::CommandsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringHttpDetailsPercentilesResponse {
#[serde(rename = "dnsResponseTimeMs")]
pub dns_response_time_ms: Option<DigitalExperienceMonitoringPercentiles>,
#[serde(rename = "resourceFetchTimeMs")]
pub resource_fetch_time_ms: Option<DigitalExperienceMonitoringPercentiles>,
#[serde(rename = "serverResponseTimeMs")]
pub server_response_time_ms: Option<DigitalExperienceMonitoringPercentiles>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringHttpDetailsResponse {
pub host: Option<String>,
#[serde(rename = "httpStats")]
pub http_stats: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "httpStatsByColo")]
pub http_stats_by_colo: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub interval: Option<String>,
pub kind: Option<serde_json::Value>,
pub method: Option<String>,
pub name: Option<String>,
pub target_policies: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub targeted: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringIpInfo {
pub address: Option<String>,
pub asn: Option<i64>,
pub aso: Option<String>,
pub location: Option<std::collections::HashMap<String, serde_json::Value>>,
pub netmask: Option<String>,
pub version: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringListRulesResponse {
pub rules: Option<Vec<DigitalExperienceMonitoringDexRule>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringLiveStat {
#[serde(rename = "uniqueDevicesTotal")]
pub unique_devices_total: Option<f64>,
pub value: Option<String>,
}
pub type DigitalExperienceMonitoringMessages =
Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type DigitalExperienceMonitoringMode = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringPatchRuleBody {
pub description: Option<String>,
#[serde(rename = "match")]
pub r#match: Option<String>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringPercentiles {
pub p50: Option<f64>,
pub p90: Option<f64>,
pub p95: Option<f64>,
pub p99: Option<f64>,
}
pub type DigitalExperienceMonitoringPersonEmail = String;
pub type DigitalExperienceMonitoringPlatform = String;
pub type DigitalExperienceMonitoringPostCommandsResponse = super::shared::CommandsObject;
pub type DigitalExperienceMonitoringRamUsedPctByApp =
Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringSchemasAggregateStat {
pub timestamp: Option<String>,
#[serde(rename = "uniqueDevicesTotal")]
pub unique_devices_total: Option<f64>,
pub value: Option<String>,
}
pub type DigitalExperienceMonitoringSchemasTestId = String;
pub type DigitalExperienceMonitoringStatus = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTestStatOverTime {
pub avg: Option<i64>,
pub max: Option<i64>,
pub min: Option<i64>,
pub slots: Vec<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTestStatPctOverTime {
pub avg: Option<f64>,
pub max: Option<f64>,
pub min: Option<f64>,
pub slots: Vec<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTestsResponse {
#[serde(rename = "overviewMetrics")]
pub overview_metrics: std::collections::HashMap<String, serde_json::Value>,
pub tests: Vec<std::collections::HashMap<String, serde_json::Value>>,
}
pub type DigitalExperienceMonitoringTimestamp = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTimingAggregates {
#[serde(rename = "avgMs")]
pub avg_ms: Option<i64>,
pub history: Vec<DigitalExperienceMonitoringAggregateStat>,
#[serde(rename = "overTime")]
pub over_time: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTracerouteDetailsPercentilesResponse {
#[serde(rename = "hopsCount")]
pub hops_count: Option<DigitalExperienceMonitoringPercentiles>,
#[serde(rename = "packetLossPct")]
pub packet_loss_pct: Option<DigitalExperienceMonitoringPercentiles>,
#[serde(rename = "roundTripTimeMs")]
pub round_trip_time_ms: Option<DigitalExperienceMonitoringPercentiles>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTracerouteDetailsResponse {
pub host: String,
pub interval: String,
pub kind: serde_json::Value,
pub name: String,
pub target_policies: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub targeted: Option<bool>,
#[serde(rename = "tracerouteStats")]
pub traceroute_stats: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "tracerouteStatsByColo")]
pub traceroute_stats_by_colo: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTracerouteTestNetworkPathResponse {
#[serde(rename = "deviceName")]
pub device_name: Option<String>,
pub id: String,
pub interval: Option<String>,
pub kind: Option<serde_json::Value>,
pub name: Option<String>,
#[serde(rename = "networkPath")]
pub network_path: Option<std::collections::HashMap<String, serde_json::Value>>,
pub url: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringTracerouteTestResultNetworkPathResponse {
#[serde(rename = "deviceName")]
pub device_name: Option<String>,
pub hops: Vec<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "resultId")]
pub result_id: String,
#[serde(rename = "testId")]
pub test_id: Option<String>,
#[serde(rename = "testName")]
pub test_name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringUniqueDevicesResponse {
#[serde(rename = "uniqueDevicesTotal")]
pub unique_devices_total: i64,
}
pub type DigitalExperienceMonitoringUniqueDevicesTotal = f64;
pub type DigitalExperienceMonitoringUuid = String;
pub type DigitalExperienceMonitoringVersion = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringWarpConfigChangeEvent {
pub device_id: Option<String>,
pub device_registration: Option<String>,
pub from: Option<DigitalExperienceMonitoringWarpConfigDetails>,
pub hostname: Option<String>,
pub serial_number: Option<String>,
pub timestamp: Option<String>,
pub to: Option<DigitalExperienceMonitoringWarpConfigDetails>,
pub user_email: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringWarpConfigDetails {
pub account_name: Option<String>,
pub account_tag: Option<String>,
pub config_name: Option<String>,
}
pub type DigitalExperienceMonitoringWarpEventsResponse = Vec<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DigitalExperienceMonitoringWarpToggleChangeEvent {
pub account_name: Option<String>,
pub account_tag: Option<String>,
pub device_id: Option<String>,
pub device_registration: Option<String>,
pub hostname: Option<String>,
pub serial_number: Option<String>,
pub timestamp: Option<String>,
pub toggle: Option<String>,
pub user_email: Option<String>,
}
pub type GetCommandsEligibleDevicesResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<DigitalExperienceMonitoringCommandsDevicesResponse>,
>;
pub type GetCommandsQuotaResponse = super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<DigitalExperienceMonitoringGetCommandsQuotaResponse>,
>;
pub type GetCommandsResponse = super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<DigitalExperienceMonitoringGetCommandsResponse>,
>;
pub type GetDexRuleResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringDexRule>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetEventAggregateResponse {
#[serde(rename = "aggregateBy")]
pub aggregate_by: String,
pub aggregations: Vec<serde_json::Value>,
#[serde(rename = "dateRange")]
pub date_range: Option<GetEventAggregateResponseDateRange>,
pub total: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetEventAggregateResponseDateRange {
#[serde(rename = "endDate")]
pub end_date: Option<String>,
#[serde(rename = "startDate")]
pub start_date: Option<String>,
}
pub type InfraApiResponseCollection = super::shared::AddressingApiResponseCollectionShape;
pub type InfraApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type InfraApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraApiTlsSettings {
pub cert_verification_mode: String,
}
pub type InfraConnectivityServiceArray = Vec<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraDualStackHost {
pub ipv4: String,
pub ipv6: String,
pub network: InfraNetwork,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraHostnameHost {
pub hostname: String,
pub resolver_network: InfraResolverNetwork,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraHttpServiceConfig {
pub created_at: Option<String>,
pub host: serde_json::Value,
pub http_port: Option<i64>,
pub https_port: Option<i64>,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub service_id: Option<String>,
pub tls_settings: Option<serde_json::Value>,
pub updated_at: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraIPv4Host {
pub ipv4: String,
pub network: InfraNetwork,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraIPv6Host {
pub ipv6: String,
pub network: InfraNetwork,
}
pub type InfraMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraNetwork {
pub tunnel_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraResolverNetwork {
pub resolver_ips: Option<Vec<String>>,
pub tunnel_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraServiceCommon {
pub created_at: Option<String>,
pub host: serde_json::Value,
pub name: String,
pub service_id: Option<String>,
pub tls_settings: Option<serde_json::Value>,
#[serde(rename = "type")]
pub r#type: String,
pub updated_at: Option<String>,
}
pub type InfraServiceConfig = serde_json::Value;
pub type InfraServiceHost = serde_json::Value;
pub type InfraServiceType = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct InfraTcpServiceConfig {
pub app_protocol: Option<String>,
pub created_at: Option<String>,
pub host: serde_json::Value,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub service_id: Option<String>,
pub tcp_port: Option<i64>,
pub tls_settings: Option<serde_json::Value>,
pub updated_at: Option<String>,
}
pub type ListDexRulesResponse = super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<DigitalExperienceMonitoringListRulesResponse>,
>;
pub type ListWarpChangeEventsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<serde_json::Value>>>;
pub type MagicAllowNullCipher = bool;
pub type MagicApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicApiResponseSingle = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicAutomaticReturnRouting = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicBgpConfig {
pub customer_asn: i64,
pub extra_prefixes: Option<Vec<String>>,
pub md5_key: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicBgpStatusWithState {
pub bgp_state: Option<String>,
pub cf_speaker_ip: Option<String>,
pub cf_speaker_port: Option<i64>,
pub customer_speaker_ip: Option<String>,
pub customer_speaker_port: Option<i64>,
pub state: String,
pub tcp_established: bool,
pub updated_at: String,
}
pub type MagicCloudflareGreEndpoint = String;
pub type MagicCloudflareIpsecEndpoint = String;
pub type MagicComponentsSchemasDescription = String;
pub type MagicComponentsSchemasModifiedTunnelsCollectionResponse =
super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicComponentsSchemasName = String;
pub type MagicComponentsSchemasTunnelModifiedResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicComponentsSchemasTunnelSingleResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicComponentsSchemasTunnelsCollectionResponse =
super::shared::ApiEnvelope<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicCreateGreTunnelRequest {
pub automatic_return_routing: Option<bool>,
pub bgp: Option<MagicBgpConfig>,
pub cloudflare_gre_endpoint: String,
pub customer_gre_endpoint: String,
pub description: Option<String>,
pub health_check: Option<MagicTunnelHealthCheck>,
pub interface_address: String,
pub interface_address6: Option<String>,
pub mtu: Option<i64>,
pub name: String,
pub ttl: Option<i64>,
}
pub type MagicCreateGreTunnelResponse = super::shared::ApiEnvelope<MagicGreTunnel>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicCustomRemoteIdentities {
pub fqdn_id: Option<String>,
}
pub type MagicCustomerGreEndpoint = String;
pub type MagicCustomerIpsecEndpoint = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicGre {
pub cloudflare_endpoint: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicGreTunnel {
pub automatic_return_routing: Option<bool>,
pub bgp: Option<MagicBgpConfig>,
pub bgp_status: Option<MagicBgpStatusWithState>,
pub cloudflare_gre_endpoint: String,
pub created_on: Option<String>,
pub customer_gre_endpoint: String,
pub description: Option<String>,
pub health_check: Option<MagicTunnelHealthCheck>,
pub id: String,
pub interface_address: String,
pub interface_address6: Option<String>,
pub modified_on: Option<String>,
pub mtu: Option<i64>,
pub name: String,
pub ttl: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicGreTunnelAddSingleRequest {
pub automatic_return_routing: Option<bool>,
pub cloudflare_gre_endpoint: String,
pub customer_gre_endpoint: String,
pub description: Option<String>,
pub health_check: Option<MagicTunnelHealthCheck>,
pub interface_address: String,
pub interface_address6: Option<String>,
pub mtu: Option<i64>,
pub name: String,
pub ttl: Option<i64>,
}
pub type MagicGreTunnelName = String;
pub type MagicGreTunnelUpdateRequest = MagicGreTunnelAddSingleRequest;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicHealthCheckBase {
pub enabled: Option<bool>,
pub rate: Option<String>,
pub target: Option<serde_json::Value>,
#[serde(rename = "type")]
pub r#type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicInterconnect {
pub automatic_return_routing: Option<bool>,
pub colo_name: Option<String>,
pub created_on: Option<String>,
pub description: Option<String>,
pub gre: Option<MagicGre>,
pub health_check: Option<MagicInterconnectHealthCheck>,
pub id: Option<String>,
pub interface_address: Option<String>,
pub interface_address6: Option<String>,
pub modified_on: Option<String>,
pub mtu: Option<i64>,
pub name: Option<String>,
pub virtual_port_reservation_id: Option<serde_json::Value>,
}
pub type MagicInterconnectComponentsSchemasDescription = String;
pub type MagicInterconnectHealthCheck = MagicHealthCheckBase;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicInterconnectTunnelUpdateRequest {
pub automatic_return_routing: Option<bool>,
pub description: Option<String>,
pub gre: Option<MagicGre>,
pub health_check: Option<MagicInterconnectHealthCheck>,
pub interface_address: Option<String>,
pub interface_address6: Option<String>,
pub mtu: Option<i64>,
pub name: Option<String>,
}
pub type MagicInterfaceAddress = String;
pub type MagicInterfaceAddress6 = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicIpsecTunnel {
pub allow_null_cipher: Option<bool>,
pub automatic_return_routing: Option<bool>,
pub bgp: Option<MagicBgpConfig>,
pub bgp_status: Option<MagicBgpStatusWithState>,
pub cloudflare_endpoint: String,
pub created_on: Option<String>,
pub custom_remote_identities: Option<MagicCustomRemoteIdentities>,
pub customer_endpoint: Option<String>,
pub description: Option<String>,
pub health_check: Option<MagicTunnelHealthCheck>,
pub id: String,
pub interface_address: String,
pub interface_address6: Option<String>,
pub modified_on: Option<String>,
pub name: String,
pub psk_metadata: Option<MagicPskMetadata>,
pub replay_protection: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicIpsecTunnelAddRequest {
pub automatic_return_routing: Option<bool>,
pub bgp: Option<MagicBgpConfig>,
pub cloudflare_endpoint: String,
pub custom_remote_identities: Option<MagicCustomRemoteIdentities>,
pub customer_endpoint: Option<String>,
pub description: Option<String>,
pub health_check: Option<MagicTunnelHealthCheck>,
pub interface_address: String,
pub interface_address6: Option<String>,
pub name: String,
pub psk: Option<String>,
pub replay_protection: Option<bool>,
}
pub type MagicIpsecTunnelAddSingleRequest = MagicIpsecTunnelAddRequest;
pub type MagicIpsecTunnelName = String;
pub type MagicMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicModifiedTunnelsCollectionResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicMtu = i64;
pub type MagicPsk = String;
pub type MagicPskGenerationResponse = super::shared::ApiEnvelope<serde_json::Value>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicPskMetadata {
pub last_generated_on: Option<String>,
}
pub type MagicReplayProtection = bool;
pub type MagicSchemasCreateIpsecTunnelResponse = super::shared::ApiEnvelope<MagicIpsecTunnel>;
pub type MagicSchemasCreatedOn = String;
pub type MagicSchemasDescription = String;
pub type MagicSchemasIdentifier = String;
pub type MagicSchemasModifiedOn = String;
pub type MagicSchemasModifiedTunnelsCollectionResponse =
super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicSchemasMtu = i64;
pub type MagicSchemasTunnelDeletedResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicSchemasTunnelModifiedResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicSchemasTunnelSingleResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicSchemasTunnelsCollectionResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicTtl = i64;
pub type MagicTunnelDeletedResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicTunnelHealthCheck {
pub direction: Option<String>,
pub enabled: Option<bool>,
#[serde(rename = "type")]
pub r#type: Option<String>,
pub rate: Option<String>,
pub target: Option<serde_json::Value>,
}
pub type MagicTunnelModifiedResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicTunnelSingleResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicTunnelsCollectionResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type NscAccountTag = String;
pub type NscApiBandwidth = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscBgpControl {
pub customer_asn: i64,
pub extra_prefixes: Vec<String>,
pub md5_key: Option<String>,
}
pub type NscCloudflareSite = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscCni {
pub account: String,
pub bgp: Option<NscBgpControl>,
pub cust_ip: String,
pub id: String,
pub interconnect: String,
pub magic: NscMagicSettings,
pub p2p_ip: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscCniCreate {
pub account: String,
pub bgp: Option<NscBgpControl>,
pub interconnect: String,
pub magic: NscMagicSettings,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscCniList {
pub items: Vec<NscCni>,
pub next: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscFacilityInfo {
pub address: Vec<String>,
pub name: String,
}
pub type NscInterconnect = serde_json::Value;
pub type NscInterconnectCreate = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscInterconnectCreateGcpPartnerBody {
pub account: String,
pub bandwidth: String,
pub pairing_key: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscInterconnectCreatePhysicalBody {
pub account: String,
#[serde(rename = "type")]
pub r#type: String,
pub slot_id: String,
pub speed: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscInterconnectGcpPartnerBody {
pub account: String,
pub name: String,
pub owner: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
pub region: String,
pub speed: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscInterconnectList {
pub items: Vec<serde_json::Value>,
pub next: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscInterconnectPhysicalBody {
pub account: String,
pub facility: NscFacilityInfo,
pub name: String,
pub owner: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
pub site: String,
pub slot_id: String,
pub speed: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscMagicSettings {
pub conduit_name: String,
pub description: String,
pub mtu: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscSettings {
pub default_asn: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscSettingsRequest {
pub default_asn: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscSlotInfo {
pub account: Option<String>,
pub facility: NscFacilityInfo,
pub id: String,
pub occupied: bool,
pub site: String,
pub speed: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NscSlotList {
pub items: Vec<NscSlotInfo>,
pub next: Option<i64>,
}
pub type NscStatusInfo = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostCommandsRequest {
pub commands: Vec<PostCommandsRequestCommandsItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostCommandsRequestCommandsItem {
pub command_args: Option<PostCommandsRequestCommandsItemCommandArgs>,
pub command_type: String,
pub device_id: String,
pub registration_id: Option<String>,
pub user_email: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostCommandsRequestCommandsItemCommandArgs {
pub interfaces: Option<Vec<String>>,
#[serde(rename = "max-file-size-mb")]
pub max_file_size_mb: Option<f64>,
#[serde(rename = "packet-size-bytes")]
pub packet_size_bytes: Option<f64>,
#[serde(rename = "test-all-routes")]
pub test_all_routes: Option<bool>,
#[serde(rename = "time-limit-min")]
pub time_limit_min: Option<f64>,
}
pub type PostCommandsResponse = super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<DigitalExperienceMonitoringPostCommandsResponse>,
>;
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 R2SlurperConnectivityResponse {
#[serde(rename = "connectivityStatus")]
pub connectivity_status: Option<String>,
}
pub type R2SlurperGCSLikeCredsSchema = super::shared::ClientEmailPrivateKeyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperGCSSourceSchema {
pub bucket: String,
pub keys: Option<Vec<String>>,
#[serde(rename = "pathPrefix")]
pub path_prefix: Option<String>,
pub secret: R2SlurperGCSLikeCredsSchema,
pub vendor: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperJobProgressResponse {
#[serde(rename = "createdAt")]
pub created_at: Option<String>,
#[serde(rename = "failedObjects")]
pub failed_objects: Option<i64>,
pub id: Option<String>,
pub objects: Option<i64>,
#[serde(rename = "skippedObjects")]
pub skipped_objects: Option<i64>,
pub status: Option<String>,
#[serde(rename = "transferredObjects")]
pub transferred_objects: Option<i64>,
}
pub type R2SlurperJobStatus = String;
pub type R2SlurperJurisdiction = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperR2SourceSchema {
pub bucket: String,
pub jurisdiction: Option<String>,
pub keys: Option<Vec<String>>,
#[serde(rename = "pathPrefix")]
pub path_prefix: Option<String>,
pub secret: R2SlurperS3LikeCredsSchema,
pub vendor: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperR2TargetSchema {
pub bucket: String,
pub jurisdiction: Option<String>,
pub secret: R2SlurperS3LikeCredsSchema,
pub vendor: String,
}
pub type R2SlurperS3LikeCredsSchema = super::shared::AccessKeyIdSecretAccessKeyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct R2SlurperS3SourceSchema {
pub bucket: String,
pub endpoint: Option<String>,
pub keys: Option<Vec<String>>,
#[serde(rename = "pathPrefix")]
pub path_prefix: Option<String>,
pub region: Option<String>,
pub secret: R2SlurperS3LikeCredsSchema,
pub vendor: String,
}
pub type R2SlurperSourceJobSchema = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpHijacksEventsResponse {
pub result: RadarGetBgpHijacksEventsResponseResult,
pub result_info: RadarGetBgpHijacksEventsResponseResultInfo,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpHijacksEventsResponseResult {
pub asn_info: Vec<RadarGetBgpHijacksEventsResponseResultAsnInfoItem>,
pub events: Vec<RadarGetBgpHijacksEventsResponseResultEventsItem>,
pub total_monitors: i64,
}
pub type RadarGetBgpHijacksEventsResponseResultAsnInfoItem =
super::shared::AsnCountryCodeOrgNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpHijacksEventsResponseResultEventsItem {
pub confidence_score: i64,
pub duration: i64,
pub event_type: i64,
pub hijack_msgs_count: i64,
pub hijacker_asn: i64,
pub hijacker_country: String,
pub id: i64,
pub is_stale: bool,
pub max_hijack_ts: String,
pub max_msg_ts: String,
pub min_hijack_ts: String,
pub on_going_count: i64,
pub peer_asns: Vec<i64>,
pub peer_ip_count: i64,
pub prefixes: Vec<String>,
pub tags: Vec<RadarGetBgpHijacksEventsResponseResultEventsItemTagsItem>,
pub victim_asns: Vec<i64>,
pub victim_countries: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpHijacksEventsResponseResultEventsItemTagsItem {
pub name: String,
pub score: i64,
}
pub type RadarGetBgpHijacksEventsResponseResultInfo =
super::shared::AiSearchInstanceListJobLogsResponseResultInfoShape;
pub type RadarGetBgpIpsTimeseriesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpIpsTimeseriesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResult {
pub meta: RadarGetBgpIpsTimeseriesResponseResultMeta,
pub serie_0: RadarGetBgpIpsTimeseriesResponseResultSerie0,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMeta {
#[serde(rename = "aggInterval")]
pub agg_interval: String,
#[serde(rename = "confidenceInfo")]
pub confidence_info: RadarGetBgpIpsTimeseriesResponseResultMetaConfidenceInfo,
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetBgpIpsTimeseriesResponseResultMetaDateRangeItem>,
pub delay: Option<RadarGetBgpIpsTimeseriesResponseResultMetaDelay>,
#[serde(rename = "lastUpdated")]
pub last_updated: String,
pub normalization: String,
pub units: Vec<RadarGetBgpIpsTimeseriesResponseResultMetaUnitsItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaConfidenceInfo {
pub annotations: Vec<RadarGetBgpIpsTimeseriesResponseResultMetaConfidenceInfoAnnotationsItem>,
pub level: i64,
}
pub type RadarGetBgpIpsTimeseriesResponseResultMetaConfidenceInfoAnnotationsItem =
super::shared::RadarGetAiBotsSummaryResponseResultMetaConfidenceInfoAnnotationsItemShape;
pub type RadarGetBgpIpsTimeseriesResponseResultMetaDateRangeItem =
super::shared::EndTimeStartTimeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaDelay {
pub asn_data: RadarGetBgpIpsTimeseriesResponseResultMetaDelayAsnData,
pub country_data: RadarGetBgpIpsTimeseriesResponseResultMetaDelayCountryData,
pub healthy: bool,
#[serde(rename = "nowTs")]
pub now_ts: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaDelayAsnData {
#[serde(rename = "delaySecs")]
pub delay_secs: f64,
#[serde(rename = "delayStr")]
pub delay_str: String,
pub healthy: bool,
pub latest: RadarGetBgpIpsTimeseriesResponseResultMetaDelayAsnDataLatest,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaDelayAsnDataLatest {
pub entries_count: f64,
pub path: String,
pub timestamp: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaDelayCountryData {
#[serde(rename = "delaySecs")]
pub delay_secs: f64,
#[serde(rename = "delayStr")]
pub delay_str: String,
pub healthy: bool,
pub latest: RadarGetBgpIpsTimeseriesResponseResultMetaDelayCountryDataLatest,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultMetaDelayCountryDataLatest {
pub count: f64,
pub timestamp: f64,
}
pub type RadarGetBgpIpsTimeseriesResponseResultMetaUnitsItem = super::shared::NameValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesResponseResultSerie0 {
pub ipv4: Vec<String>,
pub ipv6: Vec<String>,
pub timestamps: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpPfx2AsMoasResponseResult {
pub meta: RadarGetBgpPfx2AsMoasResponseResultMeta,
pub moas: Vec<RadarGetBgpPfx2AsMoasResponseResultMoasItem>,
}
pub type RadarGetBgpPfx2AsMoasResponseResultMeta = super::shared::DataTimeQueryTimeTotalPeersObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpPfx2AsMoasResponseResultMoasItem {
pub origins: Vec<RadarGetBgpPfx2AsMoasResponseResultMoasItemOriginsItem>,
pub prefix: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpPfx2AsMoasResponseResultMoasItemOriginsItem {
pub origin: i64,
pub peer_count: i64,
pub rpki_validation: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpPfx2AsResponseResult {
pub meta: RadarGetBgpPfx2AsResponseResultMeta,
pub prefix_origins: Vec<RadarGetBgpPfx2AsResponseResultPrefixOriginsItem>,
}
pub type RadarGetBgpPfx2AsResponseResultMeta = super::shared::DataTimeQueryTimeTotalPeersObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpPfx2AsResponseResultPrefixOriginsItem {
pub origin: i64,
pub peer_count: i64,
pub prefix: String,
pub rpki_validation: String,
}
pub type RadarGetBgpPfx2asMoasResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpPfx2AsMoasResponseResult>;
pub type RadarGetBgpPfx2asResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpPfx2AsResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRouteLeakEventsResponse {
pub result: RadarGetBgpRouteLeakEventsResponseResult,
pub result_info: RadarGetBgpRouteLeakEventsResponseResultInfo,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRouteLeakEventsResponseResult {
pub asn_info: Vec<RadarGetBgpRouteLeakEventsResponseResultAsnInfoItem>,
pub events: Vec<RadarGetBgpRouteLeakEventsResponseResultEventsItem>,
}
pub type RadarGetBgpRouteLeakEventsResponseResultAsnInfoItem =
super::shared::AsnCountryCodeOrgNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRouteLeakEventsResponseResultEventsItem {
pub countries: Vec<String>,
pub detected_ts: String,
pub finished: bool,
pub id: i64,
pub leak_asn: i64,
pub leak_count: i64,
pub leak_seg: Vec<i64>,
pub leak_type: i64,
pub max_ts: String,
pub min_ts: String,
pub origin_count: i64,
pub peer_count: i64,
pub prefix_count: i64,
}
pub type RadarGetBgpRouteLeakEventsResponseResultInfo =
super::shared::AiSearchInstanceListJobLogsResponseResultInfoShape;
pub type RadarGetBgpRoutesAsnsResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRoutesAsnsResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesAsnsResponseResult {
pub asns: Vec<RadarGetBgpRoutesAsnsResponseResultAsnsItem>,
pub meta: RadarGetBgpRoutesAsnsResponseResultMeta,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesAsnsResponseResultAsnsItem {
pub asn: i64,
#[serde(rename = "coneSize")]
pub cone_size: i64,
pub country: String,
#[serde(rename = "ipv4Count")]
pub ipv4_count: i64,
#[serde(rename = "ipv6Count")]
pub ipv6_count: String,
pub name: String,
#[serde(rename = "pfxsCount")]
pub pfxs_count: i64,
#[serde(rename = "rpkiInvalid")]
pub rpki_invalid: i64,
#[serde(rename = "rpkiUnknown")]
pub rpki_unknown: i64,
#[serde(rename = "rpkiValid")]
pub rpki_valid: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesAsnsResponseResultMeta {
#[serde(rename = "dataTime")]
pub data_time: String,
#[serde(rename = "queryTime")]
pub query_time: String,
#[serde(rename = "totalPeers")]
pub total_peers: i64,
}
pub type RadarGetBgpRoutesStatsResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRoutesStatsResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesStatsResponseResult {
pub meta: RadarGetBgpRoutesStatsResponseResultMeta,
pub stats: RadarGetBgpRoutesStatsResponseResultStats,
}
pub type RadarGetBgpRoutesStatsResponseResultMeta =
super::shared::DataTimeQueryTimeTotalPeersObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRoutesStatsResponseResultStats {
pub distinct_origins: i64,
pub distinct_origins_ipv4: i64,
pub distinct_origins_ipv6: i64,
pub distinct_prefixes: i64,
pub distinct_prefixes_ipv4: i64,
pub distinct_prefixes_ipv6: i64,
pub routes_invalid: i64,
pub routes_invalid_ipv4: i64,
pub routes_invalid_ipv6: i64,
pub routes_total: i64,
pub routes_total_ipv4: i64,
pub routes_total_ipv6: i64,
pub routes_unknown: i64,
pub routes_unknown_ipv4: i64,
pub routes_unknown_ipv6: i64,
pub routes_valid: i64,
pub routes_valid_ipv4: i64,
pub routes_valid_ipv6: i64,
}
pub type RadarGetBgpRpkiAspaChangesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRpkiAspaChangesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaChangesResponseResult {
#[serde(rename = "asnInfo")]
pub asn_info: RadarGetBgpRpkiAspaChangesResponseResultAsnInfo,
pub changes: Vec<RadarGetBgpRpkiAspaChangesResponseResultChangesItem>,
pub meta: RadarGetBgpRpkiAspaChangesResponseResultMeta,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaChangesResponseResultAsnInfo {
#[serde(rename = "13335")]
pub field_13335: RadarGetBgpRpkiAspaChangesResponseResultAsnInfo13335,
}
pub type RadarGetBgpRpkiAspaChangesResponseResultAsnInfo13335 = super::shared::AsnCountryNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaChangesResponseResultChangesItem {
#[serde(rename = "customersAdded")]
pub customers_added: i64,
#[serde(rename = "customersRemoved")]
pub customers_removed: i64,
pub date: String,
pub entries: Vec<RadarGetBgpRpkiAspaChangesResponseResultChangesItemEntriesItem>,
#[serde(rename = "providersAdded")]
pub providers_added: i64,
#[serde(rename = "providersRemoved")]
pub providers_removed: i64,
#[serde(rename = "totalCount")]
pub total_count: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaChangesResponseResultChangesItemEntriesItem {
#[serde(rename = "customerAsn")]
pub customer_asn: i64,
pub providers: Vec<i64>,
#[serde(rename = "type")]
pub r#type: String,
}
pub type RadarGetBgpRpkiAspaChangesResponseResultMeta = super::shared::DataTimeQueryTimeObject;
pub type RadarGetBgpRpkiAspaSnapshotResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRpkiAspaSnapshotResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaSnapshotResponseResult {
#[serde(rename = "asnInfo")]
pub asn_info: RadarGetBgpRpkiAspaSnapshotResponseResultAsnInfo,
#[serde(rename = "aspaObjects")]
pub aspa_objects: Vec<RadarGetBgpRpkiAspaSnapshotResponseResultAspaObjectsItem>,
pub meta: RadarGetBgpRpkiAspaSnapshotResponseResultMeta,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaSnapshotResponseResultAsnInfo {
#[serde(rename = "13335")]
pub field_13335: RadarGetBgpRpkiAspaSnapshotResponseResultAsnInfo13335,
}
pub type RadarGetBgpRpkiAspaSnapshotResponseResultAsnInfo13335 =
super::shared::AsnCountryNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaSnapshotResponseResultAspaObjectsItem {
#[serde(rename = "customerAsn")]
pub customer_asn: i64,
pub providers: Vec<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaSnapshotResponseResultMeta {
#[serde(rename = "dataTime")]
pub data_time: String,
#[serde(rename = "queryTime")]
pub query_time: String,
#[serde(rename = "totalCount")]
pub total_count: i64,
}
pub type RadarGetBgpRpkiAspaTimeseriesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpRpkiAspaTimeseriesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaTimeseriesResponseResult {
pub meta: RadarGetBgpRpkiAspaTimeseriesResponseResultMeta,
pub serie_0: RadarGetBgpRpkiAspaTimeseriesResponseResultSerie0,
}
pub type RadarGetBgpRpkiAspaTimeseriesResponseResultMeta = super::shared::DataTimeQueryTimeObject;
pub type RadarGetBgpRpkiAspaTimeseriesResponseResultSerie0 = super::shared::TimestampsValuesObject;
pub type RadarGetBgpTimeseriesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpTimeseriesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTimeseriesResponseResult {
pub meta: RadarGetBgpTimeseriesResponseResultMeta,
pub serie_0: RadarGetBgpTimeseriesResponseResultSerie0,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTimeseriesResponseResultMeta {
#[serde(rename = "aggInterval")]
pub agg_interval: String,
#[serde(rename = "confidenceInfo")]
pub confidence_info: RadarGetBgpTimeseriesResponseResultMetaConfidenceInfo,
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetBgpTimeseriesResponseResultMetaDateRangeItem>,
#[serde(rename = "lastUpdated")]
pub last_updated: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTimeseriesResponseResultMetaConfidenceInfo {
pub annotations: Vec<RadarGetBgpTimeseriesResponseResultMetaConfidenceInfoAnnotationsItem>,
pub level: i64,
}
pub type RadarGetBgpTimeseriesResponseResultMetaConfidenceInfoAnnotationsItem =
super::shared::RadarGetAiBotsSummaryResponseResultMetaConfidenceInfoAnnotationsItemShape;
pub type RadarGetBgpTimeseriesResponseResultMetaDateRangeItem =
super::shared::EndTimeStartTimeObject;
pub type RadarGetBgpTimeseriesResponseResultSerie0 = super::shared::TimestampsValuesObject;
pub type RadarGetBgpTopAsesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpTopAsesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopAsesResponseResult {
pub meta: RadarGetBgpTopAsesResponseResultMeta,
pub top_0: Vec<RadarGetBgpTopAsesResponseResultTop0Item>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopAsesResponseResultMeta {
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetBgpTopAsesResponseResultMetaDateRangeItem>,
}
pub type RadarGetBgpTopAsesResponseResultMetaDateRangeItem = super::shared::EndTimeStartTimeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopAsesResponseResultTop0Item {
#[serde(rename = "ASName")]
pub as_name: String,
pub asn: i64,
pub value: String,
}
pub type RadarGetBgpTopAsnsByPrefixesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpTopAsnsByPrefixesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopAsnsByPrefixesResponseResult {
pub asns: Vec<RadarGetBgpTopAsnsByPrefixesResponseResultAsnsItem>,
pub meta: RadarGetBgpTopAsnsByPrefixesResponseResultMeta,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopAsnsByPrefixesResponseResultAsnsItem {
pub asn: i64,
pub country: String,
pub name: String,
pub pfxs_count: i64,
}
pub type RadarGetBgpTopAsnsByPrefixesResponseResultMeta =
super::shared::DataTimeQueryTimeTotalPeersObject;
pub type RadarGetBgpTopPrefixesResponse =
super::shared::ApiEnvelopeSuccess<RadarGetBgpTopPrefixesResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopPrefixesResponseResult {
pub meta: RadarGetBgpTopPrefixesResponseResultMeta,
pub top_0: Vec<RadarGetBgpTopPrefixesResponseResultTop0Item>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopPrefixesResponseResultMeta {
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetBgpTopPrefixesResponseResultMetaDateRangeItem>,
}
pub type RadarGetBgpTopPrefixesResponseResultMetaDateRangeItem =
super::shared::EndTimeStartTimeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetBgpTopPrefixesResponseResultTop0Item {
pub prefix: String,
pub value: String,
}
pub type RadarGetQualityIndexSummaryResponse =
super::shared::ApiEnvelopeSuccess<RadarGetQualityIndexSummaryResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexSummaryResponseResult {
pub meta: RadarGetQualityIndexSummaryResponseResultMeta,
pub summary_0: RadarGetQualityIndexSummaryResponseResultSummary0,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexSummaryResponseResultMeta {
#[serde(rename = "confidenceInfo")]
pub confidence_info: RadarGetQualityIndexSummaryResponseResultMetaConfidenceInfo,
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetQualityIndexSummaryResponseResultMetaDateRangeItem>,
#[serde(rename = "lastUpdated")]
pub last_updated: String,
pub normalization: String,
pub units: Vec<RadarGetQualityIndexSummaryResponseResultMetaUnitsItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexSummaryResponseResultMetaConfidenceInfo {
pub annotations:
Vec<RadarGetQualityIndexSummaryResponseResultMetaConfidenceInfoAnnotationsItem>,
pub level: i64,
}
pub type RadarGetQualityIndexSummaryResponseResultMetaConfidenceInfoAnnotationsItem =
super::shared::RadarGetAiBotsSummaryResponseResultMetaConfidenceInfoAnnotationsItemShape;
pub type RadarGetQualityIndexSummaryResponseResultMetaDateRangeItem =
super::shared::EndTimeStartTimeObject;
pub type RadarGetQualityIndexSummaryResponseResultMetaUnitsItem = super::shared::NameValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexSummaryResponseResultSummary0 {
pub p25: String,
pub p50: String,
pub p75: String,
}
pub type RadarGetQualityIndexTimeseriesGroupResponse =
super::shared::ApiEnvelopeSuccess<RadarGetQualityIndexTimeseriesGroupResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexTimeseriesGroupResponseResult {
pub meta: RadarGetQualityIndexTimeseriesGroupResponseResultMeta,
pub serie_0: RadarGetQualityIndexTimeseriesGroupResponseResultSerie0,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexTimeseriesGroupResponseResultMeta {
#[serde(rename = "aggInterval")]
pub agg_interval: String,
#[serde(rename = "confidenceInfo")]
pub confidence_info: RadarGetQualityIndexTimeseriesGroupResponseResultMetaConfidenceInfo,
#[serde(rename = "dateRange")]
pub date_range: Vec<RadarGetQualityIndexTimeseriesGroupResponseResultMetaDateRangeItem>,
#[serde(rename = "lastUpdated")]
pub last_updated: String,
pub normalization: String,
pub units: Vec<RadarGetQualityIndexTimeseriesGroupResponseResultMetaUnitsItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexTimeseriesGroupResponseResultMetaConfidenceInfo {
pub annotations:
Vec<RadarGetQualityIndexTimeseriesGroupResponseResultMetaConfidenceInfoAnnotationsItem>,
pub level: i64,
}
pub type RadarGetQualityIndexTimeseriesGroupResponseResultMetaConfidenceInfoAnnotationsItem =
super::shared::RadarGetAiBotsSummaryResponseResultMetaConfidenceInfoAnnotationsItemShape;
pub type RadarGetQualityIndexTimeseriesGroupResponseResultMetaDateRangeItem =
super::shared::EndTimeStartTimeObject;
pub type RadarGetQualityIndexTimeseriesGroupResponseResultMetaUnitsItem =
super::shared::NameValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct RadarGetQualityIndexTimeseriesGroupResponseResultSerie0 {
pub p25: Vec<String>,
pub p50: Vec<String>,
pub p75: Vec<String>,
pub timestamps: Vec<String>,
}
pub type SlurperCheckSourceConnectivityResponse =
super::shared::ApiEnvelope3<Option<R2SlurperConnectivityResponse>>;
pub type SlurperCheckTargetConnectivityResponse =
super::shared::ApiEnvelope3<Option<R2SlurperConnectivityResponse>>;
pub type SlurperGetJobProgressResponse =
super::shared::ApiEnvelope3<Option<R2SlurperJobProgressResponse>>;
pub type SpectrumAnalyticsApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type SpectrumAnalyticsApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type SpectrumAnalyticsMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type SpectrumAnalyticsQueryResponseAggregate =
super::shared::ApiEnvelope<Option<Vec<std::collections::HashMap<String, serde_json::Value>>>>;
pub type TeamsDevicesApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type TeamsDevicesApiResponseSingle = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type TeamsDevicesDisconnect = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TeamsDevicesGlobalWarpOverride {
pub disconnect: Option<bool>,
pub timestamp: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TeamsDevicesGlobalWarpOverrideRequest {
pub disconnect: bool,
pub justification: Option<String>,
}
pub type TeamsDevicesGlobalWarpOverrideResponse =
super::shared::ApiEnvelope<TeamsDevicesGlobalWarpOverride>;
pub type TeamsDevicesJustification = String;
pub type TeamsDevicesMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type TeamsDevicesTimestamp = String;
pub type TunnelAccountId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelApiResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<serde_json::Value>>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelArch = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelCfdTunnel {
pub account_tag: Option<String>,
pub config_src: Option<String>,
pub connections: Option<Vec<TunnelSchemasConnection>>,
pub conns_active_at: Option<String>,
pub conns_inactive_at: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub metadata: Option<serde_json::Value>,
pub name: Option<String>,
pub remote_config: Option<bool>,
pub status: Option<String>,
pub tun_type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelCfdTunnelResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelCfdTunnel>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelCfdTunnelResponseSingle = super::shared::ApiEnvelope<TunnelCfdTunnel>;
pub type TunnelClientId = String;
pub type TunnelClientIdInput = String;
pub type TunnelColoName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelConfig {
pub ingress: Option<Vec<TunnelIngressRule>>,
#[serde(rename = "originRequest")]
pub origin_request: Option<TunnelOriginRequest>,
#[serde(rename = "warp-routing")]
pub warp_routing: Option<std::collections::HashMap<String, serde_json::Value>>,
}
pub type TunnelConfigSrc = String;
pub type TunnelConfigVersion = i64;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelConfiguration {
pub account_id: Option<String>,
pub config: Option<TunnelConfig>,
pub created_at: Option<String>,
pub source: Option<String>,
pub tunnel_id: Option<String>,
pub version: Option<i64>,
}
pub type TunnelConfigurationResponse = super::shared::ApiEnvelope<Option<TunnelConfiguration>>;
pub type TunnelConnectionId = String;
pub type TunnelConnections = Vec<TunnelSchemasConnection>;
pub type TunnelConnectionsDeprecated = Vec<TunnelSchemasConnection>;
pub type TunnelConnsActiveAt = String;
pub type TunnelConnsInactiveAt = String;
pub type TunnelEmptyResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type TunnelFeatures = Vec<String>;
pub type TunnelHaStatus = String;
pub type TunnelIcmpProxyEnabled = bool;
pub type TunnelIdentifier = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelIngressRule {
pub hostname: String,
#[serde(rename = "originRequest")]
pub origin_request: Option<TunnelOriginRequest>,
pub path: Option<String>,
pub service: String,
}
pub type TunnelIpNetwork = String;
pub type TunnelIsDefaultNetwork = bool;
pub type TunnelIsDefaultNetworkOptional = bool;
pub type TunnelIsPendingReconnect = bool;
pub type TunnelManagementResources = String;
pub type TunnelMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type TunnelMetadata = serde_json::Value;
pub type TunnelOfframpWarpEnabled = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelOriginRequest {
pub access: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "caPool")]
pub ca_pool: Option<String>,
#[serde(rename = "connectTimeout")]
pub connect_timeout: Option<i64>,
#[serde(rename = "disableChunkedEncoding")]
pub disable_chunked_encoding: Option<bool>,
#[serde(rename = "http2Origin")]
pub http2_origin: Option<bool>,
#[serde(rename = "httpHostHeader")]
pub http_host_header: Option<String>,
#[serde(rename = "keepAliveConnections")]
pub keep_alive_connections: Option<i64>,
#[serde(rename = "keepAliveTimeout")]
pub keep_alive_timeout: Option<i64>,
#[serde(rename = "matchSNItoHost")]
pub match_sn_ito_host: Option<bool>,
#[serde(rename = "noHappyEyeballs")]
pub no_happy_eyeballs: Option<bool>,
#[serde(rename = "noTLSVerify")]
pub no_tls_verify: Option<bool>,
#[serde(rename = "originServerName")]
pub origin_server_name: Option<String>,
#[serde(rename = "proxyType")]
pub proxy_type: Option<String>,
#[serde(rename = "tcpKeepAlive")]
pub tcp_keep_alive: Option<i64>,
#[serde(rename = "tlsTimeout")]
pub tls_timeout: Option<i64>,
}
pub type TunnelRemoteConfig = bool;
pub type TunnelResultInfo = super::shared::FirewallResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelRoute {
pub comment: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub network: Option<String>,
pub tunnel_id: Option<String>,
pub virtual_network_id: Option<String>,
}
pub type TunnelRouteComment = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelRouteCreateATunnelRouteRequest {
pub comment: Option<String>,
pub network: String,
pub tunnel_id: String,
pub virtual_network_id: Option<String>,
}
pub type TunnelRouteId = String;
pub type TunnelRouteResponseSingle = super::shared::ApiEnvelope<TunnelRoute>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelRouteUpdateATunnelRouteRequest {
pub comment: Option<String>,
pub network: Option<String>,
pub tunnel_id: Option<String>,
pub virtual_network_id: Option<String>,
}
pub type TunnelRunAt = String;
pub type TunnelSchemasApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type TunnelSchemasApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type TunnelSchemasConfigSrc = String;
pub type TunnelSchemasConfigVersion = i64;
pub type TunnelSchemasConnection = super::shared::TunnelSchemasConnectionShape;
pub type TunnelSchemasMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type TunnelSchemasTunnelId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelSchemasWarpConnectorConnection {
pub client_id: Option<String>,
pub client_version: Option<String>,
pub colo_name: Option<String>,
pub id: Option<String>,
pub opened_at: Option<String>,
pub origin_ip: Option<serde_json::Value>,
}
pub type TunnelStatus = String;
pub type TunnelSubnetResponseSingleNullable =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTeamnet {
pub comment: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub network: Option<String>,
pub tun_type: Option<String>,
pub tunnel_id: Option<String>,
pub tunnel_name: Option<String>,
pub virtual_network_id: Option<String>,
pub virtual_network_name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTeamnetResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelTeamnet>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelTeamnetResponseSingle = super::shared::ApiEnvelope<TunnelTeamnet>;
pub type TunnelTimestamp = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTunnelClient {
pub arch: Option<String>,
pub config_version: Option<i64>,
pub conns: Option<Vec<TunnelSchemasConnection>>,
pub features: Option<Vec<String>>,
pub id: Option<String>,
pub run_at: Option<String>,
pub version: Option<String>,
}
pub type TunnelTunnelClientResponse = super::shared::ApiEnvelope<TunnelTunnelClient>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTunnelConnectionsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelTunnelClient>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelTunnelId = String;
pub type TunnelTunnelName = String;
pub type TunnelTunnelResponseToken = super::shared::ApiEnvelope<String>;
pub type TunnelTunnelSecret = String;
pub type TunnelTunnelToken = String;
pub type TunnelTunnelType = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTunnelWarpConnectorClient {
pub arch: Option<String>,
pub conns: Option<Vec<TunnelSchemasWarpConnectorConnection>>,
pub features: Option<Vec<String>>,
pub ha_status: Option<String>,
pub id: Option<String>,
pub run_at: Option<String>,
pub version: Option<String>,
}
pub type TunnelTunnelWarpConnectorClientResponse =
super::shared::ApiEnvelope<TunnelTunnelWarpConnectorClient>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTunnelWarpConnectorConnectionsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelTunnelWarpConnectorClient>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelVersion = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelVirtualNetwork {
pub comment: String,
pub created_at: String,
pub deleted_at: Option<String>,
pub id: String,
pub is_default_network: bool,
pub name: String,
}
pub type TunnelVirtualNetworkComment = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelVirtualNetworkCreateAVirtualNetworkRequest {
pub comment: Option<String>,
pub is_default: Option<bool>,
pub is_default_network: Option<bool>,
pub name: String,
}
pub type TunnelVirtualNetworkGetRequest = super::shared::CommentIsDefaultNetworkNameObject;
pub type TunnelVirtualNetworkId = String;
pub type TunnelVirtualNetworkIdComputedOptional = String;
pub type TunnelVirtualNetworkName = String;
pub type TunnelVirtualNetworkUpdateRequest = super::shared::CommentIsDefaultNetworkNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelVnetResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelVirtualNetwork>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelVnetResponseSingle = super::shared::ApiEnvelope<TunnelVirtualNetwork>;
pub type TunnelWarpConnectorConnections = Vec<TunnelSchemasWarpConnectorConnection>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelWarpConnectorResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<TunnelWarpConnectorTunnel>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelWarpConnectorResponseSingle = super::shared::ApiEnvelope<TunnelWarpConnectorTunnel>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelWarpConnectorTunnel {
pub account_tag: Option<String>,
pub connections: Option<Vec<TunnelSchemasConnection>>,
pub conns_active_at: Option<String>,
pub conns_inactive_at: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub metadata: Option<serde_json::Value>,
pub name: Option<String>,
pub status: Option<String>,
pub tun_type: Option<String>,
}
pub type TunnelZeroTrustConnectivitySettingsResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type UpdateDexRuleResponse =
super::shared::ApiEnvelope<Option<DigitalExperienceMonitoringDexRule>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ZeroTrustAccountsPatchConnectivitySettingsRequest {
pub icmp_proxy_enabled: Option<bool>,
pub offramp_warp_enabled: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ZeroTrustNetworksSubnetCreateWarpRequest {
pub comment: Option<String>,
pub is_default_network: Option<bool>,
pub name: String,
pub network: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ZeroTrustNetworksSubnetUpdateWarpRequest {
pub comment: Option<String>,
pub is_default_network: Option<bool>,
pub name: Option<String>,
pub network: Option<String>,
}
pub type IpAddressManagementPrefixesListBgpPrefixesArgs = super::shared::AccountIdPrefixIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct IpAddressManagementPrefixesCreateBgpPrefixArgs {
pub account_id: String,
pub prefix_id: String,
pub body: AddressingBgpPrefixCreate,
}
pub type IpAddressManagementPrefixesFetchBgpPrefixArgs =
super::shared::AccountIdPrefixIdBgpPrefixIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct IpAddressManagementPrefixesUpdateBgpPrefixArgs {
pub account_id: String,
pub prefix_id: String,
pub bgp_prefix_id: String,
pub body: AddressingBgpPrefixUpdateAdvertisement,
}
pub type IpAddressManagementPrefixesDeleteBgpPrefixArgs =
super::shared::AccountIdPrefixIdBgpPrefixIdArgs;
pub type CloudflareTunnelListCloudflareTunnelsArgs =
super::shared::CloudflareTunnelListCloudflareTunnelsArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelCreateACloudflareTunnelArgs {
pub account_id: String,
pub body: CloudflareTunnelCreateACloudflareTunnelRequest,
}
pub type CloudflareTunnelGetACloudflareTunnelArgs = super::shared::AccountIdTunnelIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelUpdateACloudflareTunnelArgs {
pub tunnel_id: String,
pub account_id: String,
pub body: CloudflareTunnelUpdateACloudflareTunnelRequest,
}
pub type CloudflareTunnelDeleteACloudflareTunnelArgs = super::shared::AccountIdTunnelIdArgs;
pub type CloudflareTunnelConfigurationGetConfigurationArgs = super::shared::AccountIdTunnelIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelConfigurationPutConfigurationArgs {
pub account_id: String,
pub tunnel_id: String,
pub body: CloudflareTunnelConfigurationPutConfigurationRequest,
}
pub type CloudflareTunnelListCloudflareTunnelConnectionsArgs = super::shared::AccountIdTunnelIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelCleanUpCloudflareTunnelConnectionsArgs {
pub account_id: String,
pub tunnel_id: String,
pub client_id: Option<String>,
}
pub type CloudflareTunnelGetCloudflareTunnelConnectorArgs =
super::shared::AccountIdTunnelIdConnectorIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelGetACloudflareTunnelManagementTokenArgs {
pub account_id: String,
pub tunnel_id: String,
pub body: CloudflareTunnelGetACloudflareTunnelManagementTokenRequest,
}
pub type CloudflareTunnelGetACloudflareTunnelTokenArgs = super::shared::AccountIdTunnelIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetEventAggregateArgs {
pub account_id: String,
pub aggregate_by: Option<String>,
pub dataset_id: Vec<String>,
pub start_date: Option<String>,
pub end_date: Option<String>,
pub group_by_date: Option<String>,
pub limit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListCnisArgs {
pub account_id: String,
pub slot: Option<String>,
pub tunnel_id: Option<String>,
pub cursor: Option<String>,
pub limit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateCniArgs {
pub account_id: String,
pub body: NscCniCreate,
}
pub type GetCniArgs = super::shared::CniAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateCniArgs {
pub cni: String,
pub account_id: String,
pub body: NscCni,
}
pub type DeleteCniArgs = super::shared::CniAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListInterconnectsArgs {
pub account_id: String,
pub site: Option<String>,
pub r#type: Option<String>,
pub cursor: Option<String>,
pub limit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateInterconnectArgs {
pub account_id: String,
pub body: NscInterconnectCreate,
}
pub type GetInterconnectArgs = super::shared::IconAccountIdArgs;
pub type DeleteInterconnectArgs = super::shared::IconAccountIdArgs;
pub type GetInterconnectLoaArgs = super::shared::IconAccountIdArgs;
pub type GetInterconnectStatusArgs = super::shared::IconAccountIdArgs;
pub type GetSettingsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateSettingsArgs {
pub account_id: String,
pub body: NscSettingsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListSlotsArgs {
pub account_id: String,
pub address_contains: Option<String>,
pub site: Option<String>,
pub speed: Option<String>,
pub occupied: Option<String>,
pub cursor: Option<String>,
pub limit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetSlotArgs {
pub slot: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ConnectivityServicesListArgs {
pub account_id: String,
pub r#type: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ConnectivityServicesPostArgs {
pub account_id: String,
pub body: InfraServiceConfig,
}
pub type ConnectivityServicesGetArgs = super::shared::AccountIdServiceIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ConnectivityServicesPutArgs {
pub account_id: String,
pub service_id: String,
pub body: InfraServiceConfig,
}
pub type ConnectivityServicesDeleteArgs = super::shared::AccountIdServiceIdArgs;
pub type DevicesResilienceRetrieveGlobalWarpOverrideArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DevicesResilienceSetGlobalWarpOverrideArgs {
pub account_id: String,
pub body: TeamsDevicesGlobalWarpOverrideRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexEndpointsListColosArgs {
pub account_id: String,
pub from: Option<String>,
pub to: Option<String>,
pub sort_by: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetCommandsArgs {
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub from: Option<String>,
pub to: Option<String>,
pub device_id: Option<String>,
pub user_email: Option<String>,
pub command_type: Option<String>,
pub status: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostCommandsArgs {
pub account_id: String,
pub body: PostCommandsRequest,
}
pub type GetCommandsEligibleDevicesArgs = super::shared::McpPortalsApiListPortalsArgsShape;
pub type GetCommandsQuotaArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetCommandsCommandIdDownloadsFilenameArgs {
pub account_id: String,
pub command_id: String,
pub filename: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeviceDexTestDetailsArgs {
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub test_name: Option<String>,
pub kind: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeviceDexTestCreateDeviceDexTestArgs {
pub account_id: String,
pub body: DigitalExperienceMonitoringDeviceDexTestSchemasHttp,
}
pub type DeviceDexTestGetDeviceDexTestArgs = super::shared::AccountIdDexTestIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeviceDexTestUpdateDeviceDexTestArgs {
pub account_id: String,
pub dex_test_id: String,
pub body: DigitalExperienceMonitoringDeviceDexTestSchemasHttp,
}
pub type DeviceDexTestDeleteDeviceDexTestArgs = super::shared::AccountIdDexTestIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DevicesLiveStatusArgs {
pub account_id: String,
pub device_id: String,
pub since_minutes: Option<String>,
pub time_now: Option<String>,
pub colo: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexFleetStatusDevicesArgs {
pub account_id: String,
pub to: Option<String>,
pub from: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
pub sort_by: Option<String>,
pub colo: Option<String>,
pub device_id: Option<String>,
pub mode: Option<String>,
pub status: Option<String>,
pub platform: Option<String>,
pub version: Option<String>,
pub source: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexFleetStatusLiveArgs {
pub account_id: String,
pub since_minutes: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexFleetStatusOverTimeArgs {
pub account_id: String,
pub to: Option<String>,
pub from: Option<String>,
pub colo: Option<String>,
pub device_id: Option<String>,
}
pub type DexEndpointsHttpTestDetailsArgs = super::shared::DexEndpointsHttpTestDetailsArgsShape;
pub type DexEndpointsHttpTestPercentilesArgs =
super::shared::DexEndpointsHttpTestPercentilesArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListDexRulesArgs {
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub sort_order: Option<String>,
pub sort_by: Option<String>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateDexRuleArgs {
pub account_id: String,
pub body: DigitalExperienceMonitoringCreateRuleBody,
}
pub type GetDexRuleArgs = super::shared::AccountIdRuleIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateDexRuleArgs {
pub account_id: String,
pub rule_id: String,
pub body: DigitalExperienceMonitoringPatchRuleBody,
}
pub type DeleteDexRuleArgs = super::shared::AccountIdRuleIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexEndpointsListTestsOverviewArgs {
pub account_id: String,
pub colo: Option<String>,
pub test_name: Option<String>,
pub device_id: Vec<String>,
pub page: Option<String>,
pub per_page: Option<String>,
pub kind: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexEndpointsTestsUniqueDevicesArgs {
pub account_id: String,
pub test_name: Option<String>,
pub device_id: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexEndpointsTracerouteTestResultNetworkPathArgs {
pub account_id: String,
pub test_result_id: String,
}
pub type DexEndpointsTracerouteTestDetailsArgs =
super::shared::DexEndpointsHttpTestDetailsArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DexEndpointsTracerouteTestNetworkPathArgs {
pub account_id: String,
pub test_id: String,
pub device_id: Option<String>,
pub from: Option<String>,
pub to: Option<String>,
pub interval: Option<String>,
}
pub type DexEndpointsTracerouteTestPercentilesArgs =
super::shared::DexEndpointsHttpTestPercentilesArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListWarpChangeEventsArgs {
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub from: Option<String>,
pub to: Option<String>,
pub r#type: Option<String>,
pub toggle: Option<String>,
pub config_name: Option<String>,
pub account_name: Option<String>,
pub sort_order: Option<String>,
}
pub type MagicInterconnectsListInterconnectsArgs = super::shared::AccountIdArgs;
pub type MagicInterconnectsUpdateMultipleInterconnectsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicInterconnectsListInterconnectDetailsArgs {
pub cf_interconnect_id: String,
pub account_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicInterconnectsUpdateInterconnectArgs {
pub cf_interconnect_id: String,
pub account_id: String,
pub body: MagicInterconnectTunnelUpdateRequest,
}
pub type MagicGreTunnelsListGreTunnelsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicGreTunnelsCreateGreTunnelsArgs {
pub account_id: String,
pub body: MagicCreateGreTunnelRequest,
}
pub type MagicGreTunnelsUpdateMultipleGreTunnelsArgs = super::shared::AccountIdArgs;
pub type MagicGreTunnelsListGreTunnelDetailsArgs = super::shared::GreTunnelIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicGreTunnelsUpdateGreTunnelArgs {
pub gre_tunnel_id: String,
pub account_id: String,
pub body: MagicGreTunnelUpdateRequest,
}
pub type MagicGreTunnelsDeleteGreTunnelArgs = super::shared::GreTunnelIdAccountIdArgs;
pub type MagicIpsecTunnelsListIpsecTunnelsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicIpsecTunnelsCreateIpsecTunnelsArgs {
pub account_id: String,
pub body: MagicIpsecTunnelAddRequest,
}
pub type MagicIpsecTunnelsUpdateMultipleIpsecTunnelsArgs = super::shared::AccountIdArgs;
pub type MagicIpsecTunnelsListIpsecTunnelDetailsArgs = super::shared::IpsecTunnelIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicIpsecTunnelsUpdateIpsecTunnelArgs {
pub ipsec_tunnel_id: String,
pub account_id: String,
pub body: MagicIpsecTunnelAddSingleRequest,
}
pub type MagicIpsecTunnelsDeleteIpsecTunnelArgs = super::shared::IpsecTunnelIdAccountIdArgs;
pub type MagicIpsecTunnelsGeneratePreSharedKeyPskForIpsecTunnelsArgs =
super::shared::IpsecTunnelIdAccountIdArgs;
pub type SlurperGetJobProgressArgs = super::shared::AccountIdJobIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SlurperCheckSourceConnectivityArgs {
pub account_id: String,
pub body: R2SlurperSourceJobSchema,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SlurperCheckTargetConnectivityArgs {
pub account_id: String,
pub body: R2SlurperR2TargetSchema,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelRouteListTunnelRoutesArgs {
pub account_id: String,
pub comment: Option<String>,
pub is_deleted: Option<String>,
pub network_subset: Option<String>,
pub network_superset: Option<String>,
pub existed_at: Option<String>,
pub tunnel_id: Option<String>,
pub route_id: Option<String>,
pub tun_types: Option<String>,
pub virtual_network_id: Option<String>,
pub per_page: Option<String>,
pub page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelRouteCreateATunnelRouteArgs {
pub account_id: String,
pub body: TunnelRouteCreateATunnelRouteRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelRouteGetTunnelRouteByIpArgs {
pub ip: String,
pub account_id: String,
pub virtual_network_id: Option<String>,
pub default_virtual_network_fallback: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelRouteGetTunnelRouteArgs {
pub account_id: String,
pub route_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelRouteUpdateATunnelRouteArgs {
pub route_id: String,
pub account_id: String,
pub body: TunnelRouteUpdateATunnelRouteRequest,
}
pub type TunnelRouteDeleteATunnelRouteArgs = super::shared::RouteIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelVirtualNetworkListVirtualNetworksArgs {
pub account_id: String,
pub id: Option<String>,
pub name: Option<String>,
pub is_default: Option<String>,
pub is_default_network: Option<String>,
pub is_deleted: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelVirtualNetworkCreateAVirtualNetworkArgs {
pub account_id: String,
pub body: TunnelVirtualNetworkCreateAVirtualNetworkRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelVirtualNetworkGetArgs {
pub account_id: String,
pub virtual_network_id: String,
pub body: TunnelVirtualNetworkGetRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelVirtualNetworkUpdateArgs {
pub account_id: String,
pub virtual_network_id: String,
pub body: TunnelVirtualNetworkUpdateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TunnelVirtualNetworkDeleteArgs {
pub virtual_network_id: String,
pub account_id: String,
}
pub type CloudflareTunnelListWarpConnectorTunnelsArgs =
super::shared::CloudflareTunnelListCloudflareTunnelsArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelCreateAWarpConnectorTunnelArgs {
pub account_id: String,
pub body: CloudflareTunnelCreateAWarpConnectorTunnelRequest,
}
pub type CloudflareTunnelGetAWarpConnectorTunnelArgs = super::shared::AccountIdTunnelIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelUpdateAWarpConnectorTunnelArgs {
pub account_id: String,
pub tunnel_id: String,
pub body: CloudflareTunnelUpdateAWarpConnectorTunnelRequest,
}
pub type CloudflareTunnelDeleteAWarpConnectorTunnelArgs = super::shared::AccountIdTunnelIdArgs;
pub type CloudflareTunnelListWarpConnectorTunnelConnectionsArgs =
super::shared::AccountIdTunnelIdArgs;
pub type CloudflareTunnelGetWarpConnectorTunnelConnectorArgs =
super::shared::AccountIdTunnelIdConnectorIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelManualFailoverWarpConnectorTunnelArgs {
pub account_id: String,
pub tunnel_id: String,
pub body: CloudflareTunnelManualFailoverWarpConnectorTunnelRequest,
}
pub type CloudflareTunnelGetAWarpConnectorTunnelTokenArgs = super::shared::AccountIdTunnelIdArgs;
pub type ZeroTrustAccountsGetConnectivitySettingsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ZeroTrustAccountsPatchConnectivitySettingsArgs {
pub account_id: String,
pub body: ZeroTrustAccountsPatchConnectivitySettingsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ZeroTrustNetworksSubnetCreateWarpArgs {
pub account_id: String,
pub body: ZeroTrustNetworksSubnetCreateWarpRequest,
}
pub type ZeroTrustNetworksSubnetGetWarpArgs = super::shared::AccountIdSubnetIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ZeroTrustNetworksSubnetUpdateWarpArgs {
pub account_id: String,
pub subnet_id: String,
pub body: ZeroTrustNetworksSubnetUpdateWarpRequest,
}
pub type ZeroTrustNetworksSubnetDeleteWarpArgs = super::shared::AccountIdSubnetIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpHijacksEventsArgs {
pub page: Option<String>,
pub per_page: Option<String>,
pub event_id: Option<String>,
pub hijacker_asn: Option<String>,
pub victim_asn: Option<String>,
pub involved_asn: Option<String>,
pub involved_country: Option<String>,
pub prefix: Option<String>,
pub min_confidence: Option<String>,
pub max_confidence: Option<String>,
pub date_range: Option<String>,
pub date_start: Option<String>,
pub date_end: Option<String>,
pub sort_by: Option<String>,
pub sort_order: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpIpsTimeseriesArgs {
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub asn: Vec<String>,
pub location: Vec<String>,
pub ip_version: Vec<String>,
pub include_delay: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRouteLeakEventsArgs {
pub page: Option<String>,
pub per_page: Option<String>,
pub event_id: Option<String>,
pub leak_asn: Option<String>,
pub involved_asn: Option<String>,
pub involved_country: Option<String>,
pub date_range: Option<String>,
pub date_start: Option<String>,
pub date_end: Option<String>,
pub sort_by: Option<String>,
pub sort_order: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRoutesAsnsArgs {
pub location: Option<String>,
pub limit: Option<String>,
pub sort_by: Option<String>,
pub sort_order: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpPfx2AsMoasArgs {
pub origin: Option<String>,
pub prefix: Option<String>,
pub invalid_only: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpPfx2AsArgs {
pub prefix: Option<String>,
pub origin: Option<String>,
pub rpki_status: Option<String>,
pub longest_prefix_match: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRoutesStatsArgs {
pub asn: Option<String>,
pub location: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaChangesArgs {
pub date_start: Option<String>,
pub date_end: Option<String>,
pub asn: Option<String>,
pub include_asn_info: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaSnapshotArgs {
pub customer_asn: Option<String>,
pub provider_asn: Option<String>,
pub date: Option<String>,
pub include_asn_info: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpRpkiAspaTimeseriesArgs {
pub date_start: Option<String>,
pub date_end: Option<String>,
pub name: Vec<String>,
pub rir: Vec<String>,
pub location: Vec<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpTimeseriesArgs {
pub agg_interval: Option<String>,
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub prefix: Vec<String>,
pub update_type: Vec<String>,
pub asn: Vec<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpTopAsesArgs {
pub limit: Option<String>,
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub asn: Vec<String>,
pub prefix: Vec<String>,
pub update_type: Vec<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpTopAsnsByPrefixesArgs {
pub country: Option<String>,
pub limit: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetBgpTopPrefixesArgs {
pub limit: Option<String>,
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub asn: Vec<String>,
pub update_type: Vec<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetQualityIndexSummaryArgs {
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub asn: Vec<String>,
pub location: Vec<String>,
pub continent: Vec<String>,
pub metric: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct RadarGetQualityIndexTimeseriesGroupArgs {
pub agg_interval: Option<String>,
pub name: Vec<String>,
pub date_range: Vec<String>,
pub date_start: Vec<String>,
pub date_end: Vec<String>,
pub asn: Vec<String>,
pub location: Vec<String>,
pub continent: Vec<String>,
pub interpolation: Option<String>,
pub metric: Option<String>,
pub format: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SpectrumAggregateAnalyticsGetCurrentAggregatedAnalyticsArgs {
pub zone_id: String,
pub app_id: Option<String>,
pub colo_name: Option<String>,
}
pub async fn ip_address_management_prefixes_list_bgp_prefixes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementPrefixesListBgpPrefixesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingResponseCollectionBgp>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bgp/prefixes",
args.account_id, args.prefix_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 ip_address_management_prefixes_create_bgp_prefix_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementPrefixesCreateBgpPrefixArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingSingleResponseBgp>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bgp/prefixes",
args.account_id, args.prefix_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 ip_address_management_prefixes_fetch_bgp_prefix_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementPrefixesFetchBgpPrefixArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingSingleResponseBgp>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bgp/prefixes/{}",
args.account_id, args.prefix_id, args.bgp_prefix_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 ip_address_management_prefixes_update_bgp_prefix_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementPrefixesUpdateBgpPrefixArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingSingleResponseBgp>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bgp/prefixes/{}",
args.account_id, args.prefix_id, args.bgp_prefix_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 ip_address_management_prefixes_delete_bgp_prefix_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementPrefixesDeleteBgpPrefixArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bgp/prefixes/{}",
args.account_id, args.prefix_id, args.bgp_prefix_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 cloudflare_tunnel_list_cloudflare_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelListCloudflareTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelCfdTunnelResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cfd_tunnel", 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("name", args.name.as_deref());
builder = builder.query("is_deleted", args.is_deleted.as_deref());
builder = builder.query("existed_at", args.existed_at.as_deref());
builder = builder.query("uuid", args.uuid.as_deref());
builder = builder.query("was_active_at", args.was_active_at.as_deref());
builder = builder.query("was_inactive_at", args.was_inactive_at.as_deref());
builder = builder.query("include_prefix", args.include_prefix.as_deref());
builder = builder.query("exclude_prefix", args.exclude_prefix.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_tunnel_create_a_cloudflare_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelCreateACloudflareTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelCfdTunnelResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cfd_tunnel", 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 cloudflare_tunnel_get_a_cloudflare_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetACloudflareTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelCfdTunnelResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_update_a_cloudflare_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelUpdateACloudflareTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelCfdTunnelResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_delete_a_cloudflare_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelDeleteACloudflareTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelCfdTunnelResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_configuration_get_configuration_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelConfigurationGetConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelConfigurationResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/configurations",
args.account_id, args.tunnel_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 cloudflare_tunnel_configuration_put_configuration_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelConfigurationPutConfigurationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelConfigurationResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/configurations",
args.account_id, args.tunnel_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 cloudflare_tunnel_list_cloudflare_tunnel_connections_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelListCloudflareTunnelConnectionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelConnectionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/connections",
args.account_id, args.tunnel_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 cloudflare_tunnel_clean_up_cloudflare_tunnel_connections_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelCleanUpCloudflareTunnelConnectionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelEmptyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/connections",
args.account_id, args.tunnel_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("client_id", args.client_id.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_tunnel_get_cloudflare_tunnel_connector_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetCloudflareTunnelConnectorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelClientResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/connectors/{}",
args.account_id, args.tunnel_id, args.connector_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 cloudflare_tunnel_get_a_cloudflare_tunnel_management_token_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetACloudflareTunnelManagementTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelResponseToken>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/management",
args.account_id, args.tunnel_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 cloudflare_tunnel_get_a_cloudflare_tunnel_token_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetACloudflareTunnelTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelResponseToken>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cfd_tunnel/{}/token",
args.account_id, args.tunnel_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_event_aggregate_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetEventAggregateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetEventAggregateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cloudforce-one/events/aggregate",
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("aggregateBy", args.aggregate_by.as_deref());
for value in &args.dataset_id {
builder = builder.query("datasetId", Some(value.as_str()));
}
builder = builder.query("startDate", args.start_date.as_deref());
builder = builder.query("endDate", args.end_date.as_deref());
builder = builder.query("groupByDate", args.group_by_date.as_deref());
builder = builder.query("limit", args.limit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_cnis_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListCnisArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscCniList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/cnis", 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("slot", args.slot.as_deref());
builder = builder.query("tunnel_id", args.tunnel_id.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
builder = builder.query("limit", args.limit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_cni_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateCniArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscCni>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/cnis", 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_cni_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetCniArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscCni>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/cnis/{}", args.account_id, args.cni,);
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 update_cni_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateCniArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscCni>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/cnis/{}", args.account_id, args.cni,);
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_cni_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteCniArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/cnis/{}", args.account_id, args.cni,);
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_without_body(client.into(), builder.build()).await
}
pub async fn list_interconnects_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListInterconnectsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscInterconnectList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/interconnects", 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("site", args.site.as_deref());
builder = builder.query("type", args.r#type.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
builder = builder.query("limit", args.limit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_interconnect_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateInterconnectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscInterconnect>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/interconnects", 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_interconnect_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetInterconnectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscInterconnect>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cni/interconnects/{}",
args.account_id, args.icon,
);
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 delete_interconnect_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteInterconnectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cni/interconnects/{}",
args.account_id, args.icon,
);
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_without_body(client.into(), builder.build()).await
}
pub async fn get_interconnect_loa_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetInterconnectLoaArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cni/interconnects/{}/loa",
args.account_id, args.icon,
);
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_without_body(client.into(), builder.build()).await
}
pub async fn get_interconnect_status_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetInterconnectStatusArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscStatusInfo>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/cni/interconnects/{}/status",
args.account_id, args.icon,
);
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_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscSettings>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/settings", 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 update_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscSettings>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/settings", 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 list_slots_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListSlotsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscSlotList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/slots", 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("address_contains", args.address_contains.as_deref());
builder = builder.query("site", args.site.as_deref());
builder = builder.query("speed", args.speed.as_deref());
builder = builder.query("occupied", args.occupied.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
builder = builder.query("limit", args.limit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_slot_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetSlotArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NscSlotInfo>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/cni/slots/{}", args.account_id, args.slot,);
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 connectivity_services_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConnectivityServicesListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ConnectivityServicesListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/connectivity/directory/services",
args.account_id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("type", args.r#type.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn connectivity_services_post_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConnectivityServicesPostArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ConnectivityServicesPostResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/connectivity/directory/services",
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 connectivity_services_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConnectivityServicesGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ConnectivityServicesGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/connectivity/directory/services/{}",
args.account_id, args.service_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 connectivity_services_put_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConnectivityServicesPutArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ConnectivityServicesPutResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/connectivity/directory/services/{}",
args.account_id, args.service_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 connectivity_services_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConnectivityServicesDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/connectivity/directory/services/{}",
args.account_id, args.service_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_without_body(client.into(), builder.build()).await
}
pub async fn devices_resilience_retrieve_global_warp_override_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DevicesResilienceRetrieveGlobalWarpOverrideArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TeamsDevicesGlobalWarpOverrideResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/devices/resilience/disconnect",
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 devices_resilience_set_global_warp_override_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DevicesResilienceSetGlobalWarpOverrideArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TeamsDevicesGlobalWarpOverrideResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/devices/resilience/disconnect",
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 dex_endpoints_list_colos_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsListColosArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsListColosResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/colos", 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("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("sortBy", args.sort_by.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_commands_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetCommandsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetCommandsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/commands", 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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("device_id", args.device_id.as_deref());
builder = builder.query("user_email", args.user_email.as_deref());
builder = builder.query("command_type", args.command_type.as_deref());
builder = builder.query("status", args.status.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn post_commands_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostCommandsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PostCommandsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/commands", 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_commands_eligible_devices_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetCommandsEligibleDevicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetCommandsEligibleDevicesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/commands/devices", 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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("search", args.search.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_commands_quota_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetCommandsQuotaArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetCommandsQuotaResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/commands/quota", 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 get_commands_command_id_downloads_filename_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetCommandsCommandIdDownloadsFilenameArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/commands/{}/downloads/{}",
args.account_id, args.command_id, args.filename,
);
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_bytes(client.into(), builder.build()).await
}
pub async fn device_dex_test_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeviceDexTestDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringDexResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/devices/dex_tests", 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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("testName", args.test_name.as_deref());
builder = builder.query("kind", args.kind.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn device_dex_test_create_device_dex_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeviceDexTestCreateDeviceDexTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringDexSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/devices/dex_tests", 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 device_dex_test_get_device_dex_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeviceDexTestGetDeviceDexTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringDexSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/devices/dex_tests/{}",
args.account_id, args.dex_test_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 device_dex_test_update_device_dex_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeviceDexTestUpdateDeviceDexTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringDexSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/devices/dex_tests/{}",
args.account_id, args.dex_test_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 device_dex_test_delete_device_dex_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeviceDexTestDeleteDeviceDexTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<DigitalExperienceMonitoringDexDeleteResponseCollection>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/devices/dex_tests/{}",
args.account_id, args.dex_test_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 devices_live_status_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DevicesLiveStatusArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringDevice>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/devices/{}/fleet-status/live",
args.account_id, args.device_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("since_minutes", args.since_minutes.as_deref());
builder = builder.query("time_now", args.time_now.as_deref());
builder = builder.query("colo", args.colo.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_fleet_status_devices_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexFleetStatusDevicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<DigitalExperienceMonitoringFleetStatusDevicesResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/fleet-status/devices", 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("to", args.to.as_deref());
builder = builder.query("from", args.from.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("sort_by", args.sort_by.as_deref());
builder = builder.query("colo", args.colo.as_deref());
builder = builder.query("device_id", args.device_id.as_deref());
builder = builder.query("mode", args.mode.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("platform", args.platform.as_deref());
builder = builder.query("version", args.version.as_deref());
builder = builder.query("source", args.source.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_fleet_status_live_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexFleetStatusLiveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DigitalExperienceMonitoringFleetStatusLiveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/fleet-status/live", 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("since_minutes", args.since_minutes.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_fleet_status_over_time_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexFleetStatusOverTimeArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<DigitalExperienceMonitoringFleetStatusOverTimeResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/fleet-status/over-time", 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("to", args.to.as_deref());
builder = builder.query("from", args.from.as_deref());
builder = builder.query("colo", args.colo.as_deref());
builder = builder.query("device_id", args.device_id.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_http_test_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsHttpTestDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsHttpTestDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/http-tests/{}",
args.account_id, args.test_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.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("interval", args.interval.as_deref());
builder = builder.query("colo", args.colo.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_http_test_percentiles_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsHttpTestPercentilesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsHttpTestPercentilesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/http-tests/{}/percentiles",
args.account_id, args.test_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.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("colo", args.colo.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_dex_rules_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListDexRulesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListDexRulesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/rules", 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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
builder = builder.query("sort_by", args.sort_by.as_deref());
builder = builder.query("name", args.name.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_dex_rule_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateDexRuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateDexRuleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/rules", 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_dex_rule_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetDexRuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetDexRuleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/rules/{}", args.account_id, args.rule_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 update_dex_rule_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateDexRuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpdateDexRuleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/rules/{}", args.account_id, args.rule_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 delete_dex_rule_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteDexRuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteDexRuleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/rules/{}", args.account_id, args.rule_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 dex_endpoints_list_tests_overview_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsListTestsOverviewArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsListTestsOverviewResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/tests/overview", 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("colo", args.colo.as_deref());
builder = builder.query("testName", args.test_name.as_deref());
for value in &args.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
builder = builder.query("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("kind", args.kind.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_tests_unique_devices_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsTestsUniqueDevicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsTestsUniqueDevicesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/tests/unique-devices", 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("testName", args.test_name.as_deref());
for value in &args.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_traceroute_test_result_network_path_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsTracerouteTestResultNetworkPathArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsTracerouteTestResultNetworkPathResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/traceroute-test-results/{}/network-path",
args.account_id, args.test_result_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 dex_endpoints_traceroute_test_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsTracerouteTestDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsTracerouteTestDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/traceroute-tests/{}",
args.account_id, args.test_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.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("interval", args.interval.as_deref());
builder = builder.query("colo", args.colo.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_traceroute_test_network_path_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsTracerouteTestNetworkPathArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsTracerouteTestNetworkPathResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/traceroute-tests/{}/network-path",
args.account_id, args.test_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("deviceId", args.device_id.as_deref());
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("interval", args.interval.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn dex_endpoints_traceroute_test_percentiles_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DexEndpointsTracerouteTestPercentilesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DexEndpointsTracerouteTestPercentilesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/dex/traceroute-tests/{}/percentiles",
args.account_id, args.test_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.device_id {
builder = builder.query("deviceId", Some(value.as_str()));
}
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("colo", args.colo.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_warp_change_events_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListWarpChangeEventsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListWarpChangeEventsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/dex/warp-change-events", 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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("from", args.from.as_deref());
builder = builder.query("to", args.to.as_deref());
builder = builder.query("type", args.r#type.as_deref());
builder = builder.query("toggle", args.toggle.as_deref());
builder = builder.query("config_name", args.config_name.as_deref());
builder = builder.query("account_name", args.account_name.as_deref());
builder = builder.query("sort_order", args.sort_order.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_interconnects_list_interconnects_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicInterconnectsListInterconnectsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicComponentsSchemasTunnelsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cf_interconnects", 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 magic_interconnects_update_multiple_interconnects_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicInterconnectsUpdateMultipleInterconnectsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<MagicComponentsSchemasModifiedTunnelsCollectionResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/cf_interconnects", 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_interconnects_list_interconnect_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicInterconnectsListInterconnectDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicComponentsSchemasTunnelSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cf_interconnects/{}",
args.account_id, args.cf_interconnect_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 magic_interconnects_update_interconnect_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicInterconnectsUpdateInterconnectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicComponentsSchemasTunnelModifiedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/cf_interconnects/{}",
args.account_id, args.cf_interconnect_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 magic_gre_tunnels_list_gre_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsListGreTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTunnelsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/gre_tunnels", 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 magic_gre_tunnels_create_gre_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsCreateGreTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicCreateGreTunnelResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/gre_tunnels", 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 magic_gre_tunnels_update_multiple_gre_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsUpdateMultipleGreTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicModifiedTunnelsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/gre_tunnels", 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_gre_tunnels_list_gre_tunnel_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsListGreTunnelDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTunnelSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/gre_tunnels/{}",
args.account_id, args.gre_tunnel_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 magic_gre_tunnels_update_gre_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsUpdateGreTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTunnelModifiedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/gre_tunnels/{}",
args.account_id, args.gre_tunnel_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 magic_gre_tunnels_delete_gre_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicGreTunnelsDeleteGreTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicTunnelDeletedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/gre_tunnels/{}",
args.account_id, args.gre_tunnel_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 magic_ipsec_tunnels_list_ipsec_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsListIpsecTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasTunnelsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/ipsec_tunnels", 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 magic_ipsec_tunnels_create_ipsec_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsCreateIpsecTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasCreateIpsecTunnelResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/ipsec_tunnels", 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 magic_ipsec_tunnels_update_multiple_ipsec_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsUpdateMultipleIpsecTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasModifiedTunnelsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/magic/ipsec_tunnels", 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_ipsec_tunnels_list_ipsec_tunnel_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsListIpsecTunnelDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasTunnelSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/ipsec_tunnels/{}",
args.account_id, args.ipsec_tunnel_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 magic_ipsec_tunnels_update_ipsec_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsUpdateIpsecTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasTunnelModifiedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/ipsec_tunnels/{}",
args.account_id, args.ipsec_tunnel_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 magic_ipsec_tunnels_delete_ipsec_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsDeleteIpsecTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicSchemasTunnelDeletedResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/ipsec_tunnels/{}",
args.account_id, args.ipsec_tunnel_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 magic_ipsec_tunnels_generate_pre_shared_key_psk_for_ipsec_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicIpsecTunnelsGeneratePreSharedKeyPskForIpsecTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicPskGenerationResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/magic/ipsec_tunnels/{}/psk_generate",
args.account_id, args.ipsec_tunnel_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 slurper_get_job_progress_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SlurperGetJobProgressArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<SlurperGetJobProgressResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/slurper/jobs/{}/progress",
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 slurper_check_source_connectivity_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SlurperCheckSourceConnectivityArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<SlurperCheckSourceConnectivityResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/slurper/source/connectivity-precheck",
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 slurper_check_target_connectivity_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SlurperCheckTargetConnectivityArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<SlurperCheckTargetConnectivityResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/slurper/target/connectivity-precheck",
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 tunnel_route_list_tunnel_routes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteListTunnelRoutesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTeamnetResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/teamnet/routes", 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("comment", args.comment.as_deref());
builder = builder.query("is_deleted", args.is_deleted.as_deref());
builder = builder.query("network_subset", args.network_subset.as_deref());
builder = builder.query("network_superset", args.network_superset.as_deref());
builder = builder.query("existed_at", args.existed_at.as_deref());
builder = builder.query("tunnel_id", args.tunnel_id.as_deref());
builder = builder.query("route_id", args.route_id.as_deref());
builder = builder.query("tun_types", args.tun_types.as_deref());
builder = builder.query("virtual_network_id", args.virtual_network_id.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tunnel_route_create_a_tunnel_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteCreateATunnelRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelRouteResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/teamnet/routes", 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 tunnel_route_get_tunnel_route_by_ip_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteGetTunnelRouteByIpArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTeamnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/routes/ip/{}",
args.account_id, args.ip,
);
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("virtual_network_id", args.virtual_network_id.as_deref());
builder = builder.query(
"default_virtual_network_fallback",
args.default_virtual_network_fallback.as_deref(),
);
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tunnel_route_get_tunnel_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteGetTunnelRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelRouteResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/routes/{}",
args.account_id, args.route_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 tunnel_route_update_a_tunnel_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteUpdateATunnelRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelRouteResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/routes/{}",
args.account_id, args.route_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 tunnel_route_delete_a_tunnel_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelRouteDeleteATunnelRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelRouteResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/routes/{}",
args.account_id, args.route_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 tunnel_virtual_network_list_virtual_networks_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelVirtualNetworkListVirtualNetworksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelVnetResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/teamnet/virtual_networks", 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("name", args.name.as_deref());
builder = builder.query("is_default", args.is_default.as_deref());
builder = builder.query("is_default_network", args.is_default_network.as_deref());
builder = builder.query("is_deleted", args.is_deleted.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn tunnel_virtual_network_create_a_virtual_network_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelVirtualNetworkCreateAVirtualNetworkArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelVnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/teamnet/virtual_networks", 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 tunnel_virtual_network_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelVirtualNetworkGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelVnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/virtual_networks/{}",
args.account_id, args.virtual_network_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
.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 tunnel_virtual_network_update_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelVirtualNetworkUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelVnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/virtual_networks/{}",
args.account_id, args.virtual_network_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 tunnel_virtual_network_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TunnelVirtualNetworkDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelVnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/teamnet/virtual_networks/{}",
args.account_id, args.virtual_network_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 cloudflare_tunnel_list_warp_connector_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelListWarpConnectorTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelWarpConnectorResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/warp_connector", 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("name", args.name.as_deref());
builder = builder.query("is_deleted", args.is_deleted.as_deref());
builder = builder.query("existed_at", args.existed_at.as_deref());
builder = builder.query("uuid", args.uuid.as_deref());
builder = builder.query("was_active_at", args.was_active_at.as_deref());
builder = builder.query("was_inactive_at", args.was_inactive_at.as_deref());
builder = builder.query("include_prefix", args.include_prefix.as_deref());
builder = builder.query("exclude_prefix", args.exclude_prefix.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn cloudflare_tunnel_create_a_warp_connector_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelCreateAWarpConnectorTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelWarpConnectorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/warp_connector", 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 cloudflare_tunnel_get_a_warp_connector_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetAWarpConnectorTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelWarpConnectorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_update_a_warp_connector_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelUpdateAWarpConnectorTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelWarpConnectorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_delete_a_warp_connector_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelDeleteAWarpConnectorTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelWarpConnectorResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}",
args.account_id, args.tunnel_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 cloudflare_tunnel_list_warp_connector_tunnel_connections_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelListWarpConnectorTunnelConnectionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelWarpConnectorConnectionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}/connections",
args.account_id, args.tunnel_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 cloudflare_tunnel_get_warp_connector_tunnel_connector_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetWarpConnectorTunnelConnectorArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelWarpConnectorClientResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}/connectors/{}",
args.account_id, args.tunnel_id, args.connector_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 cloudflare_tunnel_manual_failover_warp_connector_tunnel_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelManualFailoverWarpConnectorTunnelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelEmptyResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}/failover",
args.account_id, args.tunnel_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 cloudflare_tunnel_get_a_warp_connector_tunnel_token_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelGetAWarpConnectorTunnelTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelResponseToken>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/warp_connector/{}/token",
args.account_id, args.tunnel_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 zero_trust_accounts_get_connectivity_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustAccountsGetConnectivitySettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelZeroTrustConnectivitySettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/zerotrust/connectivity_settings",
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 zero_trust_accounts_patch_connectivity_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustAccountsPatchConnectivitySettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelZeroTrustConnectivitySettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/zerotrust/connectivity_settings",
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);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn zero_trust_networks_subnet_create_warp_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustNetworksSubnetCreateWarpArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelSubnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/zerotrust/subnets/warp", 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 zero_trust_networks_subnet_get_warp_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustNetworksSubnetGetWarpArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelSubnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/zerotrust/subnets/warp/{}",
args.account_id, args.subnet_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 zero_trust_networks_subnet_update_warp_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustNetworksSubnetUpdateWarpArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelSubnetResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/zerotrust/subnets/warp/{}",
args.account_id, args.subnet_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 zero_trust_networks_subnet_delete_warp_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ZeroTrustNetworksSubnetDeleteWarpArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelSubnetResponseSingleNullable>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/zerotrust/subnets/warp/{}",
args.account_id, args.subnet_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 radar_get_bgp_hijacks_events_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpHijacksEventsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpHijacksEventsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/hijacks/events",);
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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("eventId", args.event_id.as_deref());
builder = builder.query("hijackerAsn", args.hijacker_asn.as_deref());
builder = builder.query("victimAsn", args.victim_asn.as_deref());
builder = builder.query("involvedAsn", args.involved_asn.as_deref());
builder = builder.query("involvedCountry", args.involved_country.as_deref());
builder = builder.query("prefix", args.prefix.as_deref());
builder = builder.query("minConfidence", args.min_confidence.as_deref());
builder = builder.query("maxConfidence", args.max_confidence.as_deref());
builder = builder.query("dateRange", args.date_range.as_deref());
builder = builder.query("dateStart", args.date_start.as_deref());
builder = builder.query("dateEnd", args.date_end.as_deref());
builder = builder.query("sortBy", args.sort_by.as_deref());
builder = builder.query("sortOrder", args.sort_order.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_ips_timeseries_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpIpsTimeseriesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpIpsTimeseriesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/ips/timeseries",);
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.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
for value in &args.location {
builder = builder.query("location", Some(value.as_str()));
}
for value in &args.ip_version {
builder = builder.query("ipVersion", Some(value.as_str()));
}
builder = builder.query("includeDelay", args.include_delay.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_route_leak_events_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRouteLeakEventsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRouteLeakEventsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/leaks/events",);
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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("eventId", args.event_id.as_deref());
builder = builder.query("leakAsn", args.leak_asn.as_deref());
builder = builder.query("involvedAsn", args.involved_asn.as_deref());
builder = builder.query("involvedCountry", args.involved_country.as_deref());
builder = builder.query("dateRange", args.date_range.as_deref());
builder = builder.query("dateStart", args.date_start.as_deref());
builder = builder.query("dateEnd", args.date_end.as_deref());
builder = builder.query("sortBy", args.sort_by.as_deref());
builder = builder.query("sortOrder", args.sort_order.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_routes_asns_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRoutesAsnsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRoutesAsnsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/routes/ases",);
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("location", args.location.as_deref());
builder = builder.query("limit", args.limit.as_deref());
builder = builder.query("sortBy", args.sort_by.as_deref());
builder = builder.query("sortOrder", args.sort_order.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_pfx2as_moas_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpPfx2AsMoasArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpPfx2asMoasResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/routes/moas",);
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("origin", args.origin.as_deref());
builder = builder.query("prefix", args.prefix.as_deref());
builder = builder.query("invalid_only", args.invalid_only.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_pfx2as_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpPfx2AsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpPfx2asResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/routes/pfx2as",);
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("prefix", args.prefix.as_deref());
builder = builder.query("origin", args.origin.as_deref());
builder = builder.query("rpkiStatus", args.rpki_status.as_deref());
builder = builder.query("longestPrefixMatch", args.longest_prefix_match.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_routes_stats_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRoutesStatsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRoutesStatsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/routes/stats",);
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("asn", args.asn.as_deref());
builder = builder.query("location", args.location.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_rpki_aspa_changes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRpkiAspaChangesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRpkiAspaChangesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/rpki/aspa/changes",);
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("dateStart", args.date_start.as_deref());
builder = builder.query("dateEnd", args.date_end.as_deref());
builder = builder.query("asn", args.asn.as_deref());
builder = builder.query("includeAsnInfo", args.include_asn_info.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_rpki_aspa_snapshot_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRpkiAspaSnapshotArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRpkiAspaSnapshotResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/rpki/aspa/snapshot",);
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("customerAsn", args.customer_asn.as_deref());
builder = builder.query("providerAsn", args.provider_asn.as_deref());
builder = builder.query("date", args.date.as_deref());
builder = builder.query("includeAsnInfo", args.include_asn_info.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_rpki_aspa_timeseries_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpRpkiAspaTimeseriesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpRpkiAspaTimeseriesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/rpki/aspa/timeseries",);
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("dateStart", args.date_start.as_deref());
builder = builder.query("dateEnd", args.date_end.as_deref());
for value in &args.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.rir {
builder = builder.query("rir", Some(value.as_str()));
}
for value in &args.location {
builder = builder.query("location", Some(value.as_str()));
}
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_timeseries_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpTimeseriesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpTimeseriesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/timeseries",);
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("aggInterval", args.agg_interval.as_deref());
for value in &args.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.prefix {
builder = builder.query("prefix", Some(value.as_str()));
}
for value in &args.update_type {
builder = builder.query("updateType", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_top_ases_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpTopAsesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpTopAsesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/top/ases",);
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());
for value in &args.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
for value in &args.prefix {
builder = builder.query("prefix", Some(value.as_str()));
}
for value in &args.update_type {
builder = builder.query("updateType", Some(value.as_str()));
}
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_top_asns_by_prefixes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpTopAsnsByPrefixesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpTopAsnsByPrefixesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/top/ases/prefixes",);
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("country", args.country.as_deref());
builder = builder.query("limit", args.limit.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_bgp_top_prefixes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetBgpTopPrefixesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetBgpTopPrefixesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/bgp/top/prefixes",);
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());
for value in &args.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
for value in &args.update_type {
builder = builder.query("updateType", Some(value.as_str()));
}
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_quality_index_summary_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetQualityIndexSummaryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetQualityIndexSummaryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/quality/iqi/summary",);
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.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
for value in &args.location {
builder = builder.query("location", Some(value.as_str()));
}
for value in &args.continent {
builder = builder.query("continent", Some(value.as_str()));
}
builder = builder.query("metric", args.metric.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn radar_get_quality_index_timeseries_group_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &RadarGetQualityIndexTimeseriesGroupArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<RadarGetQualityIndexTimeseriesGroupResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/radar/quality/iqi/timeseries_groups",);
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("aggInterval", args.agg_interval.as_deref());
for value in &args.name {
builder = builder.query("name", Some(value.as_str()));
}
for value in &args.date_range {
builder = builder.query("dateRange", Some(value.as_str()));
}
for value in &args.date_start {
builder = builder.query("dateStart", Some(value.as_str()));
}
for value in &args.date_end {
builder = builder.query("dateEnd", Some(value.as_str()));
}
for value in &args.asn {
builder = builder.query("asn", Some(value.as_str()));
}
for value in &args.location {
builder = builder.query("location", Some(value.as_str()));
}
for value in &args.continent {
builder = builder.query("continent", Some(value.as_str()));
}
builder = builder.query("interpolation", args.interpolation.as_deref());
builder = builder.query("metric", args.metric.as_deref());
builder = builder.query("format", args.format.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn spectrum_aggregate_analytics_get_current_aggregated_analytics_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpectrumAggregateAnalyticsGetCurrentAggregatedAnalyticsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<SpectrumAnalyticsQueryResponseAggregate>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/spectrum/analytics/aggregate/current",
args.zone_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("appID", args.app_id.as_deref());
builder = builder.query("colo_name", args.colo_name.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}