#![allow(dead_code, private_interfaces, unused_imports)]
use super::*;
use serde::{Deserialize, Serialize};
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AccessPolicyDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub action: Option<String>,
#[serde(rename = "componentReference")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_reference: Option<ComponentReferenceEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub configurable: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub resource: Option<String>,
#[serde(rename = "userGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub user_groups: Option<Vec<TenantEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub users: Option<Vec<TenantEntity>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AccessPolicySummaryDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub action: Option<String>,
#[serde(rename = "componentReference")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_reference: Option<ComponentReferenceEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub configurable: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub resource: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AccessPolicySummaryEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<AccessPolicySummaryDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ActionDetailsDto {}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ActionDto {
#[serde(rename = "actionDetails")]
#[serde(skip_serializing_if = "Option::is_none")]
pub action_details: Option<ActionDetailsDto>,
#[serde(rename = "componentDetails")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_details: Option<ComponentDetailsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub operation: Option<String>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "sourceName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_name: Option<String>,
#[serde(rename = "sourceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
#[serde(rename = "userIdentity")]
#[serde(skip_serializing_if = "Option::is_none")]
pub user_identity: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AffectedComponentDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "processGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_id: Option<String>,
#[serde(rename = "referenceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reference_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AffectedComponentEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<AffectedComponentDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "processGroup")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group: Option<ProcessGroupNameDto>,
#[serde(rename = "referenceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reference_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AllowableValueDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AllowableValueEntity {
#[serde(rename = "allowableValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allowable_value: Option<AllowableValueDto>,
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AssetReferenceDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Attribute {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct AttributeDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "previousValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub previous_value: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BatchSettingsDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub duration: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub size: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BatchSize {
#[serde(skip_serializing_if = "Option::is_none")]
pub count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub duration: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub size: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BuildInfo {
#[serde(skip_serializing_if = "Option::is_none")]
pub compiler: Option<String>,
#[serde(rename = "compilerFlags")]
#[serde(skip_serializing_if = "Option::is_none")]
pub compiler_flags: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<String>,
#[serde(rename = "targetArch")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_arch: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BulletinBoardPatternParameter {
#[serde(skip_serializing_if = "Option::is_none")]
pub pattern: Option<serde_json::Value>,
#[serde(rename = "rawPattern")]
#[serde(skip_serializing_if = "Option::is_none")]
pub raw_pattern: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BulletinDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub category: Option<String>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub level: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub message: Option<String>,
#[serde(rename = "nodeAddress")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_address: Option<String>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "sourceName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_name: Option<String>,
#[serde(rename = "sourceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_type: Option<String>,
#[serde(rename = "stackTrace")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub stack_trace: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
#[serde(rename = "timestampIso")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp_iso: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Bundle {
#[serde(skip_serializing_if = "Option::is_none")]
pub artifact: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub group: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct BundleDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub artifact: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub group: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ClearBulletinsRequestEntity {
#[serde(rename = "fromTimestamp")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub from_timestamp: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ClearBulletinsResultEntity {
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(rename = "bulletinsCleared")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins_cleared: Option<i32>,
#[serde(rename = "componentId")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ClientIdParameter {
#[serde(rename = "clientId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub client_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentDetailsDto {}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentDifferenceDto {
#[serde(rename = "componentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(rename = "componentName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_name: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub differences: Option<Vec<DifferenceDto>>,
#[serde(rename = "processGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentHistoryDto {
#[serde(rename = "componentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(rename = "propertyHistory")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_history: Option<std::collections::HashMap<String, Option<PropertyHistoryDto>>>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentHistoryEntity {
pub component_history: Option<ComponentHistoryDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentManifest {
#[serde(skip_serializing_if = "Option::is_none")]
pub apis: Option<Vec<DefinedType>>,
#[serde(rename = "controllerServices")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_services: Option<Vec<ControllerServiceDefinition>>,
#[serde(rename = "flowAnalysisRules")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_analysis_rules: Option<Vec<FlowAnalysisRuleDefinition>>,
#[serde(rename = "flowRegistryClients")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_registry_clients: Option<Vec<FlowRegistryClientDefinition>>,
#[serde(rename = "parameterProviders")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_providers: Option<Vec<ParameterProviderDefinition>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub processors: Option<Vec<ProcessorDefinition>>,
#[serde(rename = "reportingTasks")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reporting_tasks: Option<Vec<ReportingTaskDefinition>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentReferenceDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentReferenceEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ComponentReferenceDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentRestrictionPermissionDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(rename = "requiredPermission")]
#[serde(skip_serializing_if = "Option::is_none")]
pub required_permission: Option<RequiredPermissionDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentSearchResultDto {
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub matches: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroup")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group: Option<SearchResultGroupDto>,
#[serde(rename = "versionedGroup")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_group: Option<SearchResultGroupDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentStateDto {
#[serde(rename = "clusterState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_state: Option<StateMapDto>,
#[serde(rename = "componentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(rename = "dropStateKeySupported")]
#[serde(skip_serializing_if = "Option::is_none")]
pub drop_state_key_supported: Option<bool>,
#[serde(rename = "localState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub local_state: Option<StateMapDto>,
#[serde(rename = "stateDescription")]
#[serde(skip_serializing_if = "Option::is_none")]
pub state_description: Option<String>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentStateEntity {
pub component_state: Option<ComponentStateDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentValidationResultDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "currentlyValid")]
#[serde(skip_serializing_if = "Option::is_none")]
pub currently_valid: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "processGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_id: Option<String>,
#[serde(rename = "referenceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reference_type: Option<String>,
#[serde(rename = "resultantValidationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resultant_validation_errors: Option<Vec<String>>,
#[serde(rename = "resultsValid")]
#[serde(skip_serializing_if = "Option::is_none")]
pub results_valid: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentValidationResultEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ComponentValidationResultDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ComponentValidationResultsEntity {
#[serde(rename = "validationResults")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_results: Option<Vec<ComponentValidationResultEntity>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConfigVerificationResultDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub explanation: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub outcome: Option<String>,
#[serde(rename = "verificationStepName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub verification_step_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConfigurationAnalysisDto {
#[serde(rename = "componentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "referencedAttributes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referenced_attributes: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "supportsVerification")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_verification: Option<bool>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConfigurationAnalysisEntity {
pub configuration_analysis: Option<ConfigurationAnalysisDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectableComponent {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectableDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub exists: Option<bool>,
#[serde(rename = "groupId")]
pub group_id: String,
pub id: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub running: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
pub r#type: String,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionDto {
#[serde(rename = "availableRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub available_relationships: Option<Vec<String>>,
#[serde(rename = "backPressureDataSizeThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub back_pressure_data_size_threshold: Option<String>,
#[serde(rename = "backPressureObjectThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub back_pressure_object_threshold: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bends: Option<Vec<PositionDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub destination: Option<ConnectableDto>,
#[serde(rename = "flowFileExpiration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_expiration: Option<String>,
#[serde(rename = "getzIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub getz_index: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "labelIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub label_index: Option<i32>,
#[serde(rename = "loadBalanceCompression")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_compression: Option<String>,
#[serde(rename = "loadBalancePartitionAttribute")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_partition_attribute: Option<String>,
#[serde(rename = "loadBalanceStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_status: Option<String>,
#[serde(rename = "loadBalanceStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_strategy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub prioritizers: Option<Vec<String>>,
#[serde(rename = "retriedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub retried_relationships: Option<Vec<String>>,
#[serde(rename = "selectedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub selected_relationships: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub source: Option<ConnectableDto>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bends: Option<Vec<PositionDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ConnectionDto>,
#[serde(rename = "destinationGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_group_id: Option<String>,
#[serde(rename = "destinationId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_id: Option<String>,
#[serde(rename = "destinationType")]
pub destination_type: String,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(rename = "getzIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub getz_index: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "labelIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub label_index: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(rename = "sourceGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_group_id: Option<String>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "sourceType")]
pub source_type: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<ConnectionStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatisticsDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<ConnectionStatisticsSnapshotDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeConnectionStatisticsSnapshotDto>>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatisticsSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "predictedBytesAtNextInterval")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_bytes_at_next_interval: Option<i64>,
#[serde(rename = "predictedCountAtNextInterval")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_count_at_next_interval: Option<i32>,
#[serde(rename = "predictedMillisUntilBytesBackpressure")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_millis_until_bytes_backpressure: Option<i64>,
#[serde(rename = "predictedMillisUntilCountBackpressure")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_millis_until_count_backpressure: Option<i64>,
#[serde(rename = "predictedPercentBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_percent_bytes: Option<i32>,
#[serde(rename = "predictedPercentCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_percent_count: Option<i32>,
#[serde(rename = "predictionIntervalMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub prediction_interval_millis: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatusDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<ConnectionStatusSnapshotDto>,
#[serde(rename = "destinationId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_id: Option<String>,
#[serde(rename = "destinationName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_name: Option<String>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeConnectionStatusSnapshotDto>>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "sourceName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_name: Option<String>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatusPredictionsSnapshotDto {
#[serde(rename = "predictedBytesAtNextInterval")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_bytes_at_next_interval: Option<i64>,
#[serde(rename = "predictedCountAtNextInterval")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_count_at_next_interval: Option<i32>,
#[serde(rename = "predictedMillisUntilBytesBackpressure")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_millis_until_bytes_backpressure: Option<i64>,
#[serde(rename = "predictedMillisUntilCountBackpressure")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_millis_until_count_backpressure: Option<i64>,
#[serde(rename = "predictedPercentBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_percent_bytes: Option<i32>,
#[serde(rename = "predictedPercentCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub predicted_percent_count: Option<i32>,
#[serde(rename = "predictionIntervalSeconds")]
#[serde(skip_serializing_if = "Option::is_none")]
pub prediction_interval_seconds: Option<i32>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatusSnapshotDto {
#[serde(rename = "bytesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_in: Option<i64>,
#[serde(rename = "bytesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_out: Option<i64>,
#[serde(rename = "bytesQueued")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_queued: Option<i64>,
#[serde(rename = "destinationId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_id: Option<String>,
#[serde(rename = "destinationName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub destination_name: Option<String>,
#[serde(rename = "flowFileAvailability")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_availability: Option<String>,
#[serde(rename = "flowFilesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_in: Option<i32>,
#[serde(rename = "flowFilesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_out: Option<i32>,
#[serde(rename = "flowFilesQueued")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_queued: Option<i32>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub input: Option<String>,
#[serde(rename = "loadBalanceStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_status: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub output: Option<String>,
#[serde(rename = "percentUseBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_use_bytes: Option<i32>,
#[serde(rename = "percentUseCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_use_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub predictions: Option<ConnectionStatusPredictionsSnapshotDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub queued: Option<String>,
#[serde(rename = "queuedCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub queued_count: Option<String>,
#[serde(rename = "queuedSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub queued_size: Option<String>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "sourceName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectionStatusSnapshotEntity {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(rename = "connectionStatusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub connection_status_snapshot: Option<ConnectionStatusSnapshotDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ContentViewerDto {
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(rename = "supportedMimeTypes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supported_mime_types: Option<Vec<SupportedMimeTypesDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerConfigurationDto {
#[serde(rename = "maxTimerDrivenThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_timer_driven_thread_count: Option<i32>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceAPI {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<Bundle>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceApiDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceDto {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(rename = "bulletinLevel")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletin_level: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "controllerServiceApis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_service_apis: Option<Vec<ControllerServiceApiDto>>,
#[serde(rename = "customUiUrl")]
#[serde(skip_serializing_if = "Option::is_none")]
pub custom_ui_url: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "persistsState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub persists_state: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "referencingComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_components: Option<Vec<ControllerServiceReferencingComponentEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(rename = "sensitiveDynamicPropertyNames")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive_dynamic_property_names: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "supportsSensitiveDynamicProperties")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_sensitive_dynamic_properties: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ControllerServiceDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<ControllerServiceStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceReferencingComponentDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "referenceCycle")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reference_cycle: Option<bool>,
#[serde(rename = "referenceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub reference_type: Option<String>,
#[serde(rename = "referencingComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_components: Option<Vec<ControllerServiceReferencingComponentEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceReferencingComponentEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ControllerServiceReferencingComponentDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ControllerServiceStatusDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct CountersSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub counters: Option<Vec<CounterDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub generated: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DateTimeParameter {
#[serde(rename = "dateTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub date_time: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DefinedType {
#[serde(skip_serializing_if = "Option::is_none")]
pub artifact: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub group: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "typeDescription")]
#[serde(skip_serializing_if = "Option::is_none")]
pub type_description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DifferenceDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub difference: Option<String>,
#[serde(rename = "differenceType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub difference_type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DimensionsDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub height: Option<f64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub width: Option<f64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DocumentedTypeDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(rename = "controllerServiceApis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_service_apis: Option<Vec<ControllerServiceApiDto>>,
#[serde(rename = "deprecationReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecation_reason: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "explicitRestrictions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub explicit_restrictions: Option<Vec<ExplicitRestrictionDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub tags: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "usageRestriction")]
#[serde(skip_serializing_if = "Option::is_none")]
pub usage_restriction: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DropRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub current: Option<String>,
#[serde(rename = "currentCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub current_count: Option<i32>,
#[serde(rename = "currentSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub current_size: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dropped: Option<String>,
#[serde(rename = "droppedCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub dropped_count: Option<i32>,
#[serde(rename = "droppedSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub dropped_size: Option<i64>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub finished: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub original: Option<String>,
#[serde(rename = "originalCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub original_count: Option<i32>,
#[serde(rename = "originalSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub original_size: Option<i64>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "submissionTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub submission_time: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DropRequestEntity {
pub drop_request: Option<DropRequestDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DynamicProperty {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "expressionLanguageScope")]
#[serde(skip_serializing_if = "Option::is_none")]
pub expression_language_scope: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct DynamicRelationship {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ExplicitRestrictionDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub explanation: Option<String>,
#[serde(rename = "requiredPermission")]
#[serde(skip_serializing_if = "Option::is_none")]
pub required_permission: Option<RequiredPermissionDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ExternalControllerServiceReference {
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowAnalysisRuleDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "enforcementPolicy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub enforcement_policy: Option<String>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "persistsState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub persists_state: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(rename = "sensitiveDynamicPropertyNames")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive_dynamic_property_names: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "supportsSensitiveDynamicProperties")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_sensitive_dynamic_properties: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowAnalysisRuleStatusDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowAnalysisRuleViolationDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub enabled: Option<bool>,
#[serde(rename = "enforcementPolicy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub enforcement_policy: Option<String>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(rename = "issueId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub issue_id: Option<String>,
#[serde(rename = "ruleId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub rule_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub scope: Option<String>,
#[serde(rename = "subjectComponentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub subject_component_type: Option<String>,
#[serde(rename = "subjectDisplayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub subject_display_name: Option<String>,
#[serde(rename = "subjectId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub subject_id: Option<String>,
#[serde(rename = "subjectPermissionDto")]
#[serde(skip_serializing_if = "Option::is_none")]
pub subject_permission_dto: Option<PermissionsDto>,
#[serde(rename = "violationMessage")]
#[serde(skip_serializing_if = "Option::is_none")]
pub violation_message: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowBreadcrumbDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "versionControlInformation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_control_information: Option<VersionControlInformationDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowComparisonEntity {
#[serde(rename = "componentDifferences")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_differences: Option<Vec<ComponentDifferenceDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowFileSummaryDto {
#[serde(rename = "clusterNodeAddress")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_address: Option<String>,
#[serde(rename = "clusterNodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub filename: Option<String>,
#[serde(rename = "lineageDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub lineage_duration: Option<i64>,
#[serde(rename = "mimeType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub mime_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub penalized: Option<bool>,
#[serde(rename = "penaltyExpiresIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub penalty_expires_in: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<i32>,
#[serde(rename = "queuedDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub queued_duration: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub size: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uuid: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryBranchDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryBranchEntity {
pub branch: Option<FlowRegistryBranchDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryBucket {
#[serde(rename = "createdTimestamp")]
#[serde(skip_serializing_if = "Option::is_none")]
pub created_timestamp: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<FlowRegistryPermissions>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryBucketDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub created: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryBucketEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket: Option<FlowRegistryBucketDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryClientDto {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(rename = "sensitiveDynamicPropertyNames")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive_dynamic_property_names: Option<Vec<String>>,
#[serde(rename = "supportsBranching")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_branching: Option<bool>,
#[serde(rename = "supportsSensitiveDynamicProperties")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_sensitive_dynamic_properties: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryClientsEntity {
#[serde(rename = "currentTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub current_time: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub registries: Option<Vec<FlowRegistryClientEntity>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowRegistryPermissions {
#[serde(rename = "canDelete")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_delete: Option<bool>,
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(rename = "canWrite")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_write: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FlowSnippetDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub connections: Option<Vec<ConnectionDto>>,
#[serde(rename = "controllerServices")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_services: Option<Vec<ControllerServiceDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub funnels: Option<Vec<FunnelDto>>,
#[serde(rename = "inputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_ports: Option<Vec<PortDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub labels: Option<Vec<LabelDto>>,
#[serde(rename = "outputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_ports: Option<Vec<PortDto>>,
#[serde(rename = "processGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_groups: Option<Vec<ProcessGroupDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub processors: Option<Vec<ProcessorDto>>,
#[serde(rename = "remoteProcessGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_process_groups: Option<Vec<RemoteProcessGroupDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FunnelDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct FunnelEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<FunnelDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct GarbageCollectionDto {
#[serde(rename = "collectionCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub collection_count: Option<i64>,
#[serde(rename = "collectionMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub collection_millis: Option<i64>,
#[serde(rename = "collectionTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub collection_time: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct HistoryDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub actions: Option<Vec<ActionEntity>>,
#[serde(rename = "lastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_refreshed: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub total: Option<i32>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct HistoryEntity {
pub history: Option<HistoryDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct IntegerParameter {
#[serde(skip_serializing_if = "Option::is_none")]
pub integer: Option<i32>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct JmxMetricsResultDto {
#[serde(rename = "attributeName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub attribute_name: Option<String>,
#[serde(rename = "attributeValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub attribute_value: Option<serde_json::Value>,
#[serde(rename = "beanName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bean_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LabelDto {
#[serde(rename = "getzIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub getz_index: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub height: Option<f64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub label: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub style: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub width: Option<f64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LabelEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<LabelDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dimensions: Option<DimensionsDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(rename = "getzIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub getz_index: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LineageRequestDto {
#[serde(rename = "clusterNodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_id: Option<String>,
#[serde(rename = "eventId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub event_id: Option<i64>,
#[serde(rename = "lineageRequestType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub lineage_request_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uuid: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LineageResultsDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub errors: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub links: Option<Vec<ProvenanceLinkDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub nodes: Option<Vec<ProvenanceNodeDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ListenPortDto {
#[serde(rename = "applicationProtocols")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub application_protocols: Option<Vec<String>>,
#[serde(rename = "componentClass")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_class: Option<String>,
#[serde(rename = "componentId")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(rename = "componentName")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_name: Option<String>,
#[serde(rename = "componentType")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "parentGroupName")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_name: Option<String>,
#[serde(rename = "portName")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_name: Option<String>,
#[serde(rename = "portNumber")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_number: Option<i32>,
#[serde(rename = "transportProtocol")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub transport_protocol: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LongParameter {
#[serde(skip_serializing_if = "Option::is_none")]
pub long: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct MultiProcessorUseCase {
#[serde(skip_serializing_if = "Option::is_none")]
pub configurations: Option<Vec<ProcessorConfiguration>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub keywords: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub notes: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NarCoordinateDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub artifact: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub group: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeConnectionStatisticsSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statisticsSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub statistics_snapshot: Option<ConnectionStatisticsSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeConnectionStatusSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshot: Option<ConnectionStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeCountersSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub snapshot: Option<CountersSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeEventDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub category: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub message: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodePortStatusSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshot: Option<PortStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeProcessGroupStatusSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshot: Option<ProcessGroupStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeProcessorStatusSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshot: Option<ProcessorStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeRemoteProcessGroupStatusSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshot: Option<RemoteProcessGroupStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeReplayLastEventSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub snapshot: Option<ReplayLastEventSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeSearchResultDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeStatusSnapshotsDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(rename = "statusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_snapshots: Option<Vec<StatusSnapshotDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct NodeSystemDiagnosticsSnapshotDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub address: Option<String>,
#[serde(rename = "apiPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub api_port: Option<i32>,
#[serde(rename = "nodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub snapshot: Option<SystemDiagnosticsSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextDto {
#[serde(rename = "boundProcessGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bound_process_groups: Option<Vec<ProcessGroupEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inheritedParameterContexts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub inherited_parameter_contexts: Option<Vec<ParameterContextReferenceEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parameterProviderConfiguration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_provider_configuration: Option<ParameterProviderConfigurationEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub parameters: Option<Vec<ParameterEntity>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextReferenceDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextReferenceEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ParameterContextReferenceDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextUpdateEntity {
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextDto>,
#[serde(rename = "parameterContextRevision")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context_revision: Option<RevisionDto>,
#[serde(rename = "referencingComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_components: Option<Vec<AffectedComponentEntity>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextUpdateRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextDto>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(rename = "referencingComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_components: Option<Vec<AffectedComponentEntity>>,
#[serde(rename = "requestId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub request_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "submissionTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub submission_time: Option<String>,
#[serde(rename = "updateSteps")]
#[serde(skip_serializing_if = "Option::is_none")]
pub update_steps: Option<Vec<ParameterContextUpdateStepDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextUpdateStepDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextValidationRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(rename = "componentValidationResults")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_validation_results: Option<ComponentValidationResultsEntity>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextDto>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(rename = "requestId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub request_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "submissionTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub submission_time: Option<String>,
#[serde(rename = "updateSteps")]
#[serde(skip_serializing_if = "Option::is_none")]
pub update_steps: Option<Vec<ParameterContextValidationStepDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterContextValidationStepDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub inherited: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextReferenceEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub provided: Option<bool>,
#[serde(rename = "referencedAssets")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referenced_assets: Option<Vec<AssetReferenceDto>>,
#[serde(rename = "referencingComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_components: Option<Vec<AffectedComponentEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
#[serde(rename = "valueRemoved")]
#[serde(skip_serializing_if = "Option::is_none")]
pub value_removed: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterEntity {
#[serde(rename = "canWrite")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_write: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter: Option<ParameterDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterGroupConfigurationEntity {
#[serde(rename = "groupName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_name: Option<String>,
#[serde(rename = "parameterContextName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context_name: Option<String>,
#[serde(rename = "parameterSensitivities")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_sensitivities: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub synchronized: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderApplyParametersUpdateStepDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderConfigurationDto {
#[serde(rename = "parameterGroupName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_group_name: Option<String>,
#[serde(rename = "parameterProviderId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_provider_id: Option<String>,
#[serde(rename = "parameterProviderName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_provider_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub synchronized: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderConfigurationEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ParameterProviderConfigurationDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderDto {
#[serde(rename = "affectedComponents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub affected_components: Option<Vec<AffectedComponentEntity>>,
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "customUiUrl")]
#[serde(skip_serializing_if = "Option::is_none")]
pub custom_ui_url: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parameterGroupConfigurations")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_group_configurations: Option<Vec<ParameterGroupConfigurationEntity>>,
#[serde(rename = "parameterStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_status: Option<Vec<ParameterStatusDto>>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "persistsState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub persists_state: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "referencingParameterContexts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referencing_parameter_contexts: Option<Vec<ParameterProviderReferencingComponentEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ParameterProviderDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderReference {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<Bundle>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderReferencingComponentDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterProviderReferencingComponentEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ParameterProviderReferencingComponentDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ParameterStatusDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter: Option<ParameterEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PeerDto {
#[serde(rename = "flowFileCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub hostname: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub port: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub secure: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PermissionsDto {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(rename = "canWrite")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_write: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortDto {
#[serde(rename = "allowRemoteAccess")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allow_remote_access: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "portFunction")]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_function: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortEntity {
#[serde(rename = "allowRemoteAccess")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allow_remote_access: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<PortDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(rename = "portType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<PortStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortRunStatusEntity {
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortStatusDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<PortStatusSnapshotDto>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodePortStatusSnapshotDto>>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortStatusSnapshotDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "bytesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_in: Option<i64>,
#[serde(rename = "bytesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_out: Option<i64>,
#[serde(rename = "flowFilesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_in: Option<i32>,
#[serde(rename = "flowFilesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_out: Option<i32>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub input: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub output: Option<String>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PortStatusSnapshotEntity {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "portStatusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_status_snapshot: Option<PortStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Position {
#[serde(skip_serializing_if = "Option::is_none")]
pub x: Option<f64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub y: Option<f64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PositionDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub x: Option<f64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub y: Option<f64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PreviousValueDto {
#[serde(rename = "previousValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub previous_value: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
#[serde(rename = "userIdentity")]
#[serde(skip_serializing_if = "Option::is_none")]
pub user_identity: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupDto {
#[serde(rename = "activeRemotePortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_remote_port_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub contents: Option<FlowSnippetDto>,
#[serde(rename = "defaultBackPressureDataSizeThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_back_pressure_data_size_threshold: Option<String>,
#[serde(rename = "defaultBackPressureObjectThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_back_pressure_object_threshold: Option<i64>,
#[serde(rename = "defaultFlowFileExpiration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_flow_file_expiration: Option<String>,
#[serde(rename = "disabledCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disabled_count: Option<i32>,
#[serde(rename = "executionEngine")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_engine: Option<String>,
#[serde(rename = "flowfileConcurrency")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flowfile_concurrency: Option<String>,
#[serde(rename = "flowfileOutboundPolicy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flowfile_outbound_policy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inactiveRemotePortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub inactive_remote_port_count: Option<i32>,
#[serde(rename = "inputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_port_count: Option<i32>,
#[serde(rename = "invalidCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub invalid_count: Option<i32>,
#[serde(rename = "localInputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub local_input_port_count: Option<i32>,
#[serde(rename = "localOutputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub local_output_port_count: Option<i32>,
#[serde(rename = "locallyModifiedAndStaleCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub locally_modified_and_stale_count: Option<i32>,
#[serde(rename = "locallyModifiedCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub locally_modified_count: Option<i32>,
#[serde(rename = "logFileSuffix")]
#[serde(skip_serializing_if = "Option::is_none")]
pub log_file_suffix: Option<String>,
#[serde(rename = "maxConcurrentTasks")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_concurrent_tasks: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "outputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_port_count: Option<i32>,
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextReferenceEntity>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "publicInputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub public_input_port_count: Option<i32>,
#[serde(rename = "publicOutputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub public_output_port_count: Option<i32>,
#[serde(rename = "runningCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub running_count: Option<i32>,
#[serde(rename = "staleCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stale_count: Option<i32>,
#[serde(rename = "statelessFlowTimeout")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stateless_flow_timeout: Option<String>,
#[serde(rename = "statelessGroupScheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stateless_group_scheduled_state: Option<String>,
#[serde(rename = "stoppedCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stopped_count: Option<i32>,
#[serde(rename = "syncFailureCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sync_failure_count: Option<i32>,
#[serde(rename = "upToDateCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub up_to_date_count: Option<i32>,
#[serde(rename = "versionControlInformation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_control_information: Option<VersionControlInformationDto>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupFlowDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub breadcrumb: Option<FlowBreadcrumbEntity>,
#[serde(skip_serializing_if = "Option::is_none")]
pub flow: Option<FlowDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "lastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_refreshed: Option<String>,
#[serde(rename = "parameterContext")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context: Option<ParameterContextReferenceEntity>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupNameDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupReplaceRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(rename = "processGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_id: Option<String>,
#[serde(rename = "requestId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub request_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupStatusDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<ProcessGroupStatusSnapshotDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeProcessGroupStatusSnapshotDto>>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupStatusSnapshotDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "bytesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_in: Option<i64>,
#[serde(rename = "bytesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_out: Option<i64>,
#[serde(rename = "bytesQueued")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_queued: Option<i64>,
#[serde(rename = "bytesRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_read: Option<i64>,
#[serde(rename = "bytesReceived")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_received: Option<i64>,
#[serde(rename = "bytesSent")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_sent: Option<i64>,
#[serde(rename = "bytesTransferred")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_transferred: Option<i64>,
#[serde(rename = "bytesWritten")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_written: Option<i64>,
#[serde(rename = "connectionStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub connection_status_snapshots: Option<Vec<ConnectionStatusSnapshotEntity>>,
#[serde(rename = "flowFilesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_in: Option<i32>,
#[serde(rename = "flowFilesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_out: Option<i32>,
#[serde(rename = "flowFilesQueued")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_queued: Option<i32>,
#[serde(rename = "flowFilesReceived")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_received: Option<i32>,
#[serde(rename = "flowFilesSent")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_sent: Option<i32>,
#[serde(rename = "flowFilesTransferred")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_transferred: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub input: Option<String>,
#[serde(rename = "inputPortStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_port_status_snapshots: Option<Vec<PortStatusSnapshotEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub output: Option<String>,
#[serde(rename = "outputPortStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_port_status_snapshots: Option<Vec<PortStatusSnapshotEntity>>,
#[serde(rename = "processGroupStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_status_snapshots: Option<Vec<ProcessGroupStatusSnapshotEntity>>,
#[serde(rename = "processingNanos")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processing_nanos: Option<i64>,
#[serde(rename = "processingPerformanceStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processing_performance_status: Option<ProcessingPerformanceStatusDto>,
#[serde(rename = "processorStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processor_status_snapshots: Option<Vec<ProcessorStatusSnapshotEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub queued: Option<String>,
#[serde(rename = "queuedCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub queued_count: Option<String>,
#[serde(rename = "queuedSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub queued_size: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub read: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub received: Option<String>,
#[serde(rename = "remoteProcessGroupStatusSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_process_group_status_snapshots: Option<Vec<RemoteProcessGroupStatusSnapshotEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sent: Option<String>,
#[serde(rename = "statelessActiveThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stateless_active_thread_count: Option<i32>,
#[serde(rename = "terminatedThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub terminated_thread_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transferred: Option<String>,
#[serde(rename = "versionedFlowState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_flow_state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub written: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessGroupStatusSnapshotEntity {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "processGroupStatusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_status_snapshot: Option<ProcessGroupStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessingPerformanceStatusDto {
#[serde(rename = "contentReadDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub content_read_duration: Option<i64>,
#[serde(rename = "contentWriteDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub content_write_duration: Option<i64>,
#[serde(rename = "cpuDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cpu_duration: Option<i64>,
#[serde(rename = "garbageCollectionDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub garbage_collection_duration: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "sessionCommitDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub session_commit_duration: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorConfigDto {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(rename = "autoTerminatedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub auto_terminated_relationships: Option<Vec<String>>,
#[serde(rename = "backoffMechanism")]
#[serde(skip_serializing_if = "Option::is_none")]
pub backoff_mechanism: Option<String>,
#[serde(rename = "bulletinLevel")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletin_level: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(rename = "customUiUrl")]
#[serde(skip_serializing_if = "Option::is_none")]
pub custom_ui_url: Option<String>,
#[serde(rename = "defaultConcurrentTasks")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_concurrent_tasks: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "defaultSchedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_scheduling_period: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "executionNode")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_node: Option<String>,
#[serde(rename = "lossTolerant")]
#[serde(skip_serializing_if = "Option::is_none")]
pub loss_tolerant: Option<bool>,
#[serde(rename = "maxBackoffPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_backoff_period: Option<String>,
#[serde(rename = "penaltyDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub penalty_duration: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "retriedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub retried_relationships: Option<Vec<String>>,
#[serde(rename = "retryCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub retry_count: Option<i32>,
#[serde(rename = "runDurationMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_duration_millis: Option<i64>,
#[serde(rename = "schedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_period: Option<String>,
#[serde(rename = "schedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_strategy: Option<String>,
#[serde(rename = "sensitiveDynamicPropertyNames")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive_dynamic_property_names: Option<Vec<String>>,
#[serde(rename = "yieldDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub yield_duration: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorConfiguration {
#[serde(skip_serializing_if = "Option::is_none")]
pub configuration: Option<String>,
#[serde(rename = "processorClassName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processor_class_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub config: Option<ProcessorConfigDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "executionNodeRestricted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_node_restricted: Option<bool>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inputRequirement")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_requirement: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "persistsState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub persists_state: Option<bool>,
#[serde(rename = "physicalState")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub physical_state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub relationships: Option<Vec<RelationshipDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub style: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "supportsBatching")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_batching: Option<bool>,
#[serde(rename = "supportsParallelProcessing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_parallel_processing: Option<bool>,
#[serde(rename = "supportsSensitiveDynamicProperties")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_sensitive_dynamic_properties: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ProcessorDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inputRequirement")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_requirement: Option<String>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(rename = "physicalState")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub physical_state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<ProcessorStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorRunStatusDetailsDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorRunStatusDetailsEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(rename = "runStatusDetails")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status_details: Option<ProcessorRunStatusDetailsDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorStatusDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<ProcessorStatusSnapshotDto>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeProcessorStatusSnapshotDto>>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorStatusSnapshotDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "bytesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_in: Option<i64>,
#[serde(rename = "bytesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_out: Option<i64>,
#[serde(rename = "bytesRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_read: Option<i64>,
#[serde(rename = "bytesWritten")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_written: Option<i64>,
#[serde(rename = "executionNode")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_node: Option<String>,
#[serde(rename = "flowFilesIn")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_in: Option<i32>,
#[serde(rename = "flowFilesOut")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_out: Option<i32>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub input: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub output: Option<String>,
#[serde(rename = "processingPerformanceStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processing_performance_status: Option<ProcessingPerformanceStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub read: Option<String>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "taskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub task_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub tasks: Option<String>,
#[serde(rename = "tasksDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub tasks_duration: Option<String>,
#[serde(rename = "tasksDurationNanos")]
#[serde(skip_serializing_if = "Option::is_none")]
pub tasks_duration_nanos: Option<i64>,
#[serde(rename = "terminatedThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub terminated_thread_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub written: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProcessorStatusSnapshotEntity {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "processorStatusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processor_status_snapshot: Option<ProcessorStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyAllowableValue {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyDependency {
#[serde(rename = "dependentValues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub dependent_values: Option<Vec<String>>,
#[serde(rename = "propertyDisplayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_display_name: Option<String>,
#[serde(rename = "propertyName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyDependencyDto {
#[serde(rename = "dependentValues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub dependent_values: Option<Vec<String>>,
#[serde(rename = "propertyName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyDescriptor {
#[serde(rename = "allowableValues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allowable_values: Option<Vec<PropertyAllowableValue>>,
#[serde(rename = "defaultValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_value: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dependencies: Option<Vec<PropertyDependency>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dynamic: Option<bool>,
#[serde(rename = "expressionLanguageScope")]
#[serde(skip_serializing_if = "Option::is_none")]
pub expression_language_scope: Option<String>,
#[serde(rename = "expressionLanguageScopeDescription")]
#[serde(skip_serializing_if = "Option::is_none")]
pub expression_language_scope_description: Option<String>,
#[serde(rename = "listenPortDefinition")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub listen_port_definition: Option<PropertyListenPortDefinition>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub required: Option<bool>,
#[serde(rename = "resourceDefinition")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resource_definition: Option<PropertyResourceDefinition>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive: Option<bool>,
#[serde(rename = "typeProvidedByValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub type_provided_by_value: Option<DefinedType>,
#[serde(rename = "validRegex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub valid_regex: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub validator: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyDescriptorDto {
#[serde(rename = "allowableValues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allowable_values: Option<Vec<AllowableValueEntity>>,
#[serde(rename = "defaultValue")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_value: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dependencies: Option<Vec<PropertyDependencyDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dynamic: Option<bool>,
#[serde(rename = "expressionLanguageScope")]
#[serde(skip_serializing_if = "Option::is_none")]
pub expression_language_scope: Option<String>,
#[serde(rename = "identifiesControllerService")]
#[serde(skip_serializing_if = "Option::is_none")]
pub identifies_controller_service: Option<String>,
#[serde(rename = "identifiesControllerServiceBundle")]
#[serde(skip_serializing_if = "Option::is_none")]
pub identifies_controller_service_bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub required: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive: Option<bool>,
#[serde(rename = "supportsEl")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_el: Option<bool>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyDescriptorEntity {
pub property_descriptor: Option<PropertyDescriptorDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyHistoryDto {
#[serde(rename = "previousValues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub previous_values: Option<Vec<PreviousValueDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyListenPortDefinition {
#[serde(rename = "applicationProtocols")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub application_protocols: Option<Vec<String>>,
#[serde(rename = "transportProtocol")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub transport_protocol: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct PropertyResourceDefinition {
#[serde(skip_serializing_if = "Option::is_none")]
pub cardinality: Option<String>,
#[serde(rename = "resourceTypes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resource_types: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceLinkDto {
#[serde(rename = "flowFileUuid")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_uuid: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub millis: Option<i64>,
#[serde(rename = "sourceId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub source_id: Option<String>,
#[serde(rename = "targetId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceNodeDto {
#[serde(rename = "childUuids")]
#[serde(skip_serializing_if = "Option::is_none")]
pub child_uuids: Option<Vec<String>>,
#[serde(rename = "clusterNodeIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_identifier: Option<String>,
#[serde(rename = "componentType")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "eventType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub event_type: Option<String>,
#[serde(rename = "flowFileUuid")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_uuid: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub millis: Option<i64>,
#[serde(rename = "parentUuids")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_uuids: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceRequestDto {
#[serde(rename = "clusterNodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_id: Option<String>,
#[serde(rename = "endDate")]
#[serde(skip_serializing_if = "Option::is_none")]
pub end_date: Option<String>,
#[serde(rename = "incrementalResults")]
#[serde(skip_serializing_if = "Option::is_none")]
pub incremental_results: Option<bool>,
#[serde(rename = "maxResults")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_results: Option<i32>,
#[serde(rename = "maximumFileSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub maximum_file_size: Option<String>,
#[serde(rename = "minimumFileSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub minimum_file_size: Option<String>,
#[serde(rename = "searchTerms")]
#[serde(skip_serializing_if = "Option::is_none")]
pub search_terms: Option<std::collections::HashMap<String, Option<ProvenanceSearchValueDto>>>,
#[serde(rename = "startDate")]
#[serde(skip_serializing_if = "Option::is_none")]
pub start_date: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub summarize: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceResultsDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub errors: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub generated: Option<String>,
#[serde(rename = "oldestEvent")]
#[serde(skip_serializing_if = "Option::is_none")]
pub oldest_event: Option<String>,
#[serde(rename = "provenanceEvents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub provenance_events: Option<Vec<ProvenanceEventDto>>,
#[serde(rename = "timeOffset")]
#[serde(skip_serializing_if = "Option::is_none")]
pub time_offset: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub total: Option<String>,
#[serde(rename = "totalCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_count: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceSearchValueDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub inverse: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceSearchableFieldDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub field: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub label: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct QueueSizeDto {
#[serde(rename = "byteCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub byte_count: Option<i64>,
#[serde(rename = "objectCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub object_count: Option<i32>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RegisteredFlow {
#[serde(skip_serializing_if = "Option::is_none")]
pub branch: Option<String>,
#[serde(rename = "bucketIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_identifier: Option<String>,
#[serde(rename = "bucketName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_name: Option<String>,
#[serde(rename = "createdTimestamp")]
#[serde(skip_serializing_if = "Option::is_none")]
pub created_timestamp: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "lastModifiedTimestamp")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_modified_timestamp: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<FlowRegistryPermissions>,
#[serde(rename = "versionCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_count: Option<i64>,
#[serde(rename = "versionInfo")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_info: Option<RegisteredFlowVersionInfo>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RegisteredFlowSnapshot {
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket: Option<FlowRegistryBucket>,
#[serde(rename = "externalControllerServices")]
#[serde(skip_serializing_if = "Option::is_none")]
pub external_controller_services:
Option<std::collections::HashMap<String, Option<ExternalControllerServiceReference>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub flow: Option<RegisteredFlow>,
#[serde(rename = "flowContents")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_contents: Option<VersionedProcessGroup>,
#[serde(rename = "flowEncodingVersion")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_encoding_version: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub latest: Option<bool>,
#[serde(rename = "parameterContexts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_contexts:
Option<std::collections::HashMap<String, Option<VersionedParameterContext>>>,
#[serde(rename = "parameterProviders")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_providers:
Option<std::collections::HashMap<String, Option<ParameterProviderReference>>>,
#[serde(rename = "snapshotMetadata")]
#[serde(skip_serializing_if = "Option::is_none")]
pub snapshot_metadata: Option<RegisteredFlowSnapshotMetadata>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RegisteredFlowSnapshotMetadata {
#[serde(skip_serializing_if = "Option::is_none")]
pub author: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub branch: Option<String>,
#[serde(rename = "bucketIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "flowIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_identifier: Option<String>,
#[serde(rename = "flowName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_name: Option<String>,
#[serde(rename = "registryIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_identifier: Option<String>,
#[serde(rename = "registryName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RegisteredFlowVersionInfo {
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Relationship {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RelationshipDto {
#[serde(rename = "autoTerminate")]
#[serde(skip_serializing_if = "Option::is_none")]
pub auto_terminate: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub retry: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupContentsDto {
#[serde(rename = "inputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_ports: Option<Vec<RemoteProcessGroupPortDto>>,
#[serde(rename = "outputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_ports: Option<Vec<RemoteProcessGroupPortDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupDto {
#[serde(rename = "activeRemoteInputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_remote_input_port_count: Option<i32>,
#[serde(rename = "activeRemoteOutputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_remote_output_port_count: Option<i32>,
#[serde(rename = "authorizationIssues")]
#[serde(skip_serializing_if = "Option::is_none")]
pub authorization_issues: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "communicationsTimeout")]
#[serde(skip_serializing_if = "Option::is_none")]
pub communications_timeout: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub contents: Option<RemoteProcessGroupContentsDto>,
#[serde(rename = "flowRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_refreshed: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inactiveRemoteInputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub inactive_remote_input_port_count: Option<i32>,
#[serde(rename = "inactiveRemoteOutputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub inactive_remote_output_port_count: Option<i32>,
#[serde(rename = "inputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_port_count: Option<i32>,
#[serde(rename = "localNetworkInterface")]
#[serde(skip_serializing_if = "Option::is_none")]
pub local_network_interface: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "outputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_port_count: Option<i32>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "proxyHost")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_host: Option<String>,
#[serde(rename = "proxyPassword")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_password: Option<String>,
#[serde(rename = "proxyPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_port: Option<i32>,
#[serde(rename = "proxyUser")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_user: Option<String>,
#[serde(rename = "targetSecure")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_secure: Option<bool>,
#[serde(rename = "targetUri")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_uri: Option<String>,
#[serde(rename = "targetUris")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_uris: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
#[serde(rename = "transportProtocol")]
#[serde(skip_serializing_if = "Option::is_none")]
pub transport_protocol: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
#[serde(rename = "yieldDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub yield_duration: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<RemoteProcessGroupDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_port_count: Option<i32>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(rename = "outputPortCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_port_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<RemoteProcessGroupStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupPortDto {
#[serde(rename = "batchSettings")]
#[serde(skip_serializing_if = "Option::is_none")]
pub batch_settings: Option<BatchSettingsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub connected: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub exists: Option<bool>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "targetId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_id: Option<String>,
#[serde(rename = "targetRunning")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_running: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub transmitting: Option<bool>,
#[serde(rename = "useCompression")]
#[serde(skip_serializing_if = "Option::is_none")]
pub use_compression: Option<bool>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupStatusDto {
#[serde(rename = "aggregateSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshot: Option<RemoteProcessGroupStatusSnapshotDto>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeRemoteProcessGroupStatusSnapshotDto>>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
#[serde(rename = "targetUri")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_uri: Option<String>,
#[serde(rename = "transmissionStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub transmission_status: Option<String>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupStatusSnapshotDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "bytesReceived")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_received: Option<i64>,
#[serde(rename = "bytesSent")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bytes_sent: Option<i64>,
#[serde(rename = "flowFilesReceived")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_received: Option<i32>,
#[serde(rename = "flowFilesSent")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_files_sent: Option<i32>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub received: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sent: Option<String>,
#[serde(rename = "targetUri")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_uri: Option<String>,
#[serde(rename = "transmissionStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub transmission_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RemoteProcessGroupStatusSnapshotEntity {
#[serde(rename = "canRead")]
#[serde(skip_serializing_if = "Option::is_none")]
pub can_read: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "remoteProcessGroupStatusSnapshot")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_process_group_status_snapshot: Option<RemoteProcessGroupStatusSnapshotDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReplayLastEventSnapshotDto {
#[serde(rename = "eventAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub event_available: Option<bool>,
#[serde(rename = "eventsReplayed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub events_replayed: Option<Vec<i64>>,
#[serde(rename = "failureExplanation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_explanation: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReportingTaskDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<BundleDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "customUiUrl")]
#[serde(skip_serializing_if = "Option::is_none")]
pub custom_ui_url: Option<String>,
#[serde(rename = "defaultSchedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_scheduling_period: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub deprecated: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub descriptors: Option<std::collections::HashMap<String, Option<PropertyDescriptorDto>>>,
#[serde(rename = "extensionMissing")]
#[serde(skip_serializing_if = "Option::is_none")]
pub extension_missing: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "multipleVersionsAvailable")]
#[serde(skip_serializing_if = "Option::is_none")]
pub multiple_versions_available: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "persistsState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub persists_state: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub restricted: Option<bool>,
#[serde(rename = "schedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_period: Option<String>,
#[serde(rename = "schedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_strategy: Option<String>,
#[serde(rename = "sensitiveDynamicPropertyNames")]
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive_dynamic_property_names: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "supportsSensitiveDynamicProperties")]
#[serde(skip_serializing_if = "Option::is_none")]
pub supports_sensitive_dynamic_properties: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "validationErrors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_errors: Option<Vec<String>>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReportingTaskEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<ReportingTaskDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "operatePermissions")]
#[serde(skip_serializing_if = "Option::is_none")]
pub operate_permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub status: Option<ReportingTaskStatusDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReportingTaskStatusDto {
#[serde(rename = "activeThreadCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub active_thread_count: Option<i32>,
#[serde(rename = "runStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_status: Option<String>,
#[serde(rename = "validationStatus")]
#[serde(skip_serializing_if = "Option::is_none")]
pub validation_status: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RequiredPermissionDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub label: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ResourceClaimDetailsDto {
#[serde(rename = "awaitingDestruction")]
#[serde(skip_serializing_if = "Option::is_none")]
pub awaiting_destruction: Option<bool>,
#[serde(rename = "claimantCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub claimant_count: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub container: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "inUse")]
#[serde(skip_serializing_if = "Option::is_none")]
pub in_use: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub section: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub writable: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ResourceDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Restriction {
#[serde(skip_serializing_if = "Option::is_none")]
pub explanation: Option<String>,
#[serde(rename = "requiredPermission")]
#[serde(skip_serializing_if = "Option::is_none")]
pub required_permission: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct RevisionDto {
#[serde(rename = "clientId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub client_id: Option<String>,
#[serde(rename = "lastModifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_modifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SchedulingDefaults {
#[serde(rename = "defaultConcurrentTasksBySchedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_concurrent_tasks_by_scheduling_strategy:
Option<std::collections::HashMap<String, Option<i32>>>,
#[serde(rename = "defaultMaxConcurrentTasks")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_max_concurrent_tasks: Option<String>,
#[serde(rename = "defaultRunDurationNanos")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_run_duration_nanos: Option<i64>,
#[serde(rename = "defaultSchedulingPeriodMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_scheduling_period_millis: Option<i64>,
#[serde(rename = "defaultSchedulingPeriodsBySchedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_scheduling_periods_by_scheduling_strategy:
Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "defaultSchedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_scheduling_strategy: Option<String>,
#[serde(rename = "penalizationPeriodMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub penalization_period_millis: Option<i64>,
#[serde(rename = "yieldDurationMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub yield_duration_millis: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SearchResultGroupDto {
pub id: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SnippetDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub connections: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub funnels: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(rename = "inputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_ports: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub labels: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(rename = "outputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_ports: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(rename = "processGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_groups: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub processors: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(rename = "remoteProcessGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_process_groups: Option<std::collections::HashMap<String, Option<RevisionDto>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StateEntryDto {
#[serde(rename = "clusterNodeAddress")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_address: Option<String>,
#[serde(rename = "clusterNodeId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub cluster_node_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub key: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StateMapDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub scope: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<Vec<StateEntryDto>>,
#[serde(rename = "totalEntryCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_entry_count: Option<i32>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct Stateful {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub scopes: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StatusDescriptorDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub field: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub formatter: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub label: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StatusHistoryDto {
#[serde(rename = "aggregateSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub aggregate_snapshots: Option<Vec<StatusSnapshotDto>>,
#[serde(rename = "componentDetails")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_details: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "fieldDescriptors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub field_descriptors: Option<Vec<StatusDescriptorDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub generated: Option<String>,
#[serde(rename = "nodeSnapshots")]
#[serde(skip_serializing_if = "Option::is_none")]
pub node_snapshots: Option<Vec<NodeStatusSnapshotsDto>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StatusSnapshotDto {
#[serde(rename = "statusMetrics")]
#[serde(skip_serializing_if = "Option::is_none")]
pub status_metrics: Option<std::collections::HashMap<String, Option<i64>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub timestamp: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StorageUsageDto {
#[serde(rename = "freeSpace")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_space: Option<String>,
#[serde(rename = "freeSpaceBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_space_bytes: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "totalSpace")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_space: Option<String>,
#[serde(rename = "totalSpaceBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_space_bytes: Option<i64>,
#[serde(rename = "usedSpace")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_space: Option<String>,
#[serde(rename = "usedSpaceBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_space_bytes: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub utilization: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StreamingOutput {}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SupportedMimeTypesDto {
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(rename = "mimeTypes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub mime_types: Option<Vec<String>>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SystemDiagnosticsSnapshotDto {
#[serde(rename = "availableProcessors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub available_processors: Option<i32>,
#[serde(rename = "contentRepositoryStorageUsage")]
#[serde(skip_serializing_if = "Option::is_none")]
pub content_repository_storage_usage: Option<Vec<StorageUsageDto>>,
#[serde(rename = "daemonThreads")]
#[serde(skip_serializing_if = "Option::is_none")]
pub daemon_threads: Option<i32>,
#[serde(rename = "flowFileRepositoryStorageUsage")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_repository_storage_usage: Option<StorageUsageDto>,
#[serde(rename = "freeHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_heap: Option<String>,
#[serde(rename = "freeHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_heap_bytes: Option<i64>,
#[serde(rename = "freeNonHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_non_heap: Option<String>,
#[serde(rename = "freeNonHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub free_non_heap_bytes: Option<i64>,
#[serde(rename = "garbageCollection")]
#[serde(skip_serializing_if = "Option::is_none")]
pub garbage_collection: Option<Vec<GarbageCollectionDto>>,
#[serde(rename = "heapUtilization")]
#[serde(skip_serializing_if = "Option::is_none")]
pub heap_utilization: Option<String>,
#[serde(rename = "maxHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_heap: Option<String>,
#[serde(rename = "maxHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_heap_bytes: Option<i64>,
#[serde(rename = "maxNonHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_non_heap: Option<String>,
#[serde(rename = "maxNonHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_non_heap_bytes: Option<i64>,
#[serde(rename = "nonHeapUtilization")]
#[serde(skip_serializing_if = "Option::is_none")]
pub non_heap_utilization: Option<String>,
#[serde(rename = "processorLoadAverage")]
#[serde(skip_serializing_if = "Option::is_none")]
pub processor_load_average: Option<f64>,
#[serde(rename = "provenanceRepositoryStorageUsage")]
#[serde(skip_serializing_if = "Option::is_none")]
pub provenance_repository_storage_usage: Option<Vec<StorageUsageDto>>,
#[serde(rename = "resourceClaimDetails")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resource_claim_details: Option<Vec<ResourceClaimDetailsDto>>,
#[serde(rename = "statsLastRefreshed")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stats_last_refreshed: Option<String>,
#[serde(rename = "totalHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_heap: Option<String>,
#[serde(rename = "totalHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_heap_bytes: Option<i64>,
#[serde(rename = "totalNonHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_non_heap: Option<String>,
#[serde(rename = "totalNonHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_non_heap_bytes: Option<i64>,
#[serde(rename = "totalThreads")]
#[serde(skip_serializing_if = "Option::is_none")]
pub total_threads: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uptime: Option<String>,
#[serde(rename = "usedHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_heap: Option<String>,
#[serde(rename = "usedHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_heap_bytes: Option<i64>,
#[serde(rename = "usedNonHeap")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_non_heap: Option<String>,
#[serde(rename = "usedNonHeapBytes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub used_non_heap_bytes: Option<i64>,
#[serde(rename = "versionInfo")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_info: Option<VersionInfoDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SystemResourceConsideration {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub resource: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct TenantDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub configurable: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identity: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct TenantEntity {
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletins: Option<Vec<BulletinEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub component: Option<TenantDto>,
#[serde(rename = "disconnectedNodeAcknowledged")]
#[serde(skip_serializing_if = "Option::is_none")]
pub disconnected_node_acknowledged: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub permissions: Option<PermissionsDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub revision: Option<RevisionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct UseCase {
#[serde(skip_serializing_if = "Option::is_none")]
pub configuration: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "inputRequirement")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_requirement: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub keywords: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub notes: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct UserDto {
#[serde(rename = "accessPolicies")]
#[serde(skip_serializing_if = "Option::is_none")]
pub access_policies: Option<Vec<AccessPolicySummaryEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub configurable: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identity: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(rename = "userGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub user_groups: Option<Vec<TenantEntity>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct UserGroupDto {
#[serde(rename = "accessPolicies")]
#[serde(skip_serializing_if = "Option::is_none")]
pub access_policies: Option<Vec<AccessPolicyEntity>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub configurable: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identity: Option<String>,
#[serde(rename = "parentGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parent_group_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<PositionDto>,
#[serde(skip_serializing_if = "Option::is_none")]
pub users: Option<Vec<TenantEntity>>,
#[serde(rename = "versionedComponentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_component_id: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VerifyConfigRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub attributes: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(rename = "componentId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_id: Option<String>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "requestId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub request_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub results: Option<Vec<ConfigVerificationResultDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "submissionTime")]
#[serde(skip_serializing_if = "Option::is_none")]
pub submission_time: Option<String>,
#[serde(rename = "updateSteps")]
#[serde(skip_serializing_if = "Option::is_none")]
pub update_steps: Option<Vec<VerifyConfigUpdateStepDto>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VerifyConfigRequestEntity {
pub request: Option<VerifyConfigRequestDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VerifyConfigUpdateStepDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionControlInformationDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub branch: Option<String>,
#[serde(rename = "bucketId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_id: Option<String>,
#[serde(rename = "bucketName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_name: Option<String>,
#[serde(rename = "flowDescription")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_description: Option<String>,
#[serde(rename = "flowId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_id: Option<String>,
#[serde(rename = "flowName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_name: Option<String>,
#[serde(rename = "groupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_id: Option<String>,
#[serde(rename = "registryId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_id: Option<String>,
#[serde(rename = "registryName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(rename = "stateExplanation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub state_explanation: Option<String>,
#[serde(rename = "storageLocation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub storage_location: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionInfoDto {
#[serde(rename = "buildBranch")]
#[serde(skip_serializing_if = "Option::is_none")]
pub build_branch: Option<String>,
#[serde(rename = "buildRevision")]
#[serde(skip_serializing_if = "Option::is_none")]
pub build_revision: Option<String>,
#[serde(rename = "buildTag")]
#[serde(skip_serializing_if = "Option::is_none")]
pub build_tag: Option<String>,
#[serde(rename = "buildTimestamp")]
#[serde(skip_serializing_if = "Option::is_none")]
pub build_timestamp: Option<String>,
#[serde(rename = "javaVendor")]
#[serde(skip_serializing_if = "Option::is_none")]
pub java_vendor: Option<String>,
#[serde(rename = "javaVersion")]
#[serde(skip_serializing_if = "Option::is_none")]
pub java_version: Option<String>,
#[serde(rename = "niFiVersion")]
#[serde(skip_serializing_if = "Option::is_none")]
pub ni_fi_version: Option<String>,
#[serde(rename = "osArchitecture")]
#[serde(skip_serializing_if = "Option::is_none")]
pub os_architecture: Option<String>,
#[serde(rename = "osName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub os_name: Option<String>,
#[serde(rename = "osVersion")]
#[serde(skip_serializing_if = "Option::is_none")]
pub os_version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedAsset {
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedConnection {
#[serde(rename = "backPressureDataSizeThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub back_pressure_data_size_threshold: Option<String>,
#[serde(rename = "backPressureObjectThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub back_pressure_object_threshold: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bends: Option<Vec<Position>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub destination: Option<ConnectableComponent>,
#[serde(rename = "flowFileExpiration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_expiration: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(rename = "labelIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub label_index: Option<i32>,
#[serde(rename = "loadBalanceCompression")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_compression: Option<String>,
#[serde(rename = "loadBalanceStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub load_balance_strategy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "partitioningAttribute")]
#[serde(skip_serializing_if = "Option::is_none")]
pub partitioning_attribute: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub prioritizers: Option<Vec<String>>,
#[serde(rename = "selectedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub selected_relationships: Option<Vec<String>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub source: Option<ConnectableComponent>,
#[serde(rename = "zIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub z_index: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedControllerService {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(rename = "bulletinLevel")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletin_level: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<Bundle>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "controllerServiceApis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_service_apis: Option<Vec<ControllerServiceAPI>>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "propertyDescriptors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_descriptors:
Option<std::collections::HashMap<String, Option<VersionedPropertyDescriptor>>>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedFlowCoordinates {
#[serde(skip_serializing_if = "Option::is_none")]
pub branch: Option<String>,
#[serde(rename = "bucketId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bucket_id: Option<String>,
#[serde(rename = "flowId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub latest: Option<bool>,
#[serde(rename = "registryId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_id: Option<String>,
#[serde(rename = "storageLocation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub storage_location: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub version: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedFlowSnapshotMetadataEntity {
#[serde(rename = "registryId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub registry_id: Option<String>,
#[serde(rename = "versionedFlowSnapshotMetadata")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_flow_snapshot_metadata: Option<RegisteredFlowSnapshotMetadata>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedFlowUpdateRequestDto {
#[serde(skip_serializing_if = "Option::is_none")]
pub complete: Option<bool>,
#[serde(rename = "failureReason")]
#[serde(skip_serializing_if = "Option::is_none")]
pub failure_reason: Option<String>,
#[serde(rename = "lastUpdated")]
#[serde(skip_serializing_if = "Option::is_none")]
pub last_updated: Option<String>,
#[serde(rename = "percentCompleted")]
#[serde(skip_serializing_if = "Option::is_none")]
pub percent_completed: Option<i32>,
#[serde(rename = "processGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_group_id: Option<String>,
#[serde(rename = "requestId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub request_id: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub uri: Option<String>,
#[serde(rename = "versionControlInformation")]
#[serde(skip_serializing_if = "Option::is_none")]
pub version_control_information: Option<VersionControlInformationDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedFunnel {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedLabel {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub height: Option<f64>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub label: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub style: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub width: Option<f64>,
#[serde(rename = "zIndex")]
#[serde(skip_serializing_if = "Option::is_none")]
pub z_index: Option<i64>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedListenPortDefinition {
#[serde(rename = "applicationProtocols")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub application_protocols: Option<Vec<String>>,
#[serde(rename = "transportProtocol")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub transport_protocol: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedParameter {
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub provided: Option<bool>,
#[serde(rename = "referencedAssets")]
#[serde(skip_serializing_if = "Option::is_none")]
pub referenced_assets: Option<Vec<VersionedAsset>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub value: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedParameterContext {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "inheritedParameterContexts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub inherited_parameter_contexts: Option<Vec<String>>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "parameterGroupName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_group_name: Option<String>,
#[serde(rename = "parameterProvider")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_provider: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub parameters: Option<Vec<VersionedParameter>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub synchronized: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedPort {
#[serde(rename = "allowRemoteAccess")]
#[serde(skip_serializing_if = "Option::is_none")]
pub allow_remote_access: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "portFunction")]
#[serde(skip_serializing_if = "Option::is_none")]
pub port_function: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedProcessGroup {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub connections: Option<Vec<VersionedConnection>>,
#[serde(rename = "controllerServices")]
#[serde(skip_serializing_if = "Option::is_none")]
pub controller_services: Option<Vec<VersionedControllerService>>,
#[serde(rename = "defaultBackPressureDataSizeThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_back_pressure_data_size_threshold: Option<String>,
#[serde(rename = "defaultBackPressureObjectThreshold")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_back_pressure_object_threshold: Option<i64>,
#[serde(rename = "defaultFlowFileExpiration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub default_flow_file_expiration: Option<String>,
#[serde(rename = "executionEngine")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_engine: Option<String>,
#[serde(rename = "flowFileConcurrency")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_concurrency: Option<String>,
#[serde(rename = "flowFileOutboundPolicy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub flow_file_outbound_policy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub funnels: Option<Vec<VersionedFunnel>>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "inputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_ports: Option<Vec<VersionedPort>>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub labels: Option<Vec<VersionedLabel>>,
#[serde(rename = "logFileSuffix")]
#[serde(skip_serializing_if = "Option::is_none")]
pub log_file_suffix: Option<String>,
#[serde(rename = "maxConcurrentTasks")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_concurrent_tasks: Option<i32>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "outputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_ports: Option<Vec<VersionedPort>>,
#[serde(rename = "parameterContextName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub parameter_context_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(rename = "processGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub process_groups: Option<Vec<Box<VersionedProcessGroup>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub processors: Option<Vec<VersionedProcessor>>,
#[serde(rename = "remoteProcessGroups")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_process_groups: Option<Vec<VersionedRemoteProcessGroup>>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(rename = "statelessFlowTimeout")]
#[serde(skip_serializing_if = "Option::is_none")]
pub stateless_flow_timeout: Option<String>,
#[serde(rename = "versionedFlowCoordinates")]
#[serde(skip_serializing_if = "Option::is_none")]
pub versioned_flow_coordinates: Option<VersionedFlowCoordinates>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedProcessor {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(rename = "autoTerminatedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub auto_terminated_relationships: Option<Vec<String>>,
#[serde(rename = "backoffMechanism")]
#[serde(skip_serializing_if = "Option::is_none")]
pub backoff_mechanism: Option<String>,
#[serde(rename = "bulletinLevel")]
#[serde(skip_serializing_if = "Option::is_none")]
pub bulletin_level: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<Bundle>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(rename = "executionNode")]
#[serde(skip_serializing_if = "Option::is_none")]
pub execution_node: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(rename = "maxBackoffPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub max_backoff_period: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "penaltyDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub penalty_duration: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "propertyDescriptors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_descriptors:
Option<std::collections::HashMap<String, Option<VersionedPropertyDescriptor>>>,
#[serde(rename = "retriedRelationships")]
#[serde(skip_serializing_if = "Option::is_none")]
pub retried_relationships: Option<Vec<String>>,
#[serde(rename = "retryCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub retry_count: Option<i32>,
#[serde(rename = "runDurationMillis")]
#[serde(skip_serializing_if = "Option::is_none")]
pub run_duration_millis: Option<i64>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(rename = "schedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_period: Option<String>,
#[serde(rename = "schedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_strategy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub style: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
#[serde(rename = "yieldDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub yield_duration: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedPropertyDescriptor {
#[serde(rename = "displayName")]
#[serde(skip_serializing_if = "Option::is_none")]
pub display_name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub dynamic: Option<bool>,
#[serde(rename = "identifiesControllerService")]
#[serde(skip_serializing_if = "Option::is_none")]
pub identifies_controller_service: Option<bool>,
#[serde(rename = "listenPortDefinition")]
#[serde(default)]
#[serde(skip_serializing_if = "Option::is_none")]
pub listen_port_definition: Option<VersionedListenPortDefinition>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "resourceDefinition")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resource_definition: Option<VersionedResourceDefinition>,
#[serde(skip_serializing_if = "Option::is_none")]
pub sensitive: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedRemoteGroupPort {
#[serde(rename = "batchSize")]
#[serde(skip_serializing_if = "Option::is_none")]
pub batch_size: Option<BatchSize>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "concurrentlySchedulableTaskCount")]
#[serde(skip_serializing_if = "Option::is_none")]
pub concurrently_schedulable_task_count: Option<i32>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(rename = "remoteGroupId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub remote_group_id: Option<String>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(rename = "targetId")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_id: Option<String>,
#[serde(rename = "useCompression")]
#[serde(skip_serializing_if = "Option::is_none")]
pub use_compression: Option<bool>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedRemoteProcessGroup {
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "communicationsTimeout")]
#[serde(skip_serializing_if = "Option::is_none")]
pub communications_timeout: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "inputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub input_ports: Option<Vec<VersionedRemoteGroupPort>>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(rename = "localNetworkInterface")]
#[serde(skip_serializing_if = "Option::is_none")]
pub local_network_interface: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(rename = "outputPorts")]
#[serde(skip_serializing_if = "Option::is_none")]
pub output_ports: Option<Vec<VersionedRemoteGroupPort>>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(rename = "proxyHost")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_host: Option<String>,
#[serde(rename = "proxyPassword")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_password: Option<String>,
#[serde(rename = "proxyPort")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_port: Option<i32>,
#[serde(rename = "proxyUser")]
#[serde(skip_serializing_if = "Option::is_none")]
pub proxy_user: Option<String>,
#[serde(rename = "targetUris")]
#[serde(skip_serializing_if = "Option::is_none")]
pub target_uris: Option<String>,
#[serde(rename = "transportProtocol")]
#[serde(skip_serializing_if = "Option::is_none")]
pub transport_protocol: Option<String>,
#[serde(rename = "yieldDuration")]
#[serde(skip_serializing_if = "Option::is_none")]
pub yield_duration: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedReportingTask {
#[serde(rename = "annotationData")]
#[serde(skip_serializing_if = "Option::is_none")]
pub annotation_data: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub bundle: Option<Bundle>,
#[serde(skip_serializing_if = "Option::is_none")]
pub comments: Option<String>,
#[serde(rename = "componentType")]
#[serde(skip_serializing_if = "Option::is_none")]
pub component_type: Option<String>,
#[serde(rename = "groupIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub group_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub identifier: Option<String>,
#[serde(rename = "instanceIdentifier")]
#[serde(skip_serializing_if = "Option::is_none")]
pub instance_identifier: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub position: Option<Position>,
#[serde(skip_serializing_if = "Option::is_none")]
pub properties: Option<std::collections::HashMap<String, Option<String>>>,
#[serde(rename = "propertyDescriptors")]
#[serde(skip_serializing_if = "Option::is_none")]
pub property_descriptors:
Option<std::collections::HashMap<String, Option<VersionedPropertyDescriptor>>>,
#[serde(rename = "scheduledState")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduled_state: Option<String>,
#[serde(rename = "schedulingPeriod")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_period: Option<String>,
#[serde(rename = "schedulingStrategy")]
#[serde(skip_serializing_if = "Option::is_none")]
pub scheduling_strategy: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub r#type: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct VersionedResourceDefinition {
#[serde(skip_serializing_if = "Option::is_none")]
pub cardinality: Option<String>,
#[serde(rename = "resourceTypes")]
#[serde(skip_serializing_if = "Option::is_none")]
pub resource_types: Option<Vec<String>>,
}