#![cfg(feature = "cloudflare_accounts")]
#![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::IamApiResponseCollection;
use super::shared::IamApiResponseCommon;
use super::shared::IamApiResponseSingle;
use super::shared::IamApiResponseSingleId;
use super::shared::IamCommonComponentsSchemasIdentifier;
use super::shared::IamResultInfo;
use super::shared::TunnelApiResponseCommon;
use super::shared::TunnelCreatedAt;
use super::shared::TunnelDeletedAt;
use super::shared::ApiResponse;
pub type IamAccount = super::shared::IamAccountShape;
pub type IamAccountType = serde_json::Value;
pub type IamComponentsSchemasAccount = super::shared::IamSchemasAccountShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct IamCreateAccount {
pub name: String,
#[serde(rename = "type")]
pub r#type: Option<serde_json::Value>,
pub unit: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct IamResponseCollectionAccounts {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<IamAccount>>,
pub result_info: Option<IamResultInfo>,
pub success: bool,
}
pub type IamResponseSingleAccount = super::shared::ApiEnvelope<Option<IamAccount>>;
pub type IamSchemasMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsApiResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<serde_json::Value>>,
pub result_info: Option<MagicVisibilityPcapsResultInfo>,
pub success: bool,
}
pub type MagicVisibilityPcapsApiResponseCommon = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicVisibilityPcapsApiResponseSingle = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicVisibilityPcapsMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type MagicVisibilityPcapsPcapsByteLimit = f64;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsCollectionResponse {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<serde_json::Value>,
pub result_info: Option<MagicVisibilityPcapsResultInfo>,
pub success: bool,
}
pub type MagicVisibilityPcapsPcapsColoName = String;
pub type MagicVisibilityPcapsPcapsDestinationConf = String;
pub type MagicVisibilityPcapsPcapsErrorMessage = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsFilterV1 {
pub destination_address: Option<String>,
pub destination_port: Option<f64>,
pub protocol: Option<f64>,
pub source_address: Option<String>,
pub source_port: Option<f64>,
}
pub type MagicVisibilityPcapsPcapsId = String;
pub type MagicVisibilityPcapsPcapsOffsetTime = String;
pub type MagicVisibilityPcapsPcapsPacketLimit = f64;
pub type MagicVisibilityPcapsPcapsPacketsCaptured = i64;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsRequestFull {
pub byte_limit: Option<f64>,
pub colo_name: String,
pub destination_conf: String,
pub filter_v1: Option<MagicVisibilityPcapsPcapsFilterV1>,
pub packet_limit: Option<f64>,
pub system: String,
pub time_limit: f64,
#[serde(rename = "type")]
pub r#type: String,
}
pub type MagicVisibilityPcapsPcapsRequestPcap = serde_json::Value;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsRequestSimple {
pub filter_v1: Option<MagicVisibilityPcapsPcapsFilterV1>,
pub offset_time: Option<String>,
pub packet_limit: f64,
pub system: String,
pub time_limit: f64,
#[serde(rename = "type")]
pub r#type: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsResponseFull {
pub byte_limit: Option<f64>,
pub colo_name: Option<String>,
pub destination_conf: Option<String>,
pub error_message: Option<String>,
pub filter_v1: Option<MagicVisibilityPcapsPcapsFilterV1>,
pub id: Option<String>,
pub packets_captured: Option<i64>,
pub status: Option<String>,
pub stop_requested: Option<String>,
pub submitted: Option<String>,
pub system: Option<String>,
pub time_limit: Option<f64>,
#[serde(rename = "type")]
pub r#type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct MagicVisibilityPcapsPcapsResponseSimple {
pub filter_v1: Option<MagicVisibilityPcapsPcapsFilterV1>,
pub id: Option<String>,
pub offset_time: Option<String>,
pub status: Option<String>,
pub submitted: Option<String>,
pub system: Option<String>,
pub time_limit: Option<f64>,
#[serde(rename = "type")]
pub r#type: Option<String>,
}
pub type MagicVisibilityPcapsPcapsSingleResponse = super::shared::ApiEnvelope<serde_json::Value>;
pub type MagicVisibilityPcapsPcapsStatus = String;
pub type MagicVisibilityPcapsPcapsStopRequested = String;
pub type MagicVisibilityPcapsPcapsSubmitted = String;
pub type MagicVisibilityPcapsPcapsSystem = String;
pub type MagicVisibilityPcapsPcapsTimeLimitFull = f64;
pub type MagicVisibilityPcapsPcapsTimeLimitSampled = f64;
pub type MagicVisibilityPcapsPcapsType = String;
pub type MagicVisibilityPcapsResultInfo = super::shared::FirewallResultInfoShape;
pub type StringType = serde_json::Value;
pub type TunnelAccountId = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelApiResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Option<Vec<serde_json::Value>>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelCfdTunnel {
pub account_tag: Option<String>,
pub config_src: Option<String>,
pub connections: Option<Vec<TunnelSchemasConnection>>,
pub conns_active_at: Option<String>,
pub conns_inactive_at: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub metadata: Option<serde_json::Value>,
pub name: Option<String>,
pub remote_config: Option<bool>,
pub status: Option<String>,
pub tun_type: Option<String>,
}
pub type TunnelClientId = String;
pub type TunnelColoName = String;
pub type TunnelConfigSrc = String;
pub type TunnelConnectionId = String;
pub type TunnelConnectionsDeprecated = Vec<TunnelSchemasConnection>;
pub type TunnelConnsActiveAt = String;
pub type TunnelConnsInactiveAt = String;
pub type TunnelIsPendingReconnect = bool;
pub type TunnelMessages = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type TunnelMetadata = serde_json::Value;
pub type TunnelRemoteConfig = bool;
pub type TunnelResultInfo = super::shared::FirewallResultInfoShape;
pub type TunnelSchemasConnection = super::shared::TunnelSchemasConnectionShape;
pub type TunnelStatus = String;
pub type TunnelTunnelId = String;
pub type TunnelTunnelName = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelTunnelResponseCollection {
pub errors: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub messages: Vec<std::collections::HashMap<String, serde_json::Value>>,
pub result: Vec<serde_json::Value>,
pub result_info: Option<TunnelResultInfo>,
pub success: bool,
}
pub type TunnelTunnelType = String;
pub type TunnelVersion = String;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TunnelWarpConnectorTunnel {
pub account_tag: Option<String>,
pub connections: Option<Vec<TunnelSchemasConnection>>,
pub conns_active_at: Option<String>,
pub conns_inactive_at: Option<String>,
pub created_at: Option<String>,
pub deleted_at: Option<String>,
pub id: Option<String>,
pub metadata: Option<serde_json::Value>,
pub name: Option<String>,
pub status: Option<String>,
pub tun_type: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorBatchCreateWorkflowInstanceRequestItem {
pub instance_id: Option<String>,
pub instance_retention: Option<WorBatchCreateWorkflowInstanceRequestItemInstanceRetention>,
pub params: Option<serde_json::Value>,
}
pub type WorBatchCreateWorkflowInstanceRequestItemInstanceRetention =
super::shared::ErrorRetentionSuccessRetentionObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorBatchCreateWorkflowInstanceResponse {
pub errors: Vec<WorBatchCreateWorkflowInstanceResponseErrorsItem>,
pub messages: Vec<WorBatchCreateWorkflowInstanceResponseMessagesItem>,
pub result: Vec<WorBatchCreateWorkflowInstanceResponseResultItem>,
pub result_info: Option<WorBatchCreateWorkflowInstanceResponseResultInfo>,
pub success: bool,
}
pub type WorBatchCreateWorkflowInstanceResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorBatchCreateWorkflowInstanceResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorBatchCreateWorkflowInstanceResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
pub type WorBatchCreateWorkflowInstanceResponseResultItem =
super::shared::WorBatchCreateWorkflowInstanceResponseResultItemShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorBatchTerminateWorkflowInstancesResponse {
pub errors: Vec<WorBatchTerminateWorkflowInstancesResponseErrorsItem>,
pub messages: Vec<WorBatchTerminateWorkflowInstancesResponseMessagesItem>,
pub result: WorBatchTerminateWorkflowInstancesResponseResult,
pub result_info: Option<WorBatchTerminateWorkflowInstancesResponseResultInfo>,
pub success: bool,
}
pub type WorBatchTerminateWorkflowInstancesResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorBatchTerminateWorkflowInstancesResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorBatchTerminateWorkflowInstancesResponseResult {
#[serde(rename = "instancesTerminated")]
pub instances_terminated: f64,
pub status: String,
}
pub type WorBatchTerminateWorkflowInstancesResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
pub type WorChangeStatusWorkflowInstanceRequest = super::shared::StatusObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorChangeStatusWorkflowInstanceResponse {
pub errors: Vec<WorChangeStatusWorkflowInstanceResponseErrorsItem>,
pub messages: Vec<WorChangeStatusWorkflowInstanceResponseMessagesItem>,
pub result: WorChangeStatusWorkflowInstanceResponseResult,
pub result_info: Option<WorChangeStatusWorkflowInstanceResponseResultInfo>,
pub success: bool,
}
pub type WorChangeStatusWorkflowInstanceResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorChangeStatusWorkflowInstanceResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorChangeStatusWorkflowInstanceResponseResult {
pub status: String,
pub timestamp: String,
}
pub type WorChangeStatusWorkflowInstanceResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorCreateNewWorkflowInstanceRequest {
pub instance_id: Option<String>,
pub instance_retention: Option<WorCreateNewWorkflowInstanceRequestInstanceRetention>,
pub params: Option<serde_json::Value>,
}
pub type WorCreateNewWorkflowInstanceRequestInstanceRetention =
super::shared::ErrorRetentionSuccessRetentionObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorCreateNewWorkflowInstanceResponse {
pub errors: Vec<WorCreateNewWorkflowInstanceResponseErrorsItem>,
pub messages: Vec<WorCreateNewWorkflowInstanceResponseMessagesItem>,
pub result: WorCreateNewWorkflowInstanceResponseResult,
pub result_info: Option<WorCreateNewWorkflowInstanceResponseResultInfo>,
pub success: bool,
}
pub type WorCreateNewWorkflowInstanceResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorCreateNewWorkflowInstanceResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorCreateNewWorkflowInstanceResponseResult =
super::shared::WorBatchCreateWorkflowInstanceResponseResultItemShape;
pub type WorCreateNewWorkflowInstanceResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorCreateOrModifyWorkflowRequest {
pub class_name: String,
pub limits: Option<WorCreateOrModifyWorkflowRequestLimits>,
pub script_name: String,
}
pub type WorCreateOrModifyWorkflowRequestLimits = super::shared::StepsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorCreateOrModifyWorkflowResponse {
pub errors: Vec<WorCreateOrModifyWorkflowResponseErrorsItem>,
pub messages: Vec<WorCreateOrModifyWorkflowResponseMessagesItem>,
pub result: WorCreateOrModifyWorkflowResponseResult,
pub result_info: Option<WorCreateOrModifyWorkflowResponseResultInfo>,
pub success: bool,
}
pub type WorCreateOrModifyWorkflowResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorCreateOrModifyWorkflowResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorCreateOrModifyWorkflowResponseResult {
pub class_name: String,
pub created_on: String,
pub id: String,
pub is_deleted: f64,
pub modified_on: String,
pub name: String,
pub script_name: String,
pub terminator_running: f64,
pub triggered_on: Option<String>,
pub version_id: String,
}
pub type WorCreateOrModifyWorkflowResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDeleteWorkflowResponse {
pub errors: Vec<WorDeleteWorkflowResponseErrorsItem>,
pub messages: Vec<WorDeleteWorkflowResponseMessagesItem>,
pub result: WorDeleteWorkflowResponseResult,
pub result_info: Option<WorDeleteWorkflowResponseResultInfo>,
pub success: bool,
}
pub type WorDeleteWorkflowResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorDeleteWorkflowResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDeleteWorkflowResponseResult {
pub status: String,
pub success: Option<bool>,
}
pub type WorDeleteWorkflowResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowInstanceResponse {
pub errors: Vec<WorDescribeWorkflowInstanceResponseErrorsItem>,
pub messages: Vec<WorDescribeWorkflowInstanceResponseMessagesItem>,
pub result: WorDescribeWorkflowInstanceResponseResult,
pub result_info: Option<WorDescribeWorkflowInstanceResponseResultInfo>,
pub success: bool,
}
pub type WorDescribeWorkflowInstanceResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorDescribeWorkflowInstanceResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowInstanceResponseResult {
pub end: Option<String>,
pub error: Option<WorDescribeWorkflowInstanceResponseResultError>,
pub output: serde_json::Value,
pub params: serde_json::Value,
pub queued: String,
pub start: Option<String>,
pub status: String,
pub step_count: i64,
pub steps: Vec<serde_json::Value>,
pub success: Option<bool>,
pub trigger: WorDescribeWorkflowInstanceResponseResultTrigger,
#[serde(rename = "versionId")]
pub version_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowInstanceResponseResultError {
pub message: String,
pub name: String,
}
pub type WorDescribeWorkflowInstanceResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowInstanceResponseResultTrigger {
pub source: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsDagResponse {
pub errors: Vec<WorDescribeWorkflowVersionsDagResponseErrorsItem>,
pub messages: Vec<WorDescribeWorkflowVersionsDagResponseMessagesItem>,
pub result: WorDescribeWorkflowVersionsDagResponseResult,
pub result_info: Option<WorDescribeWorkflowVersionsDagResponseResultInfo>,
pub success: bool,
}
pub type WorDescribeWorkflowVersionsDagResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorDescribeWorkflowVersionsDagResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsDagResponseResult {
pub class_name: String,
pub created_on: String,
pub dag: Option<serde_json::Value>,
pub id: String,
pub modified_on: String,
pub workflow_id: String,
}
pub type WorDescribeWorkflowVersionsDagResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsGraphResponse {
pub errors: Vec<WorDescribeWorkflowVersionsGraphResponseErrorsItem>,
pub messages: Vec<WorDescribeWorkflowVersionsGraphResponseMessagesItem>,
pub result: WorDescribeWorkflowVersionsGraphResponseResult,
pub result_info: Option<WorDescribeWorkflowVersionsGraphResponseResultInfo>,
pub success: bool,
}
pub type WorDescribeWorkflowVersionsGraphResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorDescribeWorkflowVersionsGraphResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsGraphResponseResult {
pub class_name: String,
pub created_on: String,
pub graph: Option<WorDescribeWorkflowVersionsGraphResponseResultGraph>,
pub id: String,
pub modified_on: String,
pub workflow_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsGraphResponseResultGraph {
pub version: f64,
pub workflow: WorDescribeWorkflowVersionsGraphResponseResultGraphWorkflow,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsGraphResponseResultGraphWorkflow {
pub class_name: String,
pub functions: serde_json::Value,
pub nodes: Vec<serde_json::Value>,
pub payload: Option<serde_json::Value>,
}
pub type WorDescribeWorkflowVersionsGraphResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsResponse {
pub errors: Vec<WorDescribeWorkflowVersionsResponseErrorsItem>,
pub messages: Vec<WorDescribeWorkflowVersionsResponseMessagesItem>,
pub result: WorDescribeWorkflowVersionsResponseResult,
pub result_info: Option<WorDescribeWorkflowVersionsResponseResultInfo>,
pub success: bool,
}
pub type WorDescribeWorkflowVersionsResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorDescribeWorkflowVersionsResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorDescribeWorkflowVersionsResponseResult {
pub class_name: String,
pub created_on: String,
pub has_dag: bool,
pub id: String,
pub limits: Option<WorDescribeWorkflowVersionsResponseResultLimits>,
pub modified_on: String,
pub workflow_id: String,
}
pub type WorDescribeWorkflowVersionsResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
pub type WorDescribeWorkflowVersionsResponseResultLimits = super::shared::StepsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorGetWorkflowDetailsResponse {
pub errors: Vec<WorGetWorkflowDetailsResponseErrorsItem>,
pub messages: Vec<WorGetWorkflowDetailsResponseMessagesItem>,
pub result: WorGetWorkflowDetailsResponseResult,
pub result_info: Option<WorGetWorkflowDetailsResponseResultInfo>,
pub success: bool,
}
pub type WorGetWorkflowDetailsResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorGetWorkflowDetailsResponseMessagesItem = super::shared::CodeMessageObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorGetWorkflowDetailsResponseResult {
pub class_name: String,
pub created_on: String,
pub id: String,
pub instances: WorGetWorkflowDetailsResponseResultInstances,
pub modified_on: String,
pub name: String,
pub script_name: String,
pub triggered_on: Option<String>,
}
pub type WorGetWorkflowDetailsResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
pub type WorGetWorkflowDetailsResponseResultInstances =
super::shared::WorGetWorkflowDetailsResponseResultInstancesShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowInstancesResponse {
pub errors: Vec<WorListWorkflowInstancesResponseErrorsItem>,
pub messages: Vec<WorListWorkflowInstancesResponseMessagesItem>,
pub result: Vec<WorListWorkflowInstancesResponseResultItem>,
pub result_info: Option<WorListWorkflowInstancesResponseResultInfo>,
pub success: bool,
}
pub type WorListWorkflowInstancesResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorListWorkflowInstancesResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorListWorkflowInstancesResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowInstancesResponseResultItem {
pub created_on: String,
pub ended_on: Option<String>,
pub id: String,
pub modified_on: String,
pub started_on: Option<String>,
pub status: String,
pub version_id: String,
pub workflow_id: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowVersionsResponse {
pub errors: Vec<WorListWorkflowVersionsResponseErrorsItem>,
pub messages: Vec<WorListWorkflowVersionsResponseMessagesItem>,
pub result: Vec<WorListWorkflowVersionsResponseResultItem>,
pub result_info: Option<WorListWorkflowVersionsResponseResultInfo>,
pub success: bool,
}
pub type WorListWorkflowVersionsResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorListWorkflowVersionsResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorListWorkflowVersionsResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowVersionsResponseResultItem {
pub class_name: String,
pub created_on: String,
pub has_dag: bool,
pub id: String,
pub limits: Option<WorListWorkflowVersionsResponseResultItemLimits>,
pub modified_on: String,
pub workflow_id: String,
}
pub type WorListWorkflowVersionsResponseResultItemLimits = super::shared::StepsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowsResponse {
pub errors: Vec<WorListWorkflowsResponseErrorsItem>,
pub messages: Vec<WorListWorkflowsResponseMessagesItem>,
pub result: Vec<WorListWorkflowsResponseResultItem>,
pub result_info: Option<WorListWorkflowsResponseResultInfo>,
pub success: bool,
}
pub type WorListWorkflowsResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorListWorkflowsResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorListWorkflowsResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorListWorkflowsResponseResultItem {
pub class_name: String,
pub created_on: String,
pub id: String,
pub instances: WorListWorkflowsResponseResultItemInstances,
pub modified_on: String,
pub name: String,
pub script_name: String,
pub triggered_on: Option<String>,
}
pub type WorListWorkflowsResponseResultItemInstances =
super::shared::WorGetWorkflowDetailsResponseResultInstancesShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct WorStatusTerminateWorkflowInstancesResponse {
pub errors: Vec<WorStatusTerminateWorkflowInstancesResponseErrorsItem>,
pub messages: Vec<WorStatusTerminateWorkflowInstancesResponseMessagesItem>,
pub result: WorStatusTerminateWorkflowInstancesResponseResult,
pub result_info: Option<WorStatusTerminateWorkflowInstancesResponseResultInfo>,
pub success: bool,
}
pub type WorStatusTerminateWorkflowInstancesResponseErrorsItem = super::shared::CodeMessageObject;
pub type WorStatusTerminateWorkflowInstancesResponseMessagesItem = super::shared::CodeMessageObject;
pub type WorStatusTerminateWorkflowInstancesResponseResult = super::shared::StatusObject;
pub type WorStatusTerminateWorkflowInstancesResponseResultInfo =
super::shared::WorBatchCreateWorkflowInstanceResponseResultInfoShape;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountsListAccountsArgs {
pub name: Option<String>,
pub page: Option<String>,
pub per_page: Option<String>,
pub direction: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountCreationArgs {
pub body: IamCreateAccount,
}
pub type AccountsAccountDetailsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct AccountsUpdateAccountArgs {
pub account_id: String,
pub body: IamComponentsSchemasAccount,
}
pub type AccountDeletionArgs = super::shared::AccountIdArgs;
pub type MagicPcapCollectionListPacketCaptureRequestsArgs = super::shared::AccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct MagicPcapCollectionCreatePcapRequestArgs {
pub account_id: String,
pub body: MagicVisibilityPcapsPcapsRequestPcap,
}
pub type MagicPcapCollectionGetPcapRequestArgs = super::shared::PcapIdAccountIdArgs;
pub type MagicPcapCollectionDownloadSimplePcapArgs = super::shared::PcapIdAccountIdArgs;
pub type MagicPcapCollectionStopFullPcapArgs = super::shared::PcapIdAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct CloudflareTunnelListAllTunnelsArgs {
pub account_id: String,
pub name: Option<String>,
pub is_deleted: Option<String>,
pub existed_at: Option<String>,
pub uuid: Option<String>,
pub was_active_at: Option<String>,
pub was_inactive_at: Option<String>,
pub include_prefix: Option<String>,
pub exclude_prefix: Option<String>,
pub tun_types: Option<String>,
pub status: Option<String>,
pub per_page: Option<String>,
pub page: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorListWorkflowsArgs {
pub account_id: String,
pub per_page: Option<String>,
pub page: Option<String>,
pub search: Option<String>,
}
pub type WorGetWorkflowDetailsArgs = super::shared::WorkflowNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorCreateOrModifyWorkflowArgs {
pub workflow_name: String,
pub account_id: String,
pub body: WorCreateOrModifyWorkflowRequest,
}
pub type WorDeleteWorkflowArgs = super::shared::WorkflowNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorListWorkflowInstancesArgs {
pub workflow_name: String,
pub account_id: String,
pub page: Option<String>,
pub per_page: Option<String>,
pub cursor: Option<String>,
pub direction: Option<String>,
pub status: Option<String>,
pub date_start: Option<String>,
pub date_end: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorCreateNewWorkflowInstanceArgs {
pub workflow_name: String,
pub account_id: String,
pub body: WorCreateNewWorkflowInstanceRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorBatchCreateWorkflowInstanceArgs {
pub workflow_name: String,
pub account_id: String,
pub body: Vec<WorBatchCreateWorkflowInstanceRequestItem>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorBatchTerminateWorkflowInstancesArgs {
pub workflow_name: String,
pub account_id: String,
pub body: Vec<String>,
}
pub type WorStatusTerminateWorkflowInstancesArgs = super::shared::WorkflowNameAccountIdArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorDescribeWorkflowInstanceArgs {
pub workflow_name: String,
pub instance_id: String,
pub account_id: String,
pub simple: Option<String>,
pub order: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorChangeStatusWorkflowInstanceArgs {
pub workflow_name: String,
pub instance_id: String,
pub account_id: String,
pub body: WorChangeStatusWorkflowInstanceRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct WorListWorkflowVersionsArgs {
pub workflow_name: String,
pub account_id: String,
pub per_page: Option<String>,
pub page: Option<String>,
}
pub type WorDescribeWorkflowVersionsArgs = super::shared::WorkflowNameVersionIdAccountIdArgs;
pub type WorDescribeWorkflowVersionsDagArgs = super::shared::WorkflowNameVersionIdAccountIdArgs;
pub type WorDescribeWorkflowVersionsGraphArgs = super::shared::WorkflowNameVersionIdAccountIdArgs;
pub async fn accounts_list_accounts_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccountsListAccountsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IamResponseCollectionAccounts>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts",);
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());
builder = builder.query("direction", args.direction.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn account_creation_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccountCreationArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IamResponseSingleAccount>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts",);
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 accounts_account_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccountsAccountDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IamResponseSingleAccount>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}", 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 accounts_update_account_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccountsUpdateAccountArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IamResponseSingleAccount>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}", 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 account_deletion_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &AccountDeletionArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IamApiResponseSingleId>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_pcap_collection_list_packet_capture_requests_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicPcapCollectionListPacketCaptureRequestsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityPcapsPcapsCollectionResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pcaps", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_pcap_collection_create_pcap_request_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicPcapCollectionCreatePcapRequestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityPcapsPcapsSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pcaps", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_pcap_collection_get_pcap_request_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicPcapCollectionGetPcapRequestArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<MagicVisibilityPcapsPcapsSingleResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pcaps/{}", args.account_id, args.pcap_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn magic_pcap_collection_download_simple_pcap_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicPcapCollectionDownloadSimplePcapArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/pcaps/{}/download",
args.account_id, args.pcap_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_without_body(client.into(), builder.build()).await
}
pub async fn magic_pcap_collection_stop_full_pcap_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &MagicPcapCollectionStopFullPcapArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/pcaps/{}/stop", args.account_id, args.pcap_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::put(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn cloudflare_tunnel_list_all_tunnels_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &CloudflareTunnelListAllTunnelsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<TunnelTunnelResponseCollection>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/tunnels", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("name", args.name.as_deref());
builder = builder.query("is_deleted", args.is_deleted.as_deref());
builder = builder.query("existed_at", args.existed_at.as_deref());
builder = builder.query("uuid", args.uuid.as_deref());
builder = builder.query("was_active_at", args.was_active_at.as_deref());
builder = builder.query("was_inactive_at", args.was_inactive_at.as_deref());
builder = builder.query("include_prefix", args.include_prefix.as_deref());
builder = builder.query("exclude_prefix", args.exclude_prefix.as_deref());
builder = builder.query("tun_types", args.tun_types.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn wor_list_workflows_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorListWorkflowsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorListWorkflowsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/accounts/{}/workflows", args.account_id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
builder = builder.query("search", args.search.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn wor_get_workflow_details_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorGetWorkflowDetailsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorGetWorkflowDetailsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}",
args.account_id, args.workflow_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 wor_create_or_modify_workflow_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorCreateOrModifyWorkflowArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorCreateOrModifyWorkflowResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}",
args.account_id, args.workflow_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 wor_delete_workflow_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorDeleteWorkflowArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorDeleteWorkflowResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}",
args.account_id, args.workflow_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 wor_list_workflow_instances_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorListWorkflowInstancesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorListWorkflowInstancesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances",
args.account_id, args.workflow_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("page", args.page.as_deref());
builder = builder.query("per_page", args.per_page.as_deref());
builder = builder.query("cursor", args.cursor.as_deref());
builder = builder.query("direction", args.direction.as_deref());
builder = builder.query("status", args.status.as_deref());
builder = builder.query("date_start", args.date_start.as_deref());
builder = builder.query("date_end", args.date_end.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn wor_create_new_workflow_instance_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorCreateNewWorkflowInstanceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorCreateNewWorkflowInstanceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances",
args.account_id, args.workflow_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 wor_batch_create_workflow_instance_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorBatchCreateWorkflowInstanceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorBatchCreateWorkflowInstanceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/batch",
args.account_id, args.workflow_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 wor_batch_terminate_workflow_instances_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorBatchTerminateWorkflowInstancesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorBatchTerminateWorkflowInstancesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/batch/terminate",
args.account_id, args.workflow_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 wor_status_terminate_workflow_instances_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorStatusTerminateWorkflowInstancesArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorStatusTerminateWorkflowInstancesResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/terminate",
args.account_id, args.workflow_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 wor_describe_workflow_instance_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorDescribeWorkflowInstanceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorDescribeWorkflowInstanceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/{}",
args.account_id, args.workflow_name, args.instance_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("simple", args.simple.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 wor_change_status_workflow_instance_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorChangeStatusWorkflowInstanceArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorChangeStatusWorkflowInstanceResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/instances/{}/status",
args.account_id, args.workflow_name, args.instance_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 wor_list_workflow_versions_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorListWorkflowVersionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorListWorkflowVersionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/versions",
args.account_id, args.workflow_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("per_page", args.per_page.as_deref());
builder = builder.query("page", args.page.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn wor_describe_workflow_versions_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorDescribeWorkflowVersionsArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorDescribeWorkflowVersionsResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/versions/{}",
args.account_id, args.workflow_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 wor_describe_workflow_versions_dag_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorDescribeWorkflowVersionsDagArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorDescribeWorkflowVersionsDagResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/versions/{}/dag",
args.account_id, args.workflow_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 wor_describe_workflow_versions_graph_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &WorDescribeWorkflowVersionsGraphArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<WorDescribeWorkflowVersionsGraphResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!(
"/accounts/{}/workflows/{}/versions/{}/graph",
args.account_id, args.workflow_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
}