Struct VersionedProcessGroup 

pub struct VersionedProcessGroup {

    pub comments: Option<String>,
    pub component_type: Option<String>,
    pub connections: Option<Vec<VersionedConnection>>,
    pub controller_services: Option<Vec<VersionedControllerService>>,
    pub default_back_pressure_data_size_threshold: Option<String>,
    pub default_back_pressure_object_threshold: Option<i64>,
    pub default_flow_file_expiration: Option<String>,
    pub execution_engine: Option<String>,
    pub flow_file_concurrency: Option<String>,
    pub flow_file_outbound_policy: Option<String>,
    pub funnels: Option<Vec<VersionedFunnel>>,
    pub group_identifier: Option<String>,
    pub identifier: Option<String>,
    pub input_ports: Option<Vec<VersionedPort>>,
    pub instance_identifier: Option<String>,
    pub labels: Option<Vec<VersionedLabel>>,
    pub log_file_suffix: Option<String>,
    pub max_concurrent_tasks: Option<i32>,
    pub name: Option<String>,
    pub output_ports: Option<Vec<VersionedPort>>,
    pub parameter_context_name: Option<String>,
    pub position: Option<Position>,
    pub process_groups: Option<Vec<Box<VersionedProcessGroup>>>,
    pub processors: Option<Vec<VersionedProcessor>>,
    pub remote_process_groups: Option<Vec<VersionedRemoteProcessGroup>>,
    pub scheduled_state: Option<String>,
    pub stateless_flow_timeout: Option<String>,
    pub versioned_flow_coordinates: Option<VersionedFlowCoordinates>,
}

Fields

comments: Option<String>

component_type: Option<String>

connections: Option<Vec<VersionedConnection>>

controller_services: Option<Vec<VersionedControllerService>>

default_back_pressure_data_size_threshold: Option<String>

default_back_pressure_object_threshold: Option<i64>

default_flow_file_expiration: Option<String>

execution_engine: Option<String>

flow_file_concurrency: Option<String>

flow_file_outbound_policy: Option<String>

funnels: Option<Vec<VersionedFunnel>>

group_identifier: Option<String>

identifier: Option<String>

input_ports: Option<Vec<VersionedPort>>

instance_identifier: Option<String>

labels: Option<Vec<VersionedLabel>>

log_file_suffix: Option<String>

max_concurrent_tasks: Option<i32>

name: Option<String>

output_ports: Option<Vec<VersionedPort>>

parameter_context_name: Option<String>

position: Option<Position>

process_groups: Option<Vec<Box<VersionedProcessGroup>>>

processors: Option<Vec<VersionedProcessor>>

remote_process_groups: Option<Vec<VersionedRemoteProcessGroup>>

scheduled_state: Option<String>

stateless_flow_timeout: Option<String>

versioned_flow_coordinates: Option<VersionedFlowCoordinates>

Trait Implementations

impl Clone for VersionedProcessGroup

fn clone(&self) -> VersionedProcessGroup

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for VersionedProcessGroup

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for VersionedProcessGroup

fn default() -> VersionedProcessGroup

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for VersionedProcessGroup

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<VersionedProcessGroup> for VersionedProcessGroup

fn from(v: VersionedProcessGroup) -> Self

Converts to this type from the input type.

impl From<VersionedProcessGroup> for VersionedProcessGroup

fn from(v: VersionedProcessGroup) -> Self

Converts to this type from the input type.

impl From<VersionedProcessGroup> for VersionedProcessGroup

fn from(v: VersionedProcessGroup) -> Self

Converts to this type from the input type.

impl Serialize for VersionedProcessGroup

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.