Struct ApplyPolicyOwnedArgs 

pub struct ApplyPolicyOwnedArgs<'a> {
    pub edge_idx: usize,
    pub policy: &'a EdgePolicyKind,
    pub payload: CorrelatedPayload,
    pub queues: &'a Arc<Vec<EdgeStorage>>,
    pub warnings_seen: &'a Arc<Mutex<HashSet<String>>>,
    pub telem: &'a mut ExecutionTelemetry,
    pub warning_label: Option<String>,
    pub backpressure: BackpressureStrategy,
}

Fields

edge_idx: usize

policy: &'a EdgePolicyKind

payload: CorrelatedPayload

queues: &'a Arc<Vec<EdgeStorage>>

warnings_seen: &'a Arc<Mutex<HashSet<String>>>

telem: &'a mut ExecutionTelemetry

warning_label: Option<String>

backpressure: BackpressureStrategy