use crate::workflow::{WorkflowDefinitionSpec, WorkflowRunStatus, WorkflowSignal};
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ApplyWorkflowProviderDefinitionRequest {
pub provider: String,
pub spec: Option<WorkflowDefinitionSpec>,
pub idempotency_key: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct CancelWorkflowProviderRunRequest {
pub run_id: String,
pub reason: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DeleteWorkflowProviderDefinitionRequest {
pub definition_id: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct GetWorkflowProviderDefinitionRequest {
pub definition_id: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct GetWorkflowProviderRunEventsRequest {
pub run_id: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct GetWorkflowProviderRunOutputRequest {
pub run_id: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct GetWorkflowProviderRunRequest {
pub run_id: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ListWorkflowProviderDefinitionsRequest {
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ListWorkflowProviderRunsRequest {
pub page_size: i32,
pub page_token: String,
pub status: WorkflowRunStatus,
pub target_app: String,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SetWorkflowProviderActivationPausedRequest {
pub definition_id: String,
pub activation_id: String,
pub paused: bool,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SetWorkflowProviderDefinitionPausedRequest {
pub definition_id: String,
pub paused: bool,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SignalOrStartWorkflowProviderRunRequest {
pub workflow_key: String,
pub idempotency_key: String,
pub signal: Option<WorkflowSignal>,
pub provider: String,
pub definition_id: String,
pub input: Option<serde_json::Map<String, serde_json::Value>>,
pub expected_definition_generation: i64,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct SignalWorkflowProviderRunRequest {
pub run_id: String,
pub signal: Option<WorkflowSignal>,
pub provider: String,
}
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct StartWorkflowProviderRunRequest {
pub idempotency_key: String,
pub workflow_key: String,
pub provider: String,
pub definition_id: String,
pub input: Option<serde_json::Map<String, serde_json::Value>>,
pub expected_definition_generation: i64,
}