#![cfg(feature = "cloudflare_workers")]
#![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::AccessApiResponseCollection;
use super::shared::AccessApiResponseCommon;
use super::shared::AccessApiResponseSingle;
use super::shared::AccessComponentsSchemasIdResponse;
use super::shared::AccessUuid;
use super::shared::AddressingApiResponseCommon;
use super::shared::ObservatoryApiResponseCommon;
use super::shared::ObservatoryApiResponseSingle;
use super::shared::ObservatoryCountResponse;
use super::shared::ApiResponse;
pub type AccessCreatedAt = super::shared::EmptyObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccessCustomPage {
pub app_count: Option<i64>,
pub created_at: Option<AccessCreatedAt>,
pub custom_html: String,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub uid: Option<String>,
pub updated_at: Option<AccessUpdatedAt>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AccessCustomPageWithoutHtml {
pub app_count: Option<i64>,
pub created_at: Option<AccessCreatedAt>,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub uid: Option<String>,
pub updated_at: Option<AccessUpdatedAt>,
}
pub type AccessCustomPagesComponentsSchemasName = String;
pub type AccessCustomPagesComponentsSchemasResponseCollection =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Option<Vec<AccessCustomPageWithoutHtml>>,
>;
pub type AccessCustomPagesComponentsSchemasSingleResponse =
super::shared::ApiEnvelope<Option<AccessCustomPage>>;
pub type AccessMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type AccessSchemasAppCount = i64;
pub type AccessSchemasType = String;
pub type AccessSingleResponseWithoutHtml =
super::shared::ApiEnvelope<Option<AccessCustomPageWithoutHtml>>;
pub type AccessTimestamp = String;
pub type AccessUpdatedAt = super::shared::EmptyObject;
pub type AddressingCidr = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingCreateBindingRequest {
pub cidr: String,
pub service_id: String,
}
pub type AddressingMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingProvisioning {
pub state: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct AddressingServiceBinding {
pub cidr: Option<String>,
pub id: Option<String>,
pub provisioning: Option<AddressingProvisioning>,
pub service_id: Option<String>,
pub service_name: Option<String>,
}
pub type AddressingServiceBindingIdentifier = String;
pub type AddressingServiceIdentifier = String;
pub type AddressingServiceName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsAPIResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: Option<serde_json::Value>,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type BuildsBranch = String;
pub type BuildsBranchExcludes = Vec<String>;
pub type BuildsBranchIncludes = Vec<String>;
pub type BuildsBuildCachingEnabled = bool;
pub type BuildsBuildCommand = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsBuildLogsResponse {
pub cursor: Option<String>,
pub lines: Option<Vec<Vec<serde_json::Value>>>,
pub truncated: Option<bool>,
}
pub type BuildsBuildOutcome = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsBuildResponse {
pub build_outcome: Option<String>,
pub build_trigger_metadata: Option<BuildsBuildTriggerMetadataResponse>,
pub build_uuid: Option<String>,
pub created_on: Option<String>,
pub initializing_on: Option<String>,
pub modified_on: Option<String>,
pub pull_request: Option<std::collections::HashMap<String, serde_json::Value>>,
pub running_on: Option<String>,
pub status: Option<String>,
pub stopped_on: Option<String>,
pub trigger: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsBuildSeedRepoInput {
pub branch: String,
pub files: Option<Vec<BuildsBuildSeedRepoInputFile>>,
pub owner: String,
pub path: String,
pub provider: String,
pub repository: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsBuildSeedRepoInputFile {
pub content: String,
pub filename: String,
#[serde(rename = "isBase64")]
pub is_base64: Option<bool>,
pub replace: Option<String>,
}
pub type BuildsBuildStatus = String;
pub type BuildsBuildTokenName = String;
pub type BuildsBuildTokenUuid = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsBuildTriggerMetadataResponse {
pub author: Option<String>,
pub branch: Option<String>,
pub build_command: Option<String>,
pub build_token_name: Option<String>,
pub build_token_uuid: Option<String>,
pub build_trigger_source: Option<String>,
pub commit_hash: Option<String>,
pub commit_message: Option<String>,
pub deploy_command: Option<String>,
pub environment_variables: Option<serde_json::Value>,
pub provider_account_name: Option<String>,
pub provider_type: Option<String>,
pub repo_name: Option<String>,
pub root_directory: Option<String>,
}
pub type BuildsBuildTriggerSource = String;
pub type BuildsBuildUuid = String;
pub type BuildsBuildsByVersionResponse = super::shared::BuildsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsCanceledBuildResponse {
pub build_outcome: Option<String>,
pub build_uuid: Option<String>,
pub stopped_on: Option<String>,
}
pub type BuildsCloudflareTokenId = String;
pub type BuildsCommitHash = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsConfigAutofillResponse {
pub config_file: Option<String>,
pub default_worker_name: Option<String>,
pub env_worker_names: Option<serde_json::Value>,
pub package_manager: Option<String>,
pub scripts: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsCreateBuildRequest {
pub branch: Option<serde_json::Value>,
pub commit_hash: Option<serde_json::Value>,
pub seed_repo: Option<BuildsBuildSeedRepoInput>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsCreateBuildTokenRequest {
pub build_token_name: String,
pub build_token_secret: String,
pub cloudflare_token_id: String,
}
pub type BuildsCreateBuildTokenResponse = super::shared::BuildsCreateBuildTokenResponseShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsCreateTriggerRequest {
pub branch_excludes: Vec<String>,
pub branch_includes: Vec<String>,
pub build_caching_enabled: Option<bool>,
pub build_command: String,
pub build_token_uuid: String,
pub deploy_command: String,
pub external_script_id: String,
pub path_excludes: Vec<String>,
pub path_includes: Vec<String>,
pub repo_connection_uuid: String,
pub root_directory: String,
pub trigger_name: String,
}
pub type BuildsCreatedOn = String;
pub type BuildsCursor = String;
pub type BuildsDeletedOn = String;
pub type BuildsDeployCommand = String;
pub type BuildsEnvironmentVariablesRequest = serde_json::Value;
pub type BuildsEnvironmentVariablesResponse = serde_json::Value;
pub type BuildsExternalScriptId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsGetAccountLimitResponse {
pub build_minutes_refresh_on: Option<String>,
pub has_reached_build_minutes_limit: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsInsertBuildResponse {
pub build_uuid: Option<String>,
pub created_on: Option<String>,
}
pub type BuildsLatestBuildsResponse = super::shared::BuildsObject;
pub type BuildsListTokensResponse = super::shared::BuildsCreateBuildTokenResponseShape;
pub type BuildsModifiedOn = String;
pub type BuildsOwnerType = String;
pub type BuildsPaginationInfo = super::shared::RumResultInfoShape;
pub type BuildsPathExcludes = Vec<String>;
pub type BuildsPathIncludes = Vec<String>;
pub type BuildsProviderAccountId = String;
pub type BuildsProviderAccountName = String;
pub type BuildsRepoConnectionUuid = String;
pub type BuildsRepoId = String;
pub type BuildsRepoName = String;
pub type BuildsRootDirectory = String;
pub type BuildsSCMProviderType = String;
pub type BuildsStoppedOn = String;
pub type BuildsTriggerName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsTriggerResponse {
pub branch_excludes: Option<Vec<String>>,
pub branch_includes: Option<Vec<String>>,
pub build_caching_enabled: Option<bool>,
pub build_command: Option<String>,
pub build_token_name: Option<String>,
pub build_token_uuid: Option<String>,
pub created_on: Option<String>,
pub deleted_on: Option<String>,
pub deploy_command: Option<String>,
pub external_script_id: Option<String>,
pub modified_on: Option<String>,
pub path_excludes: Option<Vec<String>>,
pub path_includes: Option<Vec<String>>,
pub repo_connection: Option<BuildsUpsertRepoConnectionResponse>,
pub root_directory: Option<String>,
pub trigger_name: Option<String>,
pub trigger_uuid: Option<String>,
}
pub type BuildsTriggerUuid = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsUpdateTriggerRequest {
pub branch_excludes: Option<Vec<String>>,
pub branch_includes: Option<Vec<String>>,
pub build_caching_enabled: Option<bool>,
pub build_command: Option<String>,
pub build_token_uuid: Option<String>,
pub deploy_command: Option<String>,
pub path_excludes: Option<Vec<String>>,
pub path_includes: Option<Vec<String>>,
pub root_directory: Option<String>,
pub trigger_name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsUpsertRepoConnectionRequest {
pub provider_account_id: String,
pub provider_account_name: String,
pub provider_type: String,
pub repo_id: String,
pub repo_name: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct BuildsUpsertRepoConnectionResponse {
pub created_on: Option<String>,
pub deleted_on: Option<String>,
pub modified_on: Option<String>,
pub provider_account_id: Option<String>,
pub provider_account_name: Option<String>,
pub provider_type: Option<String>,
pub repo_connection_uuid: Option<String>,
pub repo_id: Option<String>,
pub repo_name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CancelBuildByUuidResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsCanceledBuildResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type CcAccountID = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcAccountRegistryToken {
pub account_id: String,
pub password: Option<String>,
pub registry_host: String,
pub username: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcApplicationHealthInstances {
pub active: i64,
pub assigned: i64,
}
pub type CcApplicationID = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcApplicationNetwork {
pub bandwidth_limit_mbps: i64,
}
pub type CcApplicationRolloutActiveGracePeriod = i64;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcCustomResourceAllocation {
pub disk_mb: i64,
pub memory_mib: i64,
pub vcpu: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcDurableObjectsConfigurationNamespaceId {
pub namespace_id: String,
}
pub type CcGenerateImageRegistryCredentialsResponse201Response =
super::shared::ApiEnvelope<CcAccountRegistryToken>;
pub type CcISO8601Timestamp = String;
pub type CcImage = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcImageRegistryCredentialsConfiguration {
pub expiration_minutes: i64,
pub permissions: Vec<String>,
}
pub type CcImageRegistryPermissions = String;
pub type CcInstanceType = String;
pub type CcMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcObservability {
pub logs: Option<CcObservabilityLogs>,
}
pub type CcObservabilityLogs = super::shared::EnabledObject2;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcPublicApplication {
pub created_at: String,
pub durable_object: Option<CcDurableObjectsConfigurationNamespaceId>,
pub health: CcApplicationHealthInstances,
pub id: String,
pub image: String,
pub instance_type: serde_json::Value,
pub max_instances: i64,
pub name: String,
pub network: Option<CcApplicationNetwork>,
pub observability: Option<CcObservability>,
pub rollout_active_grace_period: Option<i64>,
pub updated_at: String,
pub version: i64,
}
pub type CcPublicInstanceType = serde_json::Value;
pub type CcPublicListApplicationsResponse200Response =
super::shared::ApiEnvelope<Vec<CcPublicApplication>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CcPublicListApplicationsResult {
pub result: Vec<CcPublicApplication>,
}
pub type CcV4BaseResponse = super::shared::ErrorsMessagesSuccessObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesConnectionSchema {
pub fields: Option<Vec<Box<CloudflarePipelinesSourceField>>>,
pub format: Option<serde_json::Value>,
pub inferred: Option<bool>,
}
pub type CloudflarePipelinesDecimalEncoding = String;
pub type CloudflarePipelinesFieldType = serde_json::Value;
pub type CloudflarePipelinesFormat = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesJsonFormat {
pub decimal_encoding: Option<String>,
pub timestamp_format: Option<String>,
pub unstructured: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesListField {
pub items: Box<CloudflarePipelinesSourceField>,
}
pub type CloudflarePipelinesParquetCompression = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesParquetFormat {
pub compression: Option<String>,
pub row_group_bytes: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesPipelineEdge {
pub dest_id: i64,
pub edge_type: String,
pub key_type: String,
pub src_id: i64,
pub value_type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesPipelineGraph {
pub edges: Vec<CloudflarePipelinesPipelineEdge>,
pub nodes: Vec<CloudflarePipelinesPipelineNode>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesPipelineNode {
pub description: String,
pub node_id: i64,
pub operator: String,
pub parallelism: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesSourceField {
pub metadata_key: Option<String>,
pub name: String,
pub required: Option<bool>,
pub sql_name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesStructField {
pub fields: Vec<Box<CloudflarePipelinesSourceField>>,
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CloudflarePipelinesTimestampField {
pub unit: Option<String>,
}
pub type CloudflarePipelinesTimestampFormat = String;
pub type CloudflarePipelinesTimestampUnit = String;
pub type CloudflarePipelinesWorkerPipelinesCommonSuccess = bool;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateBuildTokenResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsCreateBuildTokenResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type CreateHyperdriveResponse = super::shared::ApiEnvelope<HyperdriveHyperdriveConfigResponse>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateManualBuildResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsInsertBuildResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateTriggerResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsTriggerResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type CreateWorkerRequest = super::shared::CreateWorkerRequestShape;
pub type CreateWorkerResponse = super::shared::ApiEnvelope<WorkersWorker>;
pub type CreateWorkerVersionResponse = super::shared::ApiEnvelope<WorkersVersion>;
pub type CustomAssetsForAZoneCreateACustomAssetRequest = super::shared::DescriptionNameUrlObject;
pub type CustomAssetsForAZoneUpdateACustomAssetRequest = super::shared::DescriptionUrlObject;
pub type CustomAssetsForAnAccountCreateACustomAssetRequest =
super::shared::DescriptionNameUrlObject;
pub type CustomAssetsForAnAccountUpdateACustomAssetRequest = super::shared::DescriptionUrlObject;
pub type CustomPagesApiResponseCollection = super::shared::AddressingApiResponseCollectionShape;
pub type CustomPagesApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type CustomPagesApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type CustomPagesAssetDescription = String;
pub type CustomPagesAssetName = String;
pub type CustomPagesAssetUrl = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CustomPagesCustomAsset {
pub description: Option<String>,
pub last_updated: Option<String>,
pub name: Option<String>,
pub size_bytes: Option<i64>,
pub url: Option<String>,
}
pub type CustomPagesCustomAssetResult = super::shared::ApiEnvelope<Option<CustomPagesCustomAsset>>;
pub type CustomPagesCustomAssetResultList =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<CustomPagesCustomAsset>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CustomPagesCustomPage {
pub created_on: Option<String>,
pub description: Option<String>,
pub id: Option<String>,
pub modified_on: Option<String>,
pub preview_target: Option<String>,
pub required_tokens: Option<Vec<String>>,
pub state: Option<String>,
pub url: Option<String>,
}
pub type CustomPagesCustomPageResult = super::shared::ApiEnvelope<Option<CustomPagesCustomPage>>;
pub type CustomPagesCustomPageResultList =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<CustomPagesCustomPage>>>;
pub type CustomPagesForAZoneUpdateACustomPageRequest = super::shared::StateUrlObject;
pub type CustomPagesForAnAccountUpdateACustomPageRequest = super::shared::StateUrlObject;
pub type CustomPagesMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type CustomPagesState = String;
pub type CustomPagesTimestamp = String;
pub type CustomPagesUrl = String;
pub type D1ApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type D1BatchQuery = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1CreateDatabaseRequest {
pub jurisdiction: Option<String>,
pub name: String,
pub primary_location_hint: Option<String>,
}
pub type D1CreateDatabaseResponse = super::shared::ApiEnvelope<D1DatabaseDetailsResponse>;
pub type D1CreatedAt = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1DatabaseDetailsResponse {
pub created_at: Option<String>,
pub file_size: Option<f64>,
pub jurisdiction: Option<String>,
pub name: Option<String>,
pub num_tables: Option<f64>,
pub read_replication: Option<D1ReadReplicationDetails>,
pub uuid: Option<String>,
pub version: Option<String>,
}
pub type D1DatabaseIdentifier = String;
pub type D1DatabaseName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1DatabaseResponse {
pub created_at: Option<String>,
pub jurisdiction: Option<String>,
pub name: Option<String>,
pub uuid: Option<String>,
pub version: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1DatabaseUpdatePartialRequestBody {
pub read_replication: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1DatabaseUpdateRequestBody {
pub read_replication: std::collections::HashMap<String, serde_json::Value>,
}
pub type D1DatabaseVersion = String;
pub type D1DeleteDatabaseResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1ExportDatabaseRequest {
pub current_bookmark: Option<String>,
pub dump_options: Option<D1ExportDatabaseRequestDumpOptions>,
pub output_format: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1ExportDatabaseRequestDumpOptions {
pub no_data: Option<bool>,
pub no_schema: Option<bool>,
pub tables: Option<Vec<String>>,
}
pub type D1ExportDatabaseResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type D1FileSize = f64;
pub type D1GetDatabaseResponse = super::shared::ApiEnvelope<D1DatabaseDetailsResponse>;
pub type D1ImportDatabaseRequest = serde_json::Value;
pub type D1ImportDatabaseResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type D1Jurisdiction = String;
pub type D1JurisdictionNullable = String;
pub type D1ListDatabasesResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<D1DatabaseResponse>>;
pub type D1Messages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type D1Params = Vec<String>;
pub type D1PrimaryLocationHint = String;
pub type D1QueryDatabaseResponse = super::shared::ApiEnvelope<Vec<D1QueryResultResponse>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1QueryMeta {
pub changed_db: Option<bool>,
pub changes: Option<f64>,
pub duration: Option<f64>,
pub last_row_id: Option<f64>,
pub rows_read: Option<f64>,
pub rows_written: Option<f64>,
pub served_by_colo: Option<String>,
pub served_by_primary: Option<bool>,
pub served_by_region: Option<String>,
pub size_after: Option<f64>,
pub timings: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1QueryResultResponse {
pub meta: Option<D1QueryMeta>,
pub results: Option<Vec<serde_json::Value>>,
pub success: Option<bool>,
}
pub type D1RawDatabaseQueryResponse = super::shared::ApiEnvelope<Vec<D1RawResultResponse>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1RawResultResponse {
pub meta: Option<D1QueryMeta>,
pub results: Option<std::collections::HashMap<String, serde_json::Value>>,
pub success: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1ReadReplicationDetails {
pub mode: String,
}
pub type D1ReadReplicationMode = String;
pub type D1ServedByColo = String;
pub type D1ServedByRegion = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1SingleQuery {
pub params: Option<Vec<String>>,
pub sql: String,
}
pub type D1Sql = String;
pub type D1TableCount = f64;
pub type D1TimeTravelBookmark = String;
pub type D1TimeTravelGetBookmarkResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct D1TimeTravelRestoreResponse {
pub bookmark: Option<serde_json::Value>,
pub message: Option<String>,
pub previous_bookmark: Option<serde_json::Value>,
}
pub type D1TimeTravelRestoreResponse2 = super::shared::ApiEnvelope<D1TimeTravelRestoreResponse>;
pub type D1UpdateDatabaseResponse = super::shared::ApiEnvelope<D1DatabaseDetailsResponse>;
pub type D1UpdatePartialDatabaseResponse = super::shared::ApiEnvelope<D1DatabaseDetailsResponse>;
pub type DeleteHyperdriveResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationCreateRequest {
pub configuration: DestinationCreateRequestConfiguration,
pub enabled: bool,
pub name: String,
#[serde(rename = "skipPreflightCheck")]
pub skip_preflight_check: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationCreateRequestConfiguration {
pub headers: serde_json::Value,
#[serde(rename = "logpushDataset")]
pub logpush_dataset: serde_json::Value,
#[serde(rename = "type")]
pub r#type: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationCreateResponse {
pub errors: Vec<DestinationCreateResponseErrorsItem>,
pub messages: Vec<DestinationCreateResponseMessagesItem>,
pub result: DestinationCreateResponseResult,
pub success: bool,
}
pub type DestinationCreateResponseErrorsItem = super::shared::MessageObject;
pub type DestinationCreateResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationCreateResponseResult {
pub configuration: DestinationCreateResponseResultConfiguration,
pub enabled: bool,
pub name: String,
pub scripts: Vec<String>,
pub slug: String,
}
pub type DestinationCreateResponseResultConfiguration =
super::shared::DestinationCreateResponseResultConfigurationShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationListResponse {
pub errors: Vec<DestinationListResponseErrorsItem>,
pub messages: Vec<DestinationListResponseMessagesItem>,
pub result: Vec<DestinationListResponseResultItem>,
pub success: bool,
}
pub type DestinationListResponseErrorsItem = super::shared::MessageObject;
pub type DestinationListResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationListResponseResultItem {
pub configuration: DestinationListResponseResultItemConfiguration,
pub enabled: bool,
pub name: String,
pub scripts: Vec<String>,
pub slug: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationListResponseResultItemConfiguration {
pub destination_conf: String,
pub headers: serde_json::Value,
#[serde(rename = "jobStatus")]
pub job_status: DestinationListResponseResultItemConfigurationJobStatus,
#[serde(rename = "logpushDataset")]
pub logpush_dataset: serde_json::Value,
#[serde(rename = "type")]
pub r#type: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationListResponseResultItemConfigurationJobStatus {
pub error_message: String,
pub last_complete: String,
pub last_error: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationUpdateRequest {
pub configuration: DestinationUpdateRequestConfiguration,
pub enabled: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationUpdateRequestConfiguration {
pub headers: serde_json::Value,
#[serde(rename = "type")]
pub r#type: String,
pub url: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationUpdateResponse {
pub errors: Vec<DestinationUpdateResponseErrorsItem>,
pub messages: Vec<DestinationUpdateResponseMessagesItem>,
pub result: DestinationUpdateResponseResult,
pub success: bool,
}
pub type DestinationUpdateResponseErrorsItem = super::shared::MessageObject;
pub type DestinationUpdateResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationUpdateResponseResult {
pub configuration: DestinationUpdateResponseResultConfiguration,
pub enabled: bool,
pub name: String,
pub scripts: Vec<String>,
pub slug: String,
}
pub type DestinationUpdateResponseResultConfiguration =
super::shared::DestinationCreateResponseResultConfigurationShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationsDeleteResponse {
pub errors: Vec<DestinationsDeleteResponseErrorsItem>,
pub messages: Vec<DestinationsDeleteResponseMessagesItem>,
pub result: Option<DestinationsDeleteResponseResult>,
pub success: bool,
}
pub type DestinationsDeleteResponseErrorsItem = super::shared::MessageObject;
pub type DestinationsDeleteResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct DestinationsDeleteResponseResult {
pub configuration: DestinationsDeleteResponseResultConfiguration,
pub enabled: bool,
pub name: String,
pub scripts: Vec<String>,
pub slug: String,
}
pub type DestinationsDeleteResponseResultConfiguration =
super::shared::DestinationCreateResponseResultConfigurationShape;
pub type DurableObjectsNamespaceListNamespacesResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<WorkersNamespace>>>;
pub type DurableObjectsNamespaceListObjectsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Option<Vec<WorkersObject>>>;
pub type EditWorkerRequest = super::shared::CreateWorkerRequestShape;
pub type EditWorkerResponse = super::shared::ApiEnvelope<WorkersWorker>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetAccountLimitsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsGetAccountLimitResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetBuildByUuidResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsBuildResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetBuildLogsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsBuildLogsResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetBuildsByVersionIdsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsBuildsByVersionResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type GetHyperdriveResponse = super::shared::ApiEnvelope<HyperdriveHyperdriveConfigResponse>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetLatestBuildsByScriptsResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsLatestBuildsResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponse =
super::shared::ApiEnvelopeSuccess<
GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponseResult,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponseResult {
pub created_at: String,
pub failure_reason: Option<String>,
pub id: String,
pub modified_at: String,
pub name: String,
pub sql: String,
pub status: String,
pub tables:
Vec<GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponseResultTablesItem>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponseResultTablesItem {
pub id: String,
pub latest: i64,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub version: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1PipelinesResponse {
pub result: Vec<GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultItem>,
pub result_info: GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultInfo,
pub success: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultInfo =
super::shared::AigConfigListEvaluatorsResponseResultInfoShape;
pub type GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultItem =
super::shared::GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultItemShape;
pub type GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponse =
super::shared::ApiEnvelopeSuccess<
GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponseResult,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponseResult {
pub config: Option<serde_json::Value>,
pub created_at: String,
pub format: Option<serde_json::Value>,
pub id: String,
pub modified_at: String,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1SinksResponse {
pub result: Vec<GetV4AccountsByAccountIdPipelinesV1SinksResponseResultItem>,
pub result_info: GetV4AccountsByAccountIdPipelinesV1SinksResponseResultInfo,
pub success: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1SinksResponseResultInfo =
super::shared::AigConfigListEvaluatorsResponseResultInfoShape;
pub type GetV4AccountsByAccountIdPipelinesV1SinksResponseResultItem =
GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponseResult;
pub type GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponse =
super::shared::ApiEnvelopeSuccess<
GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResult,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResult {
pub created_at: String,
pub endpoint: Option<String>,
pub format: Option<serde_json::Value>,
pub http: GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttp,
pub id: String,
pub modified_at: String,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
pub version: i64,
pub worker_binding:
GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultWorkerBinding,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttp {
pub authentication: bool,
pub cors: Option<GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttpCors>,
pub enabled: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttpCors =
super::shared::OriginsObject;
pub type GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultWorkerBinding =
super::shared::EnabledObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsResponse {
pub result: Vec<GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItem>,
pub result_info: GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultInfo,
pub success: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultInfo =
super::shared::AigConfigListEvaluatorsResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItem {
pub created_at: String,
pub endpoint: Option<String>,
pub format: Option<serde_json::Value>,
pub http: GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemHttp,
pub id: String,
pub modified_at: String,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
pub version: i64,
pub worker_binding: GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemWorkerBinding,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemHttp {
pub authentication: bool,
pub cors: Option<GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemHttpCors>,
pub enabled: bool,
}
pub type GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemHttpCors =
super::shared::OriginsObject;
pub type GetV4AccountsByAccountIdPipelinesV1StreamsResponseResultItemWorkerBinding =
super::shared::EnabledObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GetWorkerConfigAutofillResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsConfigAutofillResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type GetWorkerResponse = super::shared::ApiEnvelope<WorkersWorker>;
pub type GetWorkerVersionResponse = super::shared::ApiEnvelope<WorkersVersion>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveApiResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: serde_json::Value,
pub result_info: Option<HyperdriveResultInfo>,
pub success: bool,
}
pub type HyperdriveApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type HyperdriveApiResponseSingle = super::shared::ApiEnvelope<serde_json::Value>;
pub type HyperdriveHyperdriveCaching = serde_json::Value;
pub type HyperdriveHyperdriveCachingCommon = super::shared::DisabledObject;
pub type HyperdriveHyperdriveCachingDisabled = super::shared::DisabledObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveHyperdriveCachingEnabled {
pub disabled: Option<bool>,
pub max_age: Option<i64>,
pub stale_while_revalidate: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveHyperdriveConfig {
pub caching: Option<serde_json::Value>,
pub created_on: Option<String>,
pub id: String,
pub modified_on: Option<String>,
pub mtls: Option<HyperdriveHyperdriveMtls>,
pub name: String,
pub origin: serde_json::Value,
pub origin_connection_limit: Option<i64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveHyperdriveConfigPatch {
pub caching: Option<serde_json::Value>,
pub mtls: Option<HyperdriveHyperdriveMtls>,
pub name: Option<String>,
pub origin: Option<serde_json::Value>,
pub origin_connection_limit: Option<i64>,
}
pub type HyperdriveHyperdriveConfigResponse = HyperdriveHyperdriveConfig;
pub type HyperdriveHyperdriveDatabase = super::shared::HyperdriveHyperdriveDatabaseShape;
pub type HyperdriveHyperdriveDatabaseFull = super::shared::HyperdriveHyperdriveDatabaseShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveHyperdriveMtls {
pub ca_certificate_id: Option<String>,
pub mtls_certificate_id: Option<String>,
pub sslmode: Option<String>,
}
pub type HyperdriveHyperdriveName = String;
pub type HyperdriveHyperdriveOriginConnectionLimit = i64;
pub type HyperdriveHyperdriveScheme = String;
pub type HyperdriveIdentifier = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveInternetOrigin {
pub host: String,
pub port: i64,
}
pub type HyperdriveMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HyperdriveOverAccessOrigin {
pub access_client_id: String,
pub access_client_secret: String,
pub host: String,
}
pub type HyperdriveResultInfo = super::shared::FirewallResultInfoShape;
pub type IpAddressManagementServiceBindingsCreateServiceBindingResponse =
super::shared::ApiEnvelope<Option<AddressingServiceBinding>>;
pub type IpAddressManagementServiceBindingsGetServiceBindingResponse =
super::shared::ApiEnvelope<Option<AddressingServiceBinding>>;
pub type IpAddressManagementServiceBindingsListServiceBindingsResponse =
super::shared::ApiEnvelope<Option<Vec<AddressingServiceBinding>>>;
pub type IpAddressManagementServiceBindingsListServicesResponse =
super::shared::ApiEnvelope<Option<Vec<serde_json::Value>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ListBuildTokensResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: Vec<BuildsListTokensResponse>,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ListBuildsByScriptResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: Vec<BuildsBuildResponse>,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ListEnvironmentVariablesResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: serde_json::Value,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ListHyperdriveResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<HyperdriveHyperdriveConfigResponse>,
pub result_info: Option<HyperdriveResultInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ListTriggersByScriptResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: Vec<BuildsTriggerResponse>,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type ListWorkerVersionsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<WorkersVersion>>;
pub type ListWorkersResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<WorkersWorker>>;
pub type NamespaceWorkerCreateRequest = super::shared::NameObject2;
pub type NamespaceWorkerGetScriptBindingsResponse =
super::shared::ApiEnvelope<Vec<serde_json::Value>>;
pub type NamespaceWorkerGetScriptSecretsResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type NamespaceWorkerGetScriptSettingsResponse =
super::shared::ApiEnvelope<Option<WorkersNamespaceScriptAndVersionSettingsItem>>;
pub type NamespaceWorkerGetScriptTagsResponse = super::shared::ApiEnvelope<Option<Vec<String>>>;
pub type NamespaceWorkerListScriptSecretsResponse =
super::shared::ApiEnvelope<Vec<serde_json::Value>>;
pub type NamespaceWorkerListScriptsResponse =
super::shared::ApiEnvelope<Vec<WorkersNamespaceScriptResponse>>;
pub type NamespaceWorkerPatchNamespaceRequest = super::shared::NameTrustedWorkersObject;
pub type NamespaceWorkerPatchScriptSettingsResponse =
super::shared::ApiEnvelope<Option<WorkersNamespaceScriptAndVersionSettingsItem>>;
pub type NamespaceWorkerPutNamespaceRequest = super::shared::NameTrustedWorkersObject;
pub type NamespaceWorkerPutScriptSecretsResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type NamespaceWorkerPutScriptTagsResponse = super::shared::ApiEnvelope<Vec<String>>;
pub type ObservatoryApiResponseCollection = super::shared::ErrorsMessagesSuccessObject;
pub type ObservatoryDeviceType = String;
pub type ObservatoryLabeledRegion = super::shared::LabelValueObject;
pub type ObservatoryLighthouseErrorCode = String;
pub type ObservatoryLighthouseReport = super::shared::ObservatoryLighthouseReportShape;
pub type ObservatoryLighthouseState = String;
pub type ObservatoryMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ObservatoryPageTest {
pub date: Option<String>,
#[serde(rename = "desktopReport")]
pub desktop_report: Option<ObservatoryLighthouseReport>,
pub id: Option<String>,
#[serde(rename = "mobileReport")]
pub mobile_report: Option<ObservatoryLighthouseReport>,
pub region: Option<ObservatoryLabeledRegion>,
#[serde(rename = "scheduleFrequency")]
pub schedule_frequency: Option<String>,
pub url: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ObservatoryPageTestResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<ObservatoryPageTest>>,
pub result_info: Option<ObservatoryResultInfo>,
pub success: bool,
}
pub type ObservatoryPageTestResponseSingle =
super::shared::ApiEnvelope<Option<ObservatoryPageTest>>;
pub type ObservatoryPagesResponseCollection =
super::shared::ApiEnvelope<Option<Vec<std::collections::HashMap<String, serde_json::Value>>>>;
pub type ObservatoryRegion = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ObservatoryResultInfo {
pub count: Option<i64>,
pub page: Option<i64>,
pub per_page: Option<i64>,
pub total_count: Option<i64>,
}
pub type ObservatoryScheduleFrequency = String;
pub type ObservatoryTimestamp = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ObservatoryTrend {
pub cls: Option<Vec<f64>>,
pub fcp: Option<Vec<f64>>,
pub lcp: Option<Vec<f64>>,
#[serde(rename = "performanceScore")]
pub performance_score: Option<Vec<f64>>,
pub si: Option<Vec<f64>>,
pub tbt: Option<Vec<f64>>,
pub ttfb: Option<Vec<f64>>,
pub tti: Option<Vec<f64>>,
}
pub type ObservatoryTrendResponse = super::shared::ApiEnvelope<Option<ObservatoryTrend>>;
pub type ObservatoryUrl = String;
pub type ObservatoryUuid = String;
pub type PagesApiResponseCollection = super::shared::AddressingApiResponseCollectionShape;
pub type PagesApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type PagesBuildConfig = super::shared::PagesBuildConfigShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesDeployment {
pub aliases: Option<Vec<String>>,
pub build_config: PagesBuildConfig,
pub created_on: String,
pub deployment_trigger: std::collections::HashMap<String, serde_json::Value>,
pub env_vars: Option<serde_json::Value>,
pub environment: String,
pub id: String,
pub is_skipped: bool,
pub latest_stage: PagesStage,
pub modified_on: String,
pub project_id: String,
pub project_name: String,
pub short_id: String,
pub source: PagesSource,
pub stages: Vec<PagesStage>,
pub url: String,
pub uses_functions: Option<bool>,
}
pub type PagesDeploymentCreateDeploymentResponse = super::shared::ApiEnvelope<PagesDeployment>;
pub type PagesDeploymentDeleteDeploymentResponse =
super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type PagesDeploymentGetDeploymentInfoResponse = super::shared::ApiEnvelope<PagesDeployment>;
pub type PagesDeploymentGetDeploymentLogsResponse = super::shared::ApiEnvelope<PagesDeploymentLog>;
pub type PagesDeploymentGetDeploymentsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<PagesDeployment>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesDeploymentLog {
pub data: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub includes_container_logs: bool,
pub total: i64,
}
pub type PagesDeploymentRetryDeploymentResponse = super::shared::ApiEnvelope<PagesDeployment>;
pub type PagesDeploymentRollbackDeploymentResponse = super::shared::ApiEnvelope<PagesDeployment>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesDomain {
pub certificate_authority: String,
pub created_on: String,
pub domain_id: String,
pub id: String,
pub name: String,
pub status: String,
pub validation_data: std::collections::HashMap<String, serde_json::Value>,
pub verification_data: std::collections::HashMap<String, serde_json::Value>,
pub zone_tag: String,
}
pub type PagesDomainName = String;
pub type PagesDomainsAddDomainRequest = super::shared::NameObject;
pub type PagesDomainsAddDomainResponse = super::shared::ApiEnvelope<PagesDomain>;
pub type PagesDomainsDeleteDomainResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type PagesDomainsGetDomainResponse = super::shared::ApiEnvelope<PagesDomain>;
pub type PagesDomainsGetDomainsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<PagesDomain>>;
pub type PagesDomainsPatchDomainResponse = super::shared::ApiEnvelope<PagesDomain>;
pub type PagesEnvVars = serde_json::Value;
pub type PagesMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesProject {
pub build_config: Option<PagesBuildConfig>,
pub canonical_deployment: serde_json::Value,
pub created_on: String,
pub deployment_configs: std::collections::HashMap<String, serde_json::Value>,
pub domains: Option<Vec<String>>,
pub framework: String,
pub framework_version: String,
pub id: String,
pub latest_deployment: serde_json::Value,
pub name: String,
pub preview_script_name: String,
pub production_branch: String,
pub production_script_name: String,
pub source: Option<PagesSource>,
pub subdomain: Option<String>,
pub uses_functions: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesProjectCreateProjectRequest {
pub build_config: Option<PagesProjectCreateProjectRequestBuildConfig>,
pub deployment_configs: Option<PagesProjectCreateProjectRequestDeploymentConfigs>,
pub name: String,
pub production_branch: String,
pub source: Option<PagesProjectCreateProjectRequestSource>,
}
pub type PagesProjectCreateProjectRequestBuildConfig = super::shared::PagesBuildConfigShape;
pub type PagesProjectCreateProjectRequestDeploymentConfigs = super::shared::PreviewProductionObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesProjectCreateProjectRequestSource {
pub config: PagesProjectCreateProjectRequestSourceConfig,
#[serde(rename = "type")]
pub r#type: String,
}
pub type PagesProjectCreateProjectRequestSourceConfig =
super::shared::PagesProjectCreateProjectRequestSourceConfigShape;
pub type PagesProjectCreateProjectResponse = super::shared::ApiEnvelope<PagesProject>;
pub type PagesProjectDeleteProjectResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type PagesProjectGetProjectResponse = super::shared::ApiEnvelope<PagesProject>;
pub type PagesProjectGetProjectsResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<PagesProject>>;
pub type PagesProjectName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesProjectUpdateProjectRequest {
pub build_config: Option<PagesProjectUpdateProjectRequestBuildConfig>,
pub deployment_configs: Option<PagesProjectUpdateProjectRequestDeploymentConfigs>,
pub name: Option<String>,
pub production_branch: Option<String>,
pub source: Option<PagesProjectUpdateProjectRequestSource>,
}
pub type PagesProjectUpdateProjectRequestBuildConfig = super::shared::PagesBuildConfigShape;
pub type PagesProjectUpdateProjectRequestDeploymentConfigs = super::shared::PreviewProductionObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesProjectUpdateProjectRequestSource {
pub config: PagesProjectUpdateProjectRequestSourceConfig,
#[serde(rename = "type")]
pub r#type: String,
}
pub type PagesProjectUpdateProjectRequestSourceConfig =
super::shared::PagesProjectCreateProjectRequestSourceConfigShape;
pub type PagesProjectUpdateProjectResponse = super::shared::ApiEnvelope<PagesProject>;
pub type PagesPurgeBuildCacheResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesSource {
pub config: std::collections::HashMap<String, serde_json::Value>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PagesStage {
pub ended_on: Option<String>,
pub name: String,
pub started_on: Option<String>,
pub status: String,
}
pub type PatchHyperdriveResponse = super::shared::ApiEnvelope<HyperdriveHyperdriveConfigResponse>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequest {
pub http: Option<PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestHttp>,
pub worker_binding:
Option<PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestWorkerBinding>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestHttp {
pub authentication: bool,
pub cors: Option<PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestHttpCors>,
pub enabled: bool,
}
pub type PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestHttpCors =
super::shared::OriginsObject;
pub type PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequestWorkerBinding =
super::shared::EnabledObject;
pub type PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponse =
super::shared::ApiEnvelopeSuccess<
PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResult,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResult {
pub created_at: String,
pub endpoint: Option<String>,
pub format: Option<serde_json::Value>,
pub http: PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttp,
pub id: String,
pub modified_at: String,
pub name: String,
pub version: i64,
pub worker_binding:
PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultWorkerBinding,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttp {
pub authentication: bool,
pub cors: Option<PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttpCors>,
pub enabled: bool,
}
pub type PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultHttpCors =
super::shared::OriginsObject;
pub type PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponseResultWorkerBinding =
super::shared::EnabledObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1PipelinesRequest {
pub name: String,
pub sql: String,
}
pub type PostV4AccountsByAccountIdPipelinesV1PipelinesResponse =
super::shared::ApiEnvelopeSuccess<PostV4AccountsByAccountIdPipelinesV1PipelinesResponseResult>;
pub type PostV4AccountsByAccountIdPipelinesV1PipelinesResponseResult =
super::shared::GetV4AccountsByAccountIdPipelinesV1PipelinesResponseResultItemShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1SinksRequest {
pub config: Option<serde_json::Value>,
pub format: Option<serde_json::Value>,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
#[serde(rename = "type")]
pub r#type: String,
}
pub type PostV4AccountsByAccountIdPipelinesV1SinksResponse =
super::shared::ApiEnvelopeSuccess<PostV4AccountsByAccountIdPipelinesV1SinksResponseResult>;
pub type PostV4AccountsByAccountIdPipelinesV1SinksResponseResult =
GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponseResult;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1StreamsRequest {
pub format: Option<serde_json::Value>,
pub http: Option<PostV4AccountsByAccountIdPipelinesV1StreamsRequestHttp>,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
pub worker_binding: Option<PostV4AccountsByAccountIdPipelinesV1StreamsRequestWorkerBinding>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1StreamsRequestHttp {
pub authentication: bool,
pub cors: Option<PostV4AccountsByAccountIdPipelinesV1StreamsRequestHttpCors>,
pub enabled: bool,
}
pub type PostV4AccountsByAccountIdPipelinesV1StreamsRequestHttpCors = super::shared::OriginsObject;
pub type PostV4AccountsByAccountIdPipelinesV1StreamsRequestWorkerBinding =
super::shared::EnabledObject;
pub type PostV4AccountsByAccountIdPipelinesV1StreamsResponse =
super::shared::ApiEnvelopeSuccess<PostV4AccountsByAccountIdPipelinesV1StreamsResponseResult>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1StreamsResponseResult {
pub created_at: String,
pub endpoint: Option<String>,
pub format: Option<serde_json::Value>,
pub http: PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultHttp,
pub id: String,
pub modified_at: String,
pub name: String,
pub schema: Option<CloudflarePipelinesConnectionSchema>,
pub version: i64,
pub worker_binding: PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultWorkerBinding,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultHttp {
pub authentication: bool,
pub cors: Option<PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultHttpCors>,
pub enabled: bool,
}
pub type PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultHttpCors =
super::shared::OriginsObject;
pub type PostV4AccountsByAccountIdPipelinesV1StreamsResponseResultWorkerBinding =
super::shared::EnabledObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1ValidateSqlRequest {
pub sql: String,
}
pub type PostV4AccountsByAccountIdPipelinesV1ValidateSqlResponse =
super::shared::ApiEnvelopeSuccess<
PostV4AccountsByAccountIdPipelinesV1ValidateSqlResponseResult,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1ValidateSqlResponseResult {
pub graph: Option<CloudflarePipelinesPipelineGraph>,
pub tables: serde_json::Value,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesDeleteResponse {
pub errors: Vec<QueriesDeleteResponseErrorsItem>,
pub messages: Vec<QueriesDeleteResponseMessagesItem>,
pub result: WorkersObservabilityQuery,
pub success: bool,
}
pub type QueriesDeleteResponseErrorsItem = super::shared::MessageObject;
pub type QueriesDeleteResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesGetResponse {
pub errors: Vec<QueriesGetResponseErrorsItem>,
pub messages: Vec<QueriesGetResponseMessagesItem>,
pub result: WorkersObservabilityQuery,
pub success: bool,
}
pub type QueriesGetResponseErrorsItem = super::shared::MessageObject;
pub type QueriesGetResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesListResponse {
pub errors: Vec<QueriesListResponseErrorsItem>,
pub messages: Vec<QueriesListResponseMessagesItem>,
pub result: Vec<WorkersObservabilityQuery>,
pub success: bool,
}
pub type QueriesListResponseErrorsItem = super::shared::MessageObject;
pub type QueriesListResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPatchRequest {
pub description: Option<String>,
pub name: String,
pub parameters: QueriesPatchRequestParameters,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPatchRequestParameters {
pub calculations: Option<Vec<QueriesPatchRequestParametersCalculationsItem>>,
pub datasets: Option<Vec<String>>,
#[serde(rename = "filterCombination")]
pub filter_combination: Option<String>,
pub filters: Option<Vec<serde_json::Value>>,
#[serde(rename = "groupBys")]
pub group_bys: Option<Vec<QueriesPatchRequestParametersGroupBysItem>>,
pub havings: Option<Vec<QueriesPatchRequestParametersHavingsItem>>,
pub limit: Option<i64>,
pub needle: Option<QueriesPatchRequestParametersNeedle>,
#[serde(rename = "orderBy")]
pub order_by: Option<QueriesPatchRequestParametersOrderBy>,
}
pub type QueriesPatchRequestParametersCalculationsItem =
super::shared::QueriesPatchRequestParametersCalculationsItemShape;
pub type QueriesPatchRequestParametersGroupBysItem = super::shared::TypeValueObject;
pub type QueriesPatchRequestParametersHavingsItem = super::shared::KeyOperationValueObject;
pub type QueriesPatchRequestParametersNeedle = super::shared::IsRegexMatchCaseValueObject;
pub type QueriesPatchRequestParametersOrderBy = super::shared::OrderValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPatchResponse {
pub errors: Vec<QueriesPatchResponseErrorsItem>,
pub messages: Vec<QueriesPatchResponseMessagesItem>,
pub result: WorkersObservabilityQuery,
pub success: bool,
}
pub type QueriesPatchResponseErrorsItem = super::shared::MessageObject;
pub type QueriesPatchResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPostRequest {
pub description: Option<String>,
pub name: String,
pub parameters: QueriesPostRequestParameters,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPostRequestParameters {
pub calculations: Option<Vec<QueriesPostRequestParametersCalculationsItem>>,
pub datasets: Option<Vec<String>>,
#[serde(rename = "filterCombination")]
pub filter_combination: Option<String>,
pub filters: Option<Vec<serde_json::Value>>,
#[serde(rename = "groupBys")]
pub group_bys: Option<Vec<QueriesPostRequestParametersGroupBysItem>>,
pub havings: Option<Vec<QueriesPostRequestParametersHavingsItem>>,
pub limit: Option<i64>,
pub needle: Option<QueriesPostRequestParametersNeedle>,
#[serde(rename = "orderBy")]
pub order_by: Option<QueriesPostRequestParametersOrderBy>,
}
pub type QueriesPostRequestParametersCalculationsItem =
super::shared::QueriesPatchRequestParametersCalculationsItemShape;
pub type QueriesPostRequestParametersGroupBysItem = super::shared::TypeValueObject;
pub type QueriesPostRequestParametersHavingsItem = super::shared::KeyOperationValueObject;
pub type QueriesPostRequestParametersNeedle = super::shared::IsRegexMatchCaseValueObject;
pub type QueriesPostRequestParametersOrderBy = super::shared::OrderValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct QueriesPostResponse {
pub errors: Vec<QueriesPostResponseErrorsItem>,
pub messages: Vec<QueriesPostResponseMessagesItem>,
pub result: WorkersObservabilityQuery,
pub success: bool,
}
pub type QueriesPostResponseErrorsItem = super::shared::MessageObject;
pub type QueriesPostResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SpeedCreateTestRequest {
pub region: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryKeysListRequest {
pub datasets: Option<Vec<String>>,
pub filters: Option<Vec<serde_json::Value>>,
pub from: Option<f64>,
#[serde(rename = "keyNeedle")]
pub key_needle: Option<TelemetryKeysListRequestKeyNeedle>,
pub limit: Option<f64>,
pub needle: Option<TelemetryKeysListRequestNeedle>,
pub to: Option<f64>,
}
pub type TelemetryKeysListRequestKeyNeedle = super::shared::IsRegexMatchCaseValueObject;
pub type TelemetryKeysListRequestNeedle = super::shared::IsRegexMatchCaseValueObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryKeysListResponse {
pub errors: Vec<TelemetryKeysListResponseErrorsItem>,
pub messages: Vec<TelemetryKeysListResponseMessagesItem>,
pub result: Vec<TelemetryKeysListResponseResultItem>,
pub success: bool,
}
pub type TelemetryKeysListResponseErrorsItem = super::shared::MessageObject;
pub type TelemetryKeysListResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryKeysListResponseResultItem {
pub key: String,
#[serde(rename = "lastSeenAt")]
pub last_seen_at: f64,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryQueryRequest {
pub chart: Option<bool>,
pub compare: Option<bool>,
pub dry: Option<bool>,
pub granularity: Option<f64>,
#[serde(rename = "ignoreSeries")]
pub ignore_series: Option<bool>,
pub limit: Option<f64>,
pub offset: Option<String>,
#[serde(rename = "offsetBy")]
pub offset_by: Option<f64>,
#[serde(rename = "offsetDirection")]
pub offset_direction: Option<String>,
pub parameters: Option<TelemetryQueryRequestParameters>,
#[serde(rename = "queryId")]
pub query_id: String,
pub timeframe: TelemetryQueryRequestTimeframe,
pub view: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryQueryRequestParameters {
pub calculations: Option<Vec<TelemetryQueryRequestParametersCalculationsItem>>,
pub datasets: Option<Vec<String>>,
#[serde(rename = "filterCombination")]
pub filter_combination: Option<String>,
pub filters: Option<Vec<serde_json::Value>>,
#[serde(rename = "groupBys")]
pub group_bys: Option<Vec<TelemetryQueryRequestParametersGroupBysItem>>,
pub havings: Option<Vec<TelemetryQueryRequestParametersHavingsItem>>,
pub limit: Option<i64>,
pub needle: Option<TelemetryQueryRequestParametersNeedle>,
#[serde(rename = "orderBy")]
pub order_by: Option<TelemetryQueryRequestParametersOrderBy>,
}
pub type TelemetryQueryRequestParametersCalculationsItem =
super::shared::QueriesPatchRequestParametersCalculationsItemShape;
pub type TelemetryQueryRequestParametersGroupBysItem = super::shared::TypeValueObject;
pub type TelemetryQueryRequestParametersHavingsItem = super::shared::KeyOperationValueObject;
pub type TelemetryQueryRequestParametersNeedle = super::shared::IsRegexMatchCaseValueObject;
pub type TelemetryQueryRequestParametersOrderBy = super::shared::OrderValueObject;
pub type TelemetryQueryRequestTimeframe = super::shared::FromToObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryQueryResponse {
pub errors: Vec<TelemetryQueryResponseErrorsItem>,
pub messages: Vec<TelemetryQueryResponseMessagesItem>,
pub result: WorkersObservabilityQueryResults,
pub success: bool,
}
pub type TelemetryQueryResponseErrorsItem = super::shared::MessageObject;
pub type TelemetryQueryResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryValuesListRequest {
pub datasets: Vec<String>,
pub filters: Option<Vec<serde_json::Value>>,
pub key: String,
pub limit: Option<f64>,
pub needle: Option<TelemetryValuesListRequestNeedle>,
pub timeframe: TelemetryValuesListRequestTimeframe,
#[serde(rename = "type")]
pub r#type: String,
}
pub type TelemetryValuesListRequestNeedle = super::shared::IsRegexMatchCaseValueObject;
pub type TelemetryValuesListRequestTimeframe = super::shared::FromToObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryValuesListResponse {
pub errors: Vec<TelemetryValuesListResponseErrorsItem>,
pub messages: Vec<TelemetryValuesListResponseMessagesItem>,
pub result: Vec<TelemetryValuesListResponseResultItem>,
pub success: bool,
}
pub type TelemetryValuesListResponseErrorsItem = super::shared::MessageObject;
pub type TelemetryValuesListResponseMessagesItem = super::shared::MessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TelemetryValuesListResponseResultItem {
pub dataset: String,
pub key: String,
#[serde(rename = "type")]
pub r#type: String,
pub value: serde_json::Value,
}
pub type UpdateHyperdriveResponse = super::shared::ApiEnvelope<HyperdriveHyperdriveConfigResponse>;
pub type UpdateTriggerResponse = CreateTriggerResponse;
pub type UpdateWorkerRequest = super::shared::CreateWorkerRequestShape;
pub type UpdateWorkerResponse = super::shared::ApiEnvelope<WorkersWorker>;
pub type UpsertEnvironmentVariablesResponse = ListEnvironmentVariablesResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct UpsertRepoConnectionResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<String>,
pub result: BuildsUpsertRepoConnectionResponse,
pub result_info: Option<BuildsPaginationInfo>,
pub success: bool,
}
pub type WorkerAccountSettingsCreateWorkerAccountSettingsResponse =
super::shared::ApiEnvelope<WorkersAccountSettings>;
pub type WorkerAccountSettingsFetchWorkerAccountSettingsResponse =
super::shared::ApiEnvelope<WorkersAccountSettings>;
pub type WorkerCronTriggerGetCronTriggersResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkerCronTriggerUpdateCronTriggersResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkerDeploymentsCreateDeploymentResponse = super::shared::ApiEnvelope<WorkersDeployment>;
pub type WorkerDeploymentsGetDeploymentResponse = super::shared::ApiEnvelope<WorkersDeployment>;
pub type WorkerDeploymentsListDeploymentsResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkerGetScriptSecretResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type WorkerListScriptSecretsResponse =
super::shared::ApiEnvelope<Option<Vec<serde_json::Value>>>;
pub type WorkerPlacementListRegionsResponse =
super::shared::ApiEnvelope<WorkersPlacementRegionsResponse>;
pub type WorkerPutScriptSecretResponse = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type WorkerRoutesCreateRouteResponse = super::shared::ApiEnvelope<WorkersRoute>;
pub type WorkerRoutesDeleteRouteResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkerRoutesGetRouteResponse = super::shared::ApiEnvelope<WorkersRoute>;
pub type WorkerRoutesListRoutesResponse = super::shared::ApiEnvelope<Vec<WorkersRoute>>;
pub type WorkerRoutesUpdateRouteResponse = super::shared::ApiEnvelope<WorkersRoute>;
pub type WorkerScriptDeleteSubdomainResponse = super::shared::ApiEnvelope<WorkersSubdomain>;
pub type WorkerScriptGetSubdomainResponse = super::shared::ApiEnvelope<WorkersSubdomain>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkerScriptPostSubdomainRequest {
pub enabled: bool,
pub previews_enabled: Option<bool>,
}
pub type WorkerScriptPostSubdomainResponse = super::shared::ApiEnvelope<WorkersSubdomain>;
pub type WorkerScriptSearchWorkersResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<
Vec<std::collections::HashMap<String, serde_json::Value>>,
>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkerScriptUpdateUsageModelRequest {
pub usage_model: Option<String>,
pub user_limits: Option<WorkersUserLimits>,
}
pub type WorkerScriptUploadWorkerModuleResponse =
super::shared::ApiEnvelope<WorkersScriptResponseUpload>;
pub type WorkerSubdomainCreateSubdomainResponse =
super::shared::ApiEnvelope<WorkersSchemasSubdomain>;
pub type WorkerSubdomainGetSubdomainResponse = super::shared::ApiEnvelope<WorkersSchemasSubdomain>;
pub type WorkerTailLogsStartTailResponse = super::shared::ApiEnvelope<WorkersTail>;
pub type Workers200Response = super::shared::ApiEnvelope<WorkersScriptResponseUpload>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersAccountSettings {
pub default_usage_model: Option<String>,
pub green_compute: Option<bool>,
}
pub type WorkersApiResponseCollection = super::shared::AddressingApiResponseCollectionShape;
pub type WorkersApiResponseCommon = super::shared::ErrorsMessagesSuccessObject;
pub type WorkersApiResponseNullResult = super::shared::ApiEnvelope<Option<serde_json::Value>>;
pub type WorkersApiResponseSingle = super::shared::ErrorsMessagesSuccessObject;
pub type WorkersBindingItem = serde_json::Value;
pub type WorkersBindingKindAi = super::shared::NameTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindAiSearch {
pub instance_name: String,
pub name: String,
pub namespace: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindAiSearchNamespace {
pub name: String,
pub namespace: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindAnalyticsEngine {
pub dataset: String,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindAssets = super::shared::NameTypeObject;
pub type WorkersBindingKindBrowser = super::shared::NameTypeObject;
pub type WorkersBindingKindD1 = super::shared::IdNameTypeObject;
pub type WorkersBindingKindDataBlob = super::shared::NamePartTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindDispatchNamespace {
pub name: String,
pub namespace: String,
pub outbound: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindDurableObjectNamespace {
pub class_name: Option<String>,
pub dispatch_namespace: Option<String>,
pub environment: Option<String>,
pub name: String,
pub namespace_id: Option<serde_json::Value>,
pub script_name: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindHyperdrive = super::shared::IdNameTypeObject;
pub type WorkersBindingKindImages = super::shared::NameTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindInherit {
pub name: String,
pub old_name: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
pub version_id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindJson {
pub json: serde_json::Value,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindKvNamespace {
pub name: String,
pub namespace_id: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindMedia = super::shared::NameTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindMtlsCertificate {
pub certificate_id: String,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindPipelines {
pub name: String,
pub pipeline: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindPlainText = super::shared::NameTextTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindQueue {
pub name: String,
pub queue_name: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindR2Bucket {
pub bucket_name: String,
pub jurisdiction: Option<String>,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindRatelimit {
pub name: String,
pub namespace_id: String,
pub simple: std::collections::HashMap<String, serde_json::Value>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindSecretKey {
pub algorithm: serde_json::Value,
pub format: String,
pub key_base64: Option<String>,
pub key_jwk: Option<serde_json::Value>,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
pub usages: Vec<String>,
}
pub type WorkersBindingKindSecretText = super::shared::NameTextTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindSecretsStoreSecret {
pub name: String,
pub secret_name: String,
pub store_id: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindSendEmail {
pub allowed_destination_addresses: Option<Vec<String>>,
pub allowed_sender_addresses: Option<Vec<String>>,
pub destination_address: Option<String>,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindService {
pub entrypoint: Option<String>,
pub environment: Option<String>,
pub name: String,
pub service: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindTextBlob = super::shared::NamePartTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindVectorize {
pub index_name: String,
pub name: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindVersionMetadata = super::shared::NameTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindVpcNetwork {
pub name: String,
pub network_id: Option<String>,
pub tunnel_id: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindVpcService {
pub name: String,
pub service_id: String,
#[serde(rename = "type")]
pub r#type: String,
}
pub type WorkersBindingKindWasmModule = super::shared::NamePartTypeObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersBindingKindWorkflow {
pub class_name: Option<String>,
pub name: String,
pub script_name: Option<String>,
#[serde(rename = "type")]
pub r#type: String,
pub workflow_name: String,
}
pub type WorkersBindingName = String;
pub type WorkersBindings = Vec<serde_json::Value>;
pub type WorkersCompatibilityDate = String;
pub type WorkersCompatibilityFlag = String;
pub type WorkersCompatibilityFlags = Vec<String>;
pub type WorkersCompletedUploadAssetsResponse =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersCreateAssetsUploadSessionObject {
pub manifest: serde_json::Value,
}
pub type WorkersCreateAssetsUploadSessionResponse =
super::shared::ApiEnvelope<Option<std::collections::HashMap<String, serde_json::Value>>>;
pub type WorkersCreatedOn = String;
pub type WorkersCursor = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersDeployment {
pub annotations: Option<std::collections::HashMap<String, serde_json::Value>>,
pub author_email: Option<String>,
pub created_on: String,
pub id: String,
pub source: String,
pub strategy: String,
pub versions: Vec<std::collections::HashMap<String, serde_json::Value>>,
}
pub type WorkersDispatchNamespaceName = String;
pub type WorkersDomain = super::shared::WorkersDomainShape;
pub type WorkersDomainsGetResponse = super::shared::ApiEnvelope<WorkersDomain>;
pub type WorkersDomainsListResponse =
super::shared::ApiEnvelopeErrorsMessagesResultInfoSuccess<Vec<WorkersDomain>>;
pub type WorkersDomainsUpdateRequest = super::shared::WorkersDomainShape;
pub type WorkersDomainsUpdateResponse = super::shared::ApiEnvelope<WorkersDomain>;
pub type WorkersEtag = String;
pub type WorkersHasAssets = bool;
pub type WorkersHasModules = bool;
pub type WorkersIdentifier = String;
pub type WorkersLimits = super::shared::CpuMsObject;
pub type WorkersLogpush = bool;
pub type WorkersMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkersModifiedOn = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersNamespace {
pub class: Option<String>,
pub id: Option<String>,
pub name: Option<String>,
pub script: Option<String>,
pub use_sqlite: Option<bool>,
}
pub type WorkersNamespaceIdentifier = String;
pub type WorkersNamespaceListResponse =
super::shared::ApiEnvelope<Option<Vec<WorkersNamespaceResponse>>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersNamespaceResponse {
pub created_by: Option<String>,
pub created_on: Option<String>,
pub modified_by: Option<String>,
pub modified_on: Option<String>,
pub namespace_id: Option<String>,
pub namespace_name: Option<String>,
pub script_count: Option<i64>,
pub trusted_workers: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersNamespaceScriptAndVersionSettingsItem {
pub bindings: Option<serde_json::Value>,
pub compatibility_date: Option<serde_json::Value>,
pub compatibility_flags: Option<serde_json::Value>,
pub limits: Option<WorkersLimits>,
pub logpush: Option<bool>,
pub migrations: Option<serde_json::Value>,
pub observability: Option<WorkersObservability>,
pub placement: Option<serde_json::Value>,
pub tags: Option<serde_json::Value>,
pub tail_consumers: Option<serde_json::Value>,
pub usage_model: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersNamespaceScriptDeleteBulkResponse {
pub deleted: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub deleted_count: Option<i64>,
pub has_more: Option<bool>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersNamespaceScriptResponse {
pub created_on: Option<String>,
pub dispatch_namespace: Option<String>,
pub modified_on: Option<String>,
pub script: Option<WorkersScriptResponse>,
}
pub type WorkersNamespaceScriptResponseSingle =
super::shared::ApiEnvelope<WorkersNamespaceScriptResponse>;
pub type WorkersNamespaceSingleResponse =
super::shared::ApiEnvelope<Option<WorkersNamespaceResponse>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObject {
#[serde(rename = "hasStoredData")]
pub has_stored_data: Option<bool>,
pub id: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservability {
pub enabled: bool,
pub head_sampling_rate: Option<f64>,
pub logs: Option<std::collections::HashMap<String, serde_json::Value>>,
pub traces: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityFilterLeaf {
pub key: String,
pub kind: Option<String>,
pub operation: String,
#[serde(rename = "type")]
pub r#type: String,
pub value: Option<serde_json::Value>,
}
pub type WorkersObservabilityFilterNode = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityPerformanceInformation {
pub abr_level: Option<f64>,
pub bytes_read: f64,
pub elapsed: f64,
pub rows_read: f64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityQuery {
pub adhoc: bool,
pub created: String,
#[serde(rename = "createdBy")]
pub created_by: String,
pub description: Option<String>,
pub id: String,
pub name: String,
pub parameters: std::collections::HashMap<String, serde_json::Value>,
pub updated: String,
#[serde(rename = "updatedBy")]
pub updated_by: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityQueryResults {
pub agents: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub calculations: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub compare: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub events: Option<std::collections::HashMap<String, serde_json::Value>>,
pub invocations: Option<serde_json::Value>,
pub run: WorkersObservabilityQueryRun,
pub statistics: WorkersObservabilityPerformanceInformation,
pub traces: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityQueryRun {
#[serde(rename = "accountId")]
pub account_id: String,
pub created: Option<String>,
pub dry: bool,
pub granularity: f64,
pub id: String,
pub query: serde_json::Value,
pub statistics: Option<std::collections::HashMap<String, serde_json::Value>>,
pub status: String,
pub timeframe: std::collections::HashMap<String, serde_json::Value>,
pub updated: Option<String>,
#[serde(rename = "userId")]
pub user_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersObservabilityTelemetryEvent {
#[serde(rename = "$containers")]
pub containers: Option<serde_json::Value>,
#[serde(rename = "$metadata")]
pub metadata: std::collections::HashMap<String, serde_json::Value>,
#[serde(rename = "$workers")]
pub workers: Option<serde_json::Value>,
pub dataset: String,
pub source: serde_json::Value,
pub timestamp: i64,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersPlacementInfo {
pub last_analyzed_at: Option<String>,
pub status: Option<String>,
}
pub type WorkersPlacementInfoNoStatus = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersPlacementProvider {
pub id: String,
pub regions: Vec<WorkersPlacementRegion>,
}
pub type WorkersPlacementRegion = super::shared::IdObject2;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersPlacementRegionsResponse {
pub providers: Vec<WorkersPlacementProvider>,
}
pub type WorkersPlacementStatus = String;
pub type WorkersPlacementTarget = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersRoute {
pub id: serde_json::Value,
pub pattern: String,
pub script: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersSchedule {
pub created_on: Option<String>,
pub cron: String,
pub modified_on: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersSchemasSubdomain {
pub subdomain: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersScriptAndVersionSettingsItem {
pub annotations: Option<std::collections::HashMap<String, serde_json::Value>>,
pub bindings: Option<serde_json::Value>,
pub compatibility_date: Option<serde_json::Value>,
pub compatibility_flags: Option<serde_json::Value>,
pub limits: Option<WorkersLimits>,
pub logpush: Option<bool>,
pub migrations: Option<serde_json::Value>,
pub observability: Option<WorkersObservability>,
pub placement: Option<serde_json::Value>,
pub tags: Option<serde_json::Value>,
pub tail_consumers: Option<serde_json::Value>,
pub usage_model: Option<String>,
}
pub type WorkersScriptAndVersionSettingsResponse =
super::shared::ApiEnvelope<WorkersScriptAndVersionSettingsItem>;
pub type WorkersScriptCount = i64;
pub type WorkersScriptName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersScriptResponse {
pub compatibility_date: Option<String>,
pub compatibility_flags: Option<Vec<String>>,
pub created_on: Option<String>,
pub etag: Option<String>,
pub handlers: Option<Vec<String>>,
pub has_assets: Option<bool>,
pub has_modules: Option<bool>,
pub id: Option<String>,
pub last_deployed_from: Option<String>,
pub logpush: Option<bool>,
pub migration_tag: Option<String>,
pub modified_on: Option<String>,
pub named_handlers: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub observability: Option<WorkersObservability>,
pub placement: Option<WorkersPlacementInfo>,
pub placement_mode: Option<serde_json::Value>,
pub placement_status: Option<serde_json::Value>,
pub tag: Option<String>,
pub tags: Option<Vec<String>>,
pub tail_consumers: Option<Vec<WorkersTailConsumersScript>>,
pub usage_model: Option<String>,
}
pub type WorkersScriptResponseCollection = super::shared::ApiEnvelope<Vec<serde_json::Value>>;
pub type WorkersScriptResponseSingle = super::shared::ApiEnvelope<WorkersScriptResponse>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersScriptResponseUpload {
pub compatibility_date: Option<String>,
pub compatibility_flags: Option<Vec<String>>,
pub created_on: Option<String>,
pub entry_point: Option<String>,
pub etag: Option<String>,
pub handlers: Option<Vec<String>>,
pub has_assets: Option<bool>,
pub has_modules: Option<bool>,
pub id: Option<String>,
pub last_deployed_from: Option<String>,
pub logpush: Option<bool>,
pub migration_tag: Option<String>,
pub modified_on: Option<String>,
pub named_handlers: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub observability: Option<WorkersObservability>,
pub placement: Option<WorkersPlacementInfo>,
pub placement_mode: Option<serde_json::Value>,
pub placement_status: Option<serde_json::Value>,
pub startup_time_ms: i64,
pub tag: Option<String>,
pub tags: Option<Vec<String>>,
pub tail_consumers: Option<Vec<WorkersTailConsumersScript>>,
pub usage_model: Option<String>,
}
pub type WorkersScriptResponseUploadSingle =
super::shared::ApiEnvelope<WorkersScriptResponseUpload>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersScriptSettingsItem {
pub logpush: Option<bool>,
pub observability: Option<serde_json::Value>,
pub tags: Option<serde_json::Value>,
pub tail_consumers: Option<Vec<WorkersTailConsumersScript>>,
}
pub type WorkersScriptSettingsResponse = super::shared::ApiEnvelope<WorkersScriptSettingsItem>;
pub type WorkersSecret = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersSubdomain {
pub enabled: bool,
pub previews_enabled: bool,
}
pub type WorkersTag = String;
pub type WorkersTags = Vec<String>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersTail {
pub expires_at: String,
pub id: serde_json::Value,
pub url: String,
}
pub type WorkersTailConsumers = Vec<WorkersTailConsumersScript>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersTailConsumersScript {
pub environment: Option<String>,
pub namespace: Option<String>,
pub service: String,
}
pub type WorkersTrustedWorkers = bool;
pub type WorkersUsageModel = String;
pub type WorkersUsageModelResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkersUserLimits = super::shared::CpuMsObject;
pub type WorkersUuid = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersVersion {
pub annotations: Option<std::collections::HashMap<String, serde_json::Value>>,
pub assets: Option<std::collections::HashMap<String, serde_json::Value>>,
pub bindings: Option<Vec<serde_json::Value>>,
pub compatibility_date: Option<String>,
pub compatibility_flags: Option<Vec<String>>,
pub created_on: String,
pub id: String,
pub limits: Option<std::collections::HashMap<String, serde_json::Value>>,
pub main_module: Option<String>,
pub migration_tag: Option<String>,
pub migrations: Option<serde_json::Value>,
pub modules: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
pub number: i64,
pub placement: Option<serde_json::Value>,
pub source: Option<String>,
pub startup_time_ms: Option<i64>,
pub urls: Vec<String>,
pub usage_model: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersVersionItemFull {
pub id: Option<String>,
pub metadata: Option<std::collections::HashMap<String, serde_json::Value>>,
pub number: Option<f64>,
pub resources: std::collections::HashMap<String, serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersVersionItemShort {
pub id: Option<String>,
pub metadata: Option<std::collections::HashMap<String, serde_json::Value>>,
pub number: Option<f64>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorkersVersionItemUploaded {
pub id: Option<String>,
pub metadata: Option<std::collections::HashMap<String, serde_json::Value>>,
pub number: Option<f64>,
pub resources: std::collections::HashMap<String, serde_json::Value>,
pub startup_time_ms: Option<i64>,
}
pub type WorkersVersionsListResponse =
super::shared::ApiEnvelope<std::collections::HashMap<String, serde_json::Value>>;
pub type WorkersVersionsSingleResponse = super::shared::ApiEnvelope<WorkersVersionItemFull>;
pub type WorkersVersionsUploadResponse = super::shared::ApiEnvelope<WorkersVersionItemUploaded>;
pub type WorkersWorker = super::shared::CreateWorkerRequestShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAnAccountListCustomPagesArgs {
pub account_identifier: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAnAccountListCustomAssetsArgs {
pub account_identifier: String,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAnAccountCreateACustomAssetArgs {
pub account_identifier: String,
pub body: CustomAssetsForAnAccountCreateACustomAssetRequest,
}
pub type CustomAssetsForAnAccountGetACustomAssetArgs =
super::shared::AssetNameAccountIdentifierArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAnAccountUpdateACustomAssetArgs {
pub asset_name: String,
pub account_identifier: String,
pub body: CustomAssetsForAnAccountUpdateACustomAssetRequest,
}
pub type CustomAssetsForAnAccountDeleteACustomAssetArgs =
super::shared::AssetNameAccountIdentifierArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAnAccountGetACustomPageArgs {
pub identifier: String,
pub account_identifier: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAnAccountUpdateACustomPageArgs {
pub identifier: String,
pub account_identifier: String,
pub body: CustomPagesForAnAccountUpdateACustomPageRequest,
}
pub type AccessCustomPagesListCustomPagesArgs = super::shared::AccountIdPagePerPageArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccessCustomPagesCreateACustomPageArgs {
pub account_id: String,
pub body: AccessCustomPage,
}
pub type AccessCustomPagesGetACustomPageArgs = super::shared::CustomPageIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccessCustomPagesUpdateACustomPageArgs {
pub custom_page_id: String,
pub account_id: String,
pub body: AccessCustomPage,
}
pub type AccessCustomPagesDeleteACustomPageArgs = super::shared::CustomPageIdAccountIdArgs;
pub type IpAddressManagementServiceBindingsListServiceBindingsArgs =
super::shared::AccountIdPrefixIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct IpAddressManagementServiceBindingsCreateServiceBindingArgs {
pub account_id: String,
pub prefix_id: String,
pub body: AddressingCreateBindingRequest,
}
pub type IpAddressManagementServiceBindingsGetServiceBindingArgs =
super::shared::AccountIdPrefixIdBindingIdArgs;
pub type IpAddressManagementServiceBindingsDeleteServiceBindingArgs =
super::shared::AccountIdPrefixIdBindingIdArgs;
pub type IpAddressManagementServiceBindingsListServicesArgs = super::shared::AccountIdArgs;
pub type GetAccountLimitsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetBuildsByVersionIdsArgs {
pub account_id: String,
pub version_ids: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetLatestBuildsByScriptsArgs {
pub account_id: String,
pub external_script_ids: Option<String>,
}
pub type GetBuildByUuidArgs = super::shared::AccountIdBuildUuidArgs;
pub type CancelBuildByUuidArgs = super::shared::AccountIdBuildUuidArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetBuildLogsArgs {
pub account_id: String,
pub build_uuid: String,
pub cursor: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpsertRepoConnectionArgs {
pub account_id: String,
pub body: BuildsUpsertRepoConnectionRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteRepoConnectionArgs {
pub account_id: String,
pub repo_connection_uuid: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetWorkerConfigAutofillArgs {
pub account_id: String,
pub provider_type: String,
pub provider_account_id: String,
pub repo_id: String,
pub branch: Option<String>,
pub root_directory: Option<String>,
}
pub type ListBuildTokensArgs = super::shared::AccountIdPagePerPageArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateBuildTokenArgs {
pub account_id: String,
pub body: BuildsCreateBuildTokenRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteBuildTokenArgs {
pub account_id: String,
pub build_token_uuid: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateTriggerArgs {
pub account_id: String,
pub body: BuildsCreateTriggerRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateTriggerArgs {
pub account_id: String,
pub trigger_uuid: String,
pub body: BuildsUpdateTriggerRequest,
}
pub type DeleteTriggerArgs = super::shared::AccountIdTriggerUuidArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateManualBuildArgs {
pub account_id: String,
pub trigger_uuid: String,
pub body: BuildsCreateBuildRequest,
}
pub type ListEnvironmentVariablesArgs = super::shared::AccountIdTriggerUuidArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpsertEnvironmentVariablesArgs {
pub account_id: String,
pub trigger_uuid: String,
pub body: BuildsEnvironmentVariablesRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteEnvironmentVariableArgs {
pub account_id: String,
pub trigger_uuid: String,
pub environment_variable_key: String,
}
pub type PurgeBuildCacheArgs = super::shared::AccountIdTriggerUuidArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListBuildsByScriptArgs {
pub account_id: String,
pub external_script_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListTriggersByScriptArgs {
pub account_id: String,
pub external_script_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PublicListApplicationsArgs {
pub account_id: String,
pub name: Option<String>,
pub image: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GenerateImageRegistryCredentialsArgs {
pub domain: String,
pub body: CcImageRegistryCredentialsConfiguration,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1ListDatabasesArgs {
pub account_id: String,
pub name: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1CreateDatabaseArgs {
pub account_id: String,
pub body: D1CreateDatabaseRequest,
}
pub type D1GetDatabaseArgs = super::shared::AccountIdDatabaseIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1UpdateDatabaseArgs {
pub account_id: String,
pub database_id: String,
pub body: D1DatabaseUpdateRequestBody,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1UpdatePartialDatabaseArgs {
pub account_id: String,
pub database_id: String,
pub body: D1DatabaseUpdatePartialRequestBody,
}
pub type D1DeleteDatabaseArgs = super::shared::AccountIdDatabaseIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1ExportDatabaseArgs {
pub account_id: String,
pub database_id: String,
pub body: D1ExportDatabaseRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1ImportDatabaseArgs {
pub account_id: String,
pub database_id: String,
pub body: D1ImportDatabaseRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1QueryDatabaseArgs {
pub account_id: String,
pub database_id: String,
pub body: D1BatchQuery,
}
pub type D1RawDatabaseQueryArgs = D1QueryDatabaseArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1TimeTravelGetBookmarkArgs {
pub account_id: String,
pub database_id: String,
pub timestamp: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct D1TimeTravelRestoreArgs {
pub account_id: String,
pub database_id: String,
pub bookmark: Option<String>,
pub timestamp: Option<String>,
}
pub type ListHyperdriveArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateHyperdriveArgs {
pub account_id: String,
pub body: HyperdriveHyperdriveConfig,
}
pub type GetHyperdriveArgs = super::shared::AccountIdHyperdriveIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateHyperdriveArgs {
pub account_id: String,
pub hyperdrive_id: String,
pub body: HyperdriveHyperdriveConfig,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PatchHyperdriveArgs {
pub account_id: String,
pub hyperdrive_id: String,
pub body: HyperdriveHyperdriveConfigPatch,
}
pub type DeleteHyperdriveArgs = super::shared::AccountIdHyperdriveIdArgs;
pub type PagesProjectGetProjectsArgs = super::shared::AccountIdPagePerPageArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PagesProjectCreateProjectArgs {
pub account_id: String,
pub body: PagesProjectCreateProjectRequest,
}
pub type PagesProjectGetProjectArgs = super::shared::ProjectNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PagesProjectUpdateProjectArgs {
pub project_name: String,
pub account_id: String,
pub body: PagesProjectUpdateProjectRequest,
}
pub type PagesProjectDeleteProjectArgs = super::shared::ProjectNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PagesDeploymentGetDeploymentsArgs {
pub project_name: String,
pub account_id: String,
pub env: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
pub type PagesDeploymentCreateDeploymentArgs = super::shared::ProjectNameAccountIdArgs;
pub type PagesDeploymentGetDeploymentInfoArgs = super::shared::DeploymentIdProjectNameAccountIdArgs;
pub type PagesDeploymentDeleteDeploymentArgs = super::shared::DeploymentIdProjectNameAccountIdArgs;
pub type PagesDeploymentGetDeploymentLogsArgs = super::shared::DeploymentIdProjectNameAccountIdArgs;
pub type PagesDeploymentRetryDeploymentArgs = super::shared::DeploymentIdProjectNameAccountIdArgs;
pub type PagesDeploymentRollbackDeploymentArgs =
super::shared::DeploymentIdProjectNameAccountIdArgs;
pub type PagesDomainsGetDomainsArgs = super::shared::ProjectNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PagesDomainsAddDomainArgs {
pub project_name: String,
pub account_id: String,
pub body: PagesDomainsAddDomainRequest,
}
pub type PagesDomainsGetDomainArgs = super::shared::DomainNameProjectNameAccountIdArgs;
pub type PagesDomainsPatchDomainArgs = super::shared::DomainNameProjectNameAccountIdArgs;
pub type PagesDomainsDeleteDomainArgs = super::shared::DomainNameProjectNameAccountIdArgs;
pub type PagesPurgeBuildCacheArgs = super::shared::ProjectNameAccountIdArgs;
pub type GetV4AccountsByAccountIdPipelinesV1PipelinesArgs = super::shared::AccountIdPagePerPageArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1PipelinesArgs {
pub account_id: String,
pub body: PostV4AccountsByAccountIdPipelinesV1PipelinesRequest,
}
pub type GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdArgs =
super::shared::AccountIdPipelineIdArgs;
pub type DeleteV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdArgs =
super::shared::AccountIdPipelineIdArgs;
pub type GetV4AccountsByAccountIdPipelinesV1SinksArgs =
super::shared::GetV4AccountsByAccountIdPipelinesV1SinksArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1SinksArgs {
pub account_id: String,
pub body: PostV4AccountsByAccountIdPipelinesV1SinksRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdArgs {
pub account_id: String,
pub sink_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteV4AccountsByAccountIdPipelinesV1SinksBySinkIdArgs {
pub account_id: String,
pub sink_id: String,
pub force: Option<String>,
}
pub type GetV4AccountsByAccountIdPipelinesV1StreamsArgs =
super::shared::GetV4AccountsByAccountIdPipelinesV1SinksArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1StreamsArgs {
pub account_id: String,
pub body: PostV4AccountsByAccountIdPipelinesV1StreamsRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs {
pub account_id: String,
pub stream_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs {
pub account_id: String,
pub stream_id: String,
pub body: PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs {
pub account_id: String,
pub stream_id: String,
pub force: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PostV4AccountsByAccountIdPipelinesV1ValidateSqlArgs {
pub account_id: String,
pub body: PostV4AccountsByAccountIdPipelinesV1ValidateSqlRequest,
}
pub type WorkerAccountSettingsFetchWorkerAccountSettingsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerAccountSettingsCreateWorkerAccountSettingsArgs {
pub account_id: String,
pub body: WorkersAccountSettings,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerAssetsUploadArgs {
pub account_id: String,
pub base64: Option<String>,
}
pub type NamespaceWorkerListArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerCreateArgs {
pub account_id: String,
pub body: NamespaceWorkerCreateRequest,
}
pub type NamespaceWorkerGetNamespaceArgs = super::shared::AccountIdDispatchNamespaceArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerPutNamespaceArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub body: NamespaceWorkerPutNamespaceRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerPatchNamespaceArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub body: NamespaceWorkerPatchNamespaceRequest,
}
pub type NamespaceWorkerDeleteNamespaceArgs = super::shared::AccountIdDispatchNamespaceArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerListScriptsArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub tags: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerDeleteScriptsArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub tags: Option<String>,
pub limit: Option<String>,
}
pub type NamespaceWorkerScriptWorkerDetailsArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerScriptUploadWorkerModuleArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub script_name: String,
pub bindings_inherit: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerScriptDeleteWorkerArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub script_name: String,
pub force: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerScriptUpdateCreateAssetsUploadSessionArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub script_name: String,
pub body: WorkersCreateAssetsUploadSessionObject,
}
pub type NamespaceWorkerGetScriptBindingsArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerGetScriptContentArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerPutScriptContentArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerListScriptSecretsArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NamespaceWorkerPutScriptSecretsArgs {
pub account_id: String,
pub dispatch_namespace: String,
pub script_name: String,
pub body: WorkersSecret,
}
pub type NamespaceWorkerGetScriptSecretsArgs =
super::shared::NamespaceWorkerGetScriptSecretsArgsShape;
pub type NamespaceWorkerDeleteScriptSecretArgs =
super::shared::NamespaceWorkerGetScriptSecretsArgsShape;
pub type NamespaceWorkerGetScriptSettingsArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerPatchScriptSettingsArgs =
super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerGetScriptTagsArgs = super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerPutScriptTagsArgs = super::shared::AccountIdDispatchNamespaceScriptNameArgs;
pub type NamespaceWorkerPutScriptTagArgs = super::shared::NamespaceWorkerPutScriptTagArgsShape;
pub type NamespaceWorkerDeleteScriptTagArgs = super::shared::NamespaceWorkerPutScriptTagArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkersDomainsListArgs {
pub account_id: String,
pub zone_id: Option<String>,
pub zone_name: Option<String>,
pub service: Option<String>,
pub hostname: Option<String>,
pub environment: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkersDomainsUpdateArgs {
pub account_id: String,
pub body: WorkersDomainsUpdateRequest,
}
pub type WorkersDomainsGetArgs = super::shared::AccountIdDomainIdArgs;
pub type WorkersDomainsDeleteArgs = super::shared::AccountIdDomainIdArgs;
pub type DurableObjectsNamespaceListNamespacesArgs = super::shared::AccountIdPagePerPageArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DurableObjectsNamespaceListObjectsArgs {
pub account_id: String,
pub id: String,
pub limit: Option<String>,
pub cursor: Option<String>,
}
pub type DestinationListArgs = super::shared::DestinationListArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DestinationCreateArgs {
pub account_id: String,
pub body: DestinationCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DestinationUpdateArgs {
pub slug: String,
pub body: DestinationUpdateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DestinationsDeleteArgs {
pub slug: String,
}
pub type QueriesListArgs = super::shared::DestinationListArgsShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct QueriesPostArgs {
pub account_id: String,
pub body: QueriesPostRequest,
}
pub type QueriesGetArgs = super::shared::QueryIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct QueriesPatchArgs {
pub query_id: String,
pub body: QueriesPatchRequest,
}
pub type QueriesDeleteArgs = super::shared::QueryIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TelemetryKeysListArgs {
pub account_id: String,
pub body: TelemetryKeysListRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TelemetryQueryArgs {
pub account_id: String,
pub body: TelemetryQueryRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct TelemetryValuesListArgs {
pub account_id: String,
pub body: TelemetryValuesListRequest,
}
pub type WorkerPlacementListRegionsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptListWorkersArgs {
pub account_id: String,
pub tags: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptSearchWorkersArgs {
pub account_id: String,
pub name: Option<String>,
pub id: Option<String>,
pub order_by: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
pub type WorkerScriptDownloadWorkerArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerScriptUploadWorkerModuleArgs = super::shared::AccountIdScriptNameBindingsInheritArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptDeleteWorkerArgs {
pub account_id: String,
pub script_name: String,
pub force: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptUpdateCreateAssetsUploadSessionArgs {
pub account_id: String,
pub script_name: String,
pub body: WorkersCreateAssetsUploadSessionObject,
}
pub type WorkerScriptPutContentArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerScriptGetContentArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerDeploymentsListDeploymentsArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerDeploymentsCreateDeploymentArgs {
pub account_id: String,
pub script_name: String,
pub force: Option<String>,
pub body: WorkersDeployment,
}
pub type WorkerDeploymentsGetDeploymentArgs = super::shared::AccountIdScriptNameDeploymentIdArgs;
pub type WorkerDeploymentsDeleteDeploymentArgs = super::shared::AccountIdScriptNameDeploymentIdArgs;
pub type WorkerCronTriggerGetCronTriggersArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerCronTriggerUpdateCronTriggersArgs {
pub account_id: String,
pub script_name: String,
pub body: Vec<WorkersSchedule>,
}
pub type WorkerScriptSettingsGetSettingsArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptSettingsPatchSettingsArgs {
pub account_id: String,
pub script_name: String,
pub body: WorkersScriptSettingsItem,
}
pub type WorkerListScriptSecretsArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerPutScriptSecretArgs {
pub account_id: String,
pub script_name: String,
pub body: WorkersSecret,
}
pub type WorkerGetScriptSecretArgs = super::shared::WorkerGetScriptSecretArgsShape;
pub type WorkerDeleteScriptSecretArgs = super::shared::WorkerGetScriptSecretArgsShape;
pub type WorkerScriptGetSettingsArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerScriptPatchSettingsArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerScriptGetSubdomainArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptPostSubdomainArgs {
pub account_id: String,
pub script_name: String,
pub body: WorkerScriptPostSubdomainRequest,
}
pub type WorkerScriptDeleteSubdomainArgs = super::shared::AccountIdScriptNameArgs;
pub type WorkerTailLogsStartTailArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerTailLogsDeleteTailArgs {
pub account_id: String,
pub script_name: String,
pub id: String,
}
pub type WorkerScriptFetchUsageModelArgs = super::shared::AccountIdScriptNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptUpdateUsageModelArgs {
pub account_id: String,
pub script_name: String,
pub body: WorkerScriptUpdateUsageModelRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerVersionsListVersionsArgs {
pub account_id: String,
pub script_name: String,
pub deployable: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
}
pub type WorkerVersionsUploadVersionArgs = super::shared::AccountIdScriptNameBindingsInheritArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerVersionsGetVersionDetailArgs {
pub account_id: String,
pub script_name: String,
pub version_id: String,
}
pub type WorkerEnvironmentGetScriptContentArgs =
super::shared::AccountIdServiceNameEnvironmentNameArgs;
pub type WorkerEnvironmentPutScriptContentArgs =
super::shared::AccountIdServiceNameEnvironmentNameArgs;
pub type WorkerScriptEnvironmentGetSettingsArgs =
super::shared::AccountIdServiceNameEnvironmentNameArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerScriptEnvironmentPatchSettingsArgs {
pub account_id: String,
pub service_name: String,
pub environment_name: String,
pub body: WorkersScriptSettingsResponse,
}
pub type WorkerSubdomainGetSubdomainArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerSubdomainCreateSubdomainArgs {
pub account_id: String,
pub body: WorkersSchemasSubdomain,
}
pub type WorkerSubdomainDeleteSubdomainArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListWorkersArgs {
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub order_by: Option<String>,
pub order: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateWorkerArgs {
pub account_id: String,
pub body: CreateWorkerRequest,
}
pub type GetWorkerArgs = super::shared::AccountIdWorkerIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct UpdateWorkerArgs {
pub account_id: String,
pub worker_id: String,
pub body: UpdateWorkerRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct EditWorkerArgs {
pub account_id: String,
pub worker_id: String,
pub body: EditWorkerRequest,
}
pub type DeleteWorkerArgs = super::shared::AccountIdWorkerIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ListWorkerVersionsArgs {
pub account_id: String,
pub worker_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CreateWorkerVersionArgs {
pub account_id: String,
pub worker_id: String,
pub deploy: Option<String>,
pub body: WorkersVersion,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct GetWorkerVersionArgs {
pub account_id: String,
pub worker_id: String,
pub version_id: String,
pub include: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct DeleteWorkerVersionArgs {
pub account_id: String,
pub worker_id: String,
pub version_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAZoneListCustomPagesArgs {
pub zone_identifier: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAZoneListCustomAssetsArgs {
pub zone_identifier: String,
pub page: Option<String>,
pub per_page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAZoneCreateACustomAssetArgs {
pub zone_identifier: String,
pub body: CustomAssetsForAZoneCreateACustomAssetRequest,
}
pub type CustomAssetsForAZoneGetACustomAssetArgs = super::shared::AssetNameZoneIdentifierArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomAssetsForAZoneUpdateACustomAssetArgs {
pub asset_name: String,
pub zone_identifier: String,
pub body: CustomAssetsForAZoneUpdateACustomAssetRequest,
}
pub type CustomAssetsForAZoneDeleteACustomAssetArgs = super::shared::AssetNameZoneIdentifierArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAZoneGetACustomPageArgs {
pub identifier: String,
pub zone_identifier: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CustomPagesForAZoneUpdateACustomPageArgs {
pub identifier: String,
pub zone_identifier: String,
pub body: CustomPagesForAZoneUpdateACustomPageRequest,
}
pub type SpeedListPagesArgs = super::shared::ZoneIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SpeedListTestHistoryArgs {
pub zone_id: String,
pub url: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub region: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SpeedCreateTestArgs {
pub zone_id: String,
pub url: String,
pub body: SpeedCreateTestRequest,
}
pub type SpeedDeleteTestsArgs = super::shared::ZoneIdUrlRegionArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SpeedGetTestArgs {
pub zone_id: String,
pub url: String,
pub test_id: String,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SpeedListPageTrendArgs {
pub zone_id: String,
pub url: String,
pub region: Option<String>,
pub device_type: Option<String>,
pub start: Option<String>,
pub end: Option<String>,
pub tz: Option<String>,
pub metrics: Option<String>,
}
pub type WorkerRoutesListRoutesArgs = super::shared::ZoneIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerRoutesCreateRouteArgs {
pub zone_id: String,
pub body: WorkersRoute,
}
pub type WorkerRoutesGetRouteArgs = super::shared::RouteIdZoneIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorkerRoutesUpdateRouteArgs {
pub route_id: String,
pub zone_id: String,
pub body: WorkersRoute,
}
pub type WorkerRoutesDeleteRouteArgs = super::shared::RouteIdZoneIdArgs;
pub async fn custom_pages_for_an_account_list_custom_pages_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAnAccountListCustomPagesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPageResultList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/custom_pages", args.account_identifier,);
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 custom_assets_for_an_account_list_custom_assets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAnAccountListCustomAssetsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResultList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/custom_pages/assets", args.account_identifier,);
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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn custom_assets_for_an_account_create_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAnAccountCreateACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/custom_pages/assets", args.account_identifier,);
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 custom_assets_for_an_account_get_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAnAccountGetACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/custom_pages/assets/{}",
args.account_identifier, args.asset_name,
);
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 custom_assets_for_an_account_update_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAnAccountUpdateACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/custom_pages/assets/{}",
args.account_identifier, args.asset_name,
);
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 custom_assets_for_an_account_delete_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAnAccountDeleteACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/custom_pages/assets/{}",
args.account_identifier, args.asset_name,
);
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 custom_pages_for_an_account_get_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAnAccountGetACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPageResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/custom_pages/{}",
args.account_identifier, args.identifier,
);
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 custom_pages_for_an_account_update_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAnAccountUpdateACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPageResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/custom_pages/{}",
args.account_identifier, args.identifier,
);
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 access_custom_pages_list_custom_pages_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccessCustomPagesListCustomPagesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<AccessCustomPagesComponentsSchemasResponseCollection>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/access/custom_pages", 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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn access_custom_pages_create_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccessCustomPagesCreateACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AccessSingleResponseWithoutHtml>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/access/custom_pages", 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 access_custom_pages_get_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccessCustomPagesGetACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AccessCustomPagesComponentsSchemasSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/access/custom_pages/{}",
args.account_id, args.custom_page_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 access_custom_pages_update_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccessCustomPagesUpdateACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AccessSingleResponseWithoutHtml>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/access/custom_pages/{}",
args.account_id, args.custom_page_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 access_custom_pages_delete_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccessCustomPagesDeleteACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AccessComponentsSchemasIdResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/access/custom_pages/{}",
args.account_id, args.custom_page_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 ip_address_management_service_bindings_list_service_bindings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementServiceBindingsListServiceBindingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<IpAddressManagementServiceBindingsListServiceBindingsResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bindings",
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_service_bindings_create_service_binding_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementServiceBindingsCreateServiceBindingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<IpAddressManagementServiceBindingsCreateServiceBindingResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bindings",
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_service_bindings_get_service_binding_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementServiceBindingsGetServiceBindingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<IpAddressManagementServiceBindingsGetServiceBindingResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bindings/{}",
args.account_id, args.prefix_id, args.binding_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_service_bindings_delete_service_binding_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementServiceBindingsDeleteServiceBindingArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<AddressingApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/addressing/prefixes/{}/bindings/{}",
args.account_id, args.prefix_id, args.binding_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 ip_address_management_service_bindings_list_services_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &IpAddressManagementServiceBindingsListServicesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<IpAddressManagementServiceBindingsListServicesResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/addressing/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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_account_limits_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetAccountLimitsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetAccountLimitsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/account/limits", 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_builds_by_version_ids_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetBuildsByVersionIdsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetBuildsByVersionIdsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/builds", 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("version_ids", args.version_ids.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_latest_builds_by_scripts_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetLatestBuildsByScriptsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetLatestBuildsByScriptsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/builds/latest", 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("external_script_ids", args.external_script_ids.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn get_build_by_uuid_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetBuildByUuidArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetBuildByUuidResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/builds/{}",
args.account_id, args.build_uuid,
);
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 cancel_build_by_uuid_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CancelBuildByUuidArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CancelBuildByUuidResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/builds/{}/cancel",
args.account_id, args.build_uuid,
);
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 get_build_logs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetBuildLogsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetBuildLogsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/builds/{}/logs",
args.account_id, args.build_uuid,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("cursor", args.cursor.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn upsert_repo_connection_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpsertRepoConnectionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpsertRepoConnectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/repos/connections", 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 delete_repo_connection_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteRepoConnectionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BuildsAPIResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/repos/connections/{}",
args.account_id, args.repo_connection_uuid,
);
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 get_worker_config_autofill_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetWorkerConfigAutofillArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetWorkerConfigAutofillResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/repos/{}/{}/{}/config_autofill",
args.account_id, args.provider_type, args.provider_account_id, args.repo_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("branch", args.branch.as_deref());
builder = builder.query("root_directory", args.root_directory.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_build_tokens_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListBuildTokensArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListBuildTokensResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/tokens", 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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_build_token_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateBuildTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateBuildTokenResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/tokens", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn delete_build_token_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteBuildTokenArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BuildsAPIResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/tokens/{}",
args.account_id, args.build_token_uuid,
);
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 create_trigger_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateTriggerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateTriggerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/builds/triggers", 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 update_trigger_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateTriggerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpdateTriggerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}",
args.account_id, args.trigger_uuid,
);
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_trigger_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteTriggerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BuildsAPIResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}",
args.account_id, args.trigger_uuid,
);
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 create_manual_build_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateManualBuildArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateManualBuildResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}/builds",
args.account_id, args.trigger_uuid,
);
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 list_environment_variables_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListEnvironmentVariablesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListEnvironmentVariablesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}/environment_variables",
args.account_id, args.trigger_uuid,
);
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 upsert_environment_variables_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpsertEnvironmentVariablesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpsertEnvironmentVariablesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}/environment_variables",
args.account_id, args.trigger_uuid,
);
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_environment_variable_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteEnvironmentVariableArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BuildsAPIResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}/environment_variables/{}",
args.account_id, args.trigger_uuid, args.environment_variable_key,
);
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 purge_build_cache_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PurgeBuildCacheArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<BuildsAPIResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/triggers/{}/purge_build_cache",
args.account_id, args.trigger_uuid,
);
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 list_builds_by_script_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListBuildsByScriptArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListBuildsByScriptResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/workers/{}/builds",
args.account_id, args.external_script_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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_triggers_by_script_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListTriggersByScriptArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListTriggersByScriptResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/builds/workers/{}/triggers",
args.account_id, args.external_script_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 public_list_applications_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PublicListApplicationsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CcPublicListApplicationsResponse200Response>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/containers", 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("image", args.image.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn generate_image_registry_credentials_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GenerateImageRegistryCredentialsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<CcGenerateImageRegistryCredentialsResponse201Response>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/containers/registries/{}/credentials",
args.domain,
);
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 d1_list_databases_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1ListDatabasesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1ListDatabasesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/d1/database", 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("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 d1_create_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1CreateDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1CreateDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/d1/database", 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 d1_get_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1GetDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1GetDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}",
args.account_id, args.database_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 d1_update_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1UpdateDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1UpdateDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}",
args.account_id, args.database_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 d1_update_partial_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1UpdatePartialDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1UpdatePartialDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}",
args.account_id, args.database_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 d1_delete_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1DeleteDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1DeleteDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}",
args.account_id, args.database_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 d1_export_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1ExportDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1ExportDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/export",
args.account_id, args.database_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 d1_import_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1ImportDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1ImportDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/import",
args.account_id, args.database_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 d1_query_database_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1QueryDatabaseArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1QueryDatabaseResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/query",
args.account_id, args.database_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 d1_raw_database_query_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1RawDatabaseQueryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1RawDatabaseQueryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/raw",
args.account_id, args.database_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 d1_time_travel_get_bookmark_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1TimeTravelGetBookmarkArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1TimeTravelGetBookmarkResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/time_travel/bookmark",
args.account_id, args.database_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("timestamp", args.timestamp.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn d1_time_travel_restore_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &D1TimeTravelRestoreArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<D1TimeTravelRestoreResponse2>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/d1/database/{}/time_travel/restore",
args.account_id, args.database_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.query("bookmark", args.bookmark.as_deref());
builder = builder.query("timestamp", args.timestamp.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn list_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/hyperdrive/configs", 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 create_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/hyperdrive/configs", 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_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/hyperdrive/configs/{}",
args.account_id, args.hyperdrive_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_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpdateHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/hyperdrive/configs/{}",
args.account_id, args.hyperdrive_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 patch_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PatchHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PatchHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/hyperdrive/configs/{}",
args.account_id, args.hyperdrive_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_hyperdrive_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteHyperdriveArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DeleteHyperdriveResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/hyperdrive/configs/{}",
args.account_id, args.hyperdrive_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 pages_project_get_projects_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesProjectGetProjectsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesProjectGetProjectsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pages/projects", 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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn pages_project_create_project_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesProjectCreateProjectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesProjectCreateProjectResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pages/projects", 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 pages_project_get_project_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesProjectGetProjectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesProjectGetProjectResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}",
args.account_id, args.project_name,
);
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 pages_project_update_project_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesProjectUpdateProjectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesProjectUpdateProjectResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}",
args.account_id, args.project_name,
);
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 pages_project_delete_project_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesProjectDeleteProjectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesProjectDeleteProjectResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}",
args.account_id, args.project_name,
);
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 pages_deployment_get_deployments_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentGetDeploymentsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentGetDeploymentsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments",
args.account_id, args.project_name,
);
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("env", args.env.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 pages_deployment_create_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentCreateDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentCreateDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments",
args.account_id, args.project_name,
);
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 pages_deployment_get_deployment_info_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentGetDeploymentInfoArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentGetDeploymentInfoResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments/{}",
args.account_id, args.project_name, args.deployment_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 pages_deployment_delete_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentDeleteDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentDeleteDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments/{}",
args.account_id, args.project_name, args.deployment_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 pages_deployment_get_deployment_logs_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentGetDeploymentLogsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentGetDeploymentLogsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments/{}/history/logs",
args.account_id, args.project_name, args.deployment_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 pages_deployment_retry_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentRetryDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentRetryDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments/{}/retry",
args.account_id, args.project_name, args.deployment_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 pages_deployment_rollback_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDeploymentRollbackDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDeploymentRollbackDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/deployments/{}/rollback",
args.account_id, args.project_name, args.deployment_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 pages_domains_get_domains_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDomainsGetDomainsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDomainsGetDomainsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/domains",
args.account_id, args.project_name,
);
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 pages_domains_add_domain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDomainsAddDomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDomainsAddDomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/domains",
args.account_id, args.project_name,
);
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 pages_domains_get_domain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDomainsGetDomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDomainsGetDomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/domains/{}",
args.account_id, args.project_name, args.domain_name,
);
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 pages_domains_patch_domain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDomainsPatchDomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDomainsPatchDomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/domains/{}",
args.account_id, args.project_name, args.domain_name,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::patch(&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 pages_domains_delete_domain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesDomainsDeleteDomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesDomainsDeleteDomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/domains/{}",
args.account_id, args.project_name, args.domain_name,
);
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 pages_purge_build_cache_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PagesPurgeBuildCacheArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PagesPurgeBuildCacheResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pages/projects/{}/purge_build_cache",
args.account_id, args.project_name,
);
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 get_v4_accounts_by_account_id_pipelines_v1_pipelines_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1PipelinesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<GetV4AccountsByAccountIdPipelinesV1PipelinesResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/pipelines", 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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn post_v4_accounts_by_account_id_pipelines_v1_pipelines_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostV4AccountsByAccountIdPipelinesV1PipelinesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<PostV4AccountsByAccountIdPipelinesV1PipelinesResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/pipelines", 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_v4_accounts_by_account_id_pipelines_v1_pipelines_by_pipeline_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<GetV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/pipelines/{}",
args.account_id, args.pipeline_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 delete_v4_accounts_by_account_id_pipelines_v1_pipelines_by_pipeline_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteV4AccountsByAccountIdPipelinesV1PipelinesByPipelineIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/pipelines/{}",
args.account_id, args.pipeline_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 get_v4_accounts_by_account_id_pipelines_v1_sinks_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1SinksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV4AccountsByAccountIdPipelinesV1SinksResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/sinks", 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("pipeline_id", args.pipeline_id.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 post_v4_accounts_by_account_id_pipelines_v1_sinks_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostV4AccountsByAccountIdPipelinesV1SinksArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PostV4AccountsByAccountIdPipelinesV1SinksResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/sinks", 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_v4_accounts_by_account_id_pipelines_v1_sinks_by_sink_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<GetV4AccountsByAccountIdPipelinesV1SinksBySinkIdResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/sinks/{}",
args.account_id, args.sink_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 delete_v4_accounts_by_account_id_pipelines_v1_sinks_by_sink_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteV4AccountsByAccountIdPipelinesV1SinksBySinkIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/sinks/{}",
args.account_id, args.sink_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("force", args.force.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn get_v4_accounts_by_account_id_pipelines_v1_streams_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1StreamsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetV4AccountsByAccountIdPipelinesV1StreamsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/streams", 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("pipeline_id", args.pipeline_id.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 post_v4_accounts_by_account_id_pipelines_v1_streams_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostV4AccountsByAccountIdPipelinesV1StreamsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<PostV4AccountsByAccountIdPipelinesV1StreamsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/streams", 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_v4_accounts_by_account_id_pipelines_v1_streams_by_stream_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<GetV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/streams/{}",
args.account_id, args.stream_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 patch_v4_accounts_by_account_id_pipelines_v1_streams_by_stream_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<PatchV4AccountsByAccountIdPipelinesV1StreamsByStreamIdResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/streams/{}",
args.account_id, args.stream_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_v4_accounts_by_account_id_pipelines_v1_streams_by_stream_id_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteV4AccountsByAccountIdPipelinesV1StreamsByStreamIdArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pipelines/v1/streams/{}",
args.account_id, args.stream_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("force", args.force.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn post_v4_accounts_by_account_id_pipelines_v1_validate_sql_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PostV4AccountsByAccountIdPipelinesV1ValidateSqlArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<PostV4AccountsByAccountIdPipelinesV1ValidateSqlResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pipelines/v1/validate_sql", 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 worker_account_settings_fetch_worker_account_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerAccountSettingsFetchWorkerAccountSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<WorkerAccountSettingsFetchWorkerAccountSettingsResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/account-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 worker_account_settings_create_worker_account_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerAccountSettingsCreateWorkerAccountSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<
ApiResponse<WorkerAccountSettingsCreateWorkerAccountSettingsResponse>,
super::shared::ApiError,
>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/account-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 worker_assets_upload_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerAssetsUploadArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersCompletedUploadAssetsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/assets/upload", 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.query("base64", args.base64.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/dispatch/namespaces", 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 namespace_worker_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/dispatch/namespaces", 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 namespace_worker_get_namespace_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetNamespaceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}",
args.account_id, args.dispatch_namespace,
);
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 namespace_worker_put_namespace_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPutNamespaceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}",
args.account_id, args.dispatch_namespace,
);
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 namespace_worker_patch_namespace_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPatchNamespaceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}",
args.account_id, args.dispatch_namespace,
);
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 namespace_worker_delete_namespace_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerDeleteNamespaceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}",
args.account_id, args.dispatch_namespace,
);
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 namespace_worker_list_scripts_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerListScriptsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerListScriptsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts",
args.account_id, args.dispatch_namespace,
);
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("tags", args.tags.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_delete_scripts_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerDeleteScriptsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceScriptDeleteBulkResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts",
args.account_id, args.dispatch_namespace,
);
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("tags", args.tags.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 namespace_worker_script_worker_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerScriptWorkerDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersNamespaceScriptResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_script_upload_worker_module_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerScriptUploadWorkerModuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<Workers200Response>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}",
args.account_id, args.dispatch_namespace, args.script_name,
);
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.query("bindings_inherit", args.bindings_inherit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_script_delete_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerScriptDeleteWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}",
args.account_id, args.dispatch_namespace, args.script_name,
);
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("force", args.force.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_script_update_create_assets_upload_session_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerScriptUpdateCreateAssetsUploadSessionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersCreateAssetsUploadSessionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/assets-upload-session",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_get_script_bindings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetScriptBindingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerGetScriptBindingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/bindings",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_get_script_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetScriptContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/content",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_put_script_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPutScriptContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/content",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_list_script_secrets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerListScriptSecretsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerListScriptSecretsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/secrets",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_put_script_secrets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPutScriptSecretsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerPutScriptSecretsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/secrets",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_get_script_secrets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetScriptSecretsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerGetScriptSecretsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/secrets/{}",
args.account_id, args.dispatch_namespace, args.script_name, args.secret_name,
);
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("url_encoded", args.url_encoded.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_delete_script_secret_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerDeleteScriptSecretArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/secrets/{}",
args.account_id, args.dispatch_namespace, args.script_name, args.secret_name,
);
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("url_encoded", args.url_encoded.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn namespace_worker_get_script_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetScriptSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerGetScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/settings",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_patch_script_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPatchScriptSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerPatchScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/settings",
args.account_id, args.dispatch_namespace, args.script_name,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::patch(&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 namespace_worker_get_script_tags_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerGetScriptTagsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerGetScriptTagsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/tags",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_put_script_tags_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPutScriptTagsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NamespaceWorkerPutScriptTagsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/tags",
args.account_id, args.dispatch_namespace, args.script_name,
);
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 namespace_worker_put_script_tag_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerPutScriptTagArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/tags/{}",
args.account_id, args.dispatch_namespace, args.script_name, args.tag,
);
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 namespace_worker_delete_script_tag_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NamespaceWorkerDeleteScriptTagArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/dispatch/namespaces/{}/scripts/{}/tags/{}",
args.account_id, args.dispatch_namespace, args.script_name, args.tag,
);
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 workers_domains_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkersDomainsListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersDomainsListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/domains", 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("zone_id", args.zone_id.as_deref());
builder = builder.query("zone_name", args.zone_name.as_deref());
builder = builder.query("service", args.service.as_deref());
builder = builder.query("hostname", args.hostname.as_deref());
builder = builder.query("environment", args.environment.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn workers_domains_update_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkersDomainsUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersDomainsUpdateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/domains", 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 workers_domains_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkersDomainsGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersDomainsGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/domains/{}",
args.account_id, args.domain_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 workers_domains_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkersDomainsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/domains/{}",
args.account_id, args.domain_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 durable_objects_namespace_list_namespaces_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DurableObjectsNamespaceListNamespacesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DurableObjectsNamespaceListNamespacesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/durable_objects/namespaces",
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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn durable_objects_namespace_list_objects_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DurableObjectsNamespaceListObjectsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DurableObjectsNamespaceListObjectsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/durable_objects/namespaces/{}/objects",
args.account_id, args.id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("limit", args.limit.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn destination_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DestinationListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DestinationListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/destinations",
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("perPage", args.per_page.as_deref());
builder = builder.query("order", args.order.as_deref());
builder = builder.query("orderBy", args.order_by.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn destination_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DestinationCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DestinationCreateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/destinations",
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 destination_update_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DestinationUpdateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DestinationUpdateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/workers/observability/destinations/{}",
args.slug,
);
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 destinations_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DestinationsDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<DestinationsDeleteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/workers/observability/destinations/{}",
args.slug,
);
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 queries_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &QueriesListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<QueriesListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/queries",
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("perPage", args.per_page.as_deref());
builder = builder.query("order", args.order.as_deref());
builder = builder.query("orderBy", args.order_by.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn queries_post_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &QueriesPostArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<QueriesPostResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/queries",
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 queries_get_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &QueriesGetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<QueriesGetResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/workers/observability/queries/{}",
args.query_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 queries_patch_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &QueriesPatchArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<QueriesPatchResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/workers/observability/queries/{}",
args.query_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 queries_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &QueriesDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<QueriesDeleteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{{account_id}}/workers/observability/queries/{}",
args.query_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 telemetry_keys_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TelemetryKeysListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TelemetryKeysListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/telemetry/keys",
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 telemetry_query_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TelemetryQueryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TelemetryQueryResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/telemetry/query",
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 telemetry_values_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &TelemetryValuesListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TelemetryValuesListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/observability/telemetry/values",
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 worker_placement_list_regions_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerPlacementListRegionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerPlacementListRegionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/placement/regions", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_list_workers_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptListWorkersArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/scripts", 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("tags", args.tags.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_search_workers_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptSearchWorkersArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerScriptSearchWorkersResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/scripts-search", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("name", args.name.as_deref());
builder = builder.query("id", args.id.as_deref());
builder = builder.query("order_by", args.order_by.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 worker_script_download_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptDownloadWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}",
args.account_id, args.script_name,
);
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 worker_script_upload_worker_module_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptUploadWorkerModuleArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerScriptUploadWorkerModuleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}",
args.account_id, args.script_name,
);
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.query("bindings_inherit", args.bindings_inherit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_delete_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptDeleteWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}",
args.account_id, args.script_name,
);
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("force", args.force.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_update_create_assets_upload_session_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptUpdateCreateAssetsUploadSessionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersCreateAssetsUploadSessionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/assets-upload-session",
args.account_id, args.script_name,
);
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 worker_script_put_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptPutContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/content",
args.account_id, args.script_name,
);
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 worker_script_get_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptGetContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/content/v2",
args.account_id, args.script_name,
);
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 worker_deployments_list_deployments_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerDeploymentsListDeploymentsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerDeploymentsListDeploymentsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/deployments",
args.account_id, args.script_name,
);
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 worker_deployments_create_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerDeploymentsCreateDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerDeploymentsCreateDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/deployments",
args.account_id, args.script_name,
);
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.query("force", args.force.as_deref());
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 worker_deployments_get_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerDeploymentsGetDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerDeploymentsGetDeploymentResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/deployments/{}",
args.account_id, args.script_name, args.deployment_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 worker_deployments_delete_deployment_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerDeploymentsDeleteDeploymentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/deployments/{}",
args.account_id, args.script_name, args.deployment_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 worker_cron_trigger_get_cron_triggers_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerCronTriggerGetCronTriggersArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerCronTriggerGetCronTriggersResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/schedules",
args.account_id, args.script_name,
);
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 worker_cron_trigger_update_cron_triggers_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerCronTriggerUpdateCronTriggersArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerCronTriggerUpdateCronTriggersResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/schedules",
args.account_id, args.script_name,
);
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 worker_script_settings_get_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptSettingsGetSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/script-settings",
args.account_id, args.script_name,
);
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 worker_script_settings_patch_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptSettingsPatchSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/script-settings",
args.account_id, args.script_name,
);
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 worker_list_script_secrets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerListScriptSecretsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerListScriptSecretsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/secrets",
args.account_id, args.script_name,
);
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 worker_put_script_secret_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerPutScriptSecretArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerPutScriptSecretResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/secrets",
args.account_id, args.script_name,
);
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 worker_get_script_secret_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerGetScriptSecretArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerGetScriptSecretResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/secrets/{}",
args.account_id, args.script_name, args.secret_name,
);
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("url_encoded", args.url_encoded.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_delete_script_secret_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerDeleteScriptSecretArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseNullResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/secrets/{}",
args.account_id, args.script_name, args.secret_name,
);
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("url_encoded", args.url_encoded.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_get_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptGetSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptAndVersionSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/settings",
args.account_id, args.script_name,
);
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 worker_script_patch_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptPatchSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptAndVersionSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/settings",
args.account_id, args.script_name,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::patch(&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 worker_script_get_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptGetSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerScriptGetSubdomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/subdomain",
args.account_id, args.script_name,
);
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 worker_script_post_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptPostSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerScriptPostSubdomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/subdomain",
args.account_id, args.script_name,
);
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 worker_script_delete_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptDeleteSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerScriptDeleteSubdomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/subdomain",
args.account_id, args.script_name,
);
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 worker_tail_logs_start_tail_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerTailLogsStartTailArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerTailLogsStartTailResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/tails",
args.account_id, args.script_name,
);
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 worker_tail_logs_delete_tail_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerTailLogsDeleteTailArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/tails/{}",
args.account_id, args.script_name, args.id,
);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_script_fetch_usage_model_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptFetchUsageModelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersUsageModelResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/usage-model",
args.account_id, args.script_name,
);
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 worker_script_update_usage_model_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptUpdateUsageModelArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersUsageModelResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/usage-model",
args.account_id, args.script_name,
);
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 worker_versions_list_versions_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerVersionsListVersionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersVersionsListResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/versions",
args.account_id, args.script_name,
);
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("deployable", args.deployable.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 worker_versions_upload_version_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerVersionsUploadVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersVersionsUploadResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/versions",
args.account_id, args.script_name,
);
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.query("bindings_inherit", args.bindings_inherit.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_versions_get_version_detail_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerVersionsGetVersionDetailArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersVersionsSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/scripts/{}/versions/{}",
args.account_id, args.script_name, args.version_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 worker_environment_get_script_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerEnvironmentGetScriptContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::ByteStream>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/services/{}/environments/{}/content",
args.account_id, args.service_name, args.environment_name,
);
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 worker_environment_put_script_content_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerEnvironmentPutScriptContentArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/services/{}/environments/{}/content",
args.account_id, args.service_name, args.environment_name,
);
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 worker_script_environment_get_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptEnvironmentGetSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/services/{}/environments/{}/settings",
args.account_id, args.service_name, args.environment_name,
);
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 worker_script_environment_patch_settings_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerScriptEnvironmentPatchSettingsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersScriptSettingsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/services/{}/environments/{}/settings",
args.account_id, args.service_name, args.environment_name,
);
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 worker_subdomain_get_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerSubdomainGetSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerSubdomainGetSubdomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/subdomain", 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 worker_subdomain_create_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerSubdomainCreateSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerSubdomainCreateSubdomainResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/subdomain", 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 worker_subdomain_delete_subdomain_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerSubdomainDeleteSubdomainArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/subdomain", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn list_workers_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListWorkersArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListWorkersResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/workers", 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("order_by", args.order_by.as_deref());
builder = builder.query("order", args.order.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateWorkerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workers/workers", 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_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetWorkerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}",
args.account_id, args.worker_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_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &UpdateWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<UpdateWorkerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}",
args.account_id, args.worker_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 edit_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &EditWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<EditWorkerResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}",
args.account_id, args.worker_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_worker_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteWorkerArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}",
args.account_id, args.worker_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 list_worker_versions_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ListWorkerVersionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ListWorkerVersionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}/versions",
args.account_id, args.worker_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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn create_worker_version_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CreateWorkerVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CreateWorkerVersionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}/versions",
args.account_id, args.worker_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.query("deploy", args.deploy.as_deref());
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_worker_version_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &GetWorkerVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<GetWorkerVersionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}/versions/{}",
args.account_id, args.worker_id, args.version_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("include", args.include.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn delete_worker_version_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &DeleteWorkerVersionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkersApiResponseCommon>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workers/workers/{}/versions/{}",
args.account_id, args.worker_id, args.version_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 custom_pages_for_a_zone_list_custom_pages_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAZoneListCustomPagesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPageResultList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/custom_pages", args.zone_identifier,);
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 custom_assets_for_a_zone_list_custom_assets_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAZoneListCustomAssetsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResultList>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/custom_pages/assets", args.zone_identifier,);
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());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn custom_assets_for_a_zone_create_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAZoneCreateACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/custom_pages/assets", args.zone_identifier,);
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 custom_assets_for_a_zone_get_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAZoneGetACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/custom_pages/assets/{}",
args.zone_identifier, args.asset_name,
);
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 custom_assets_for_a_zone_update_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAZoneUpdateACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomAssetResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/custom_pages/assets/{}",
args.zone_identifier, args.asset_name,
);
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 custom_assets_for_a_zone_delete_a_custom_asset_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomAssetsForAZoneDeleteACustomAssetArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/custom_pages/assets/{}",
args.zone_identifier, args.asset_name,
);
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 custom_pages_for_a_zone_get_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAZoneGetACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPage>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/custom_pages/{}",
args.zone_identifier, args.identifier,
);
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 custom_pages_for_a_zone_update_a_custom_page_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CustomPagesForAZoneUpdateACustomPageArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<CustomPagesCustomPageResult>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/custom_pages/{}",
args.zone_identifier, args.identifier,
);
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 speed_list_pages_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedListPagesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryPagesResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/speed_api/pages", 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn speed_list_test_history_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedListTestHistoryArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryPageTestResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/speed_api/pages/{}/tests", args.zone_id, args.url,);
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("region", args.region.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn speed_create_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedCreateTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryPageTestResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/speed_api/pages/{}/tests", args.zone_id, args.url,);
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 speed_delete_tests_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedDeleteTestsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryCountResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/speed_api/pages/{}/tests", args.zone_id, args.url,);
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("region", args.region.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn speed_get_test_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedGetTestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryPageTestResponseSingle>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/zones/{}/speed_api/pages/{}/tests/{}",
args.zone_id, args.url, 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn speed_list_page_trend_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SpeedListPageTrendArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ObservatoryTrendResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/speed_api/pages/{}/trend", args.zone_id, args.url,);
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("region", args.region.as_deref());
builder = builder.query("deviceType", args.device_type.as_deref());
builder = builder.query("start", args.start.as_deref());
builder = builder.query("end", args.end.as_deref());
builder = builder.query("tz", args.tz.as_deref());
builder = builder.query("metrics", args.metrics.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_routes_list_routes_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerRoutesListRoutesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerRoutesListRoutesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/workers/routes", 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()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn worker_routes_create_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerRoutesCreateRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerRoutesCreateRouteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/workers/routes", args.zone_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 worker_routes_get_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerRoutesGetRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerRoutesGetRouteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/workers/routes/{}", args.zone_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 worker_routes_update_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerRoutesUpdateRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerRoutesUpdateRouteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/workers/routes/{}", args.zone_id, args.route_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 worker_routes_delete_route_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorkerRoutesDeleteRouteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorkerRoutesDeleteRouteResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/zones/{}/workers/routes/{}", args.zone_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
}