Struct PoolItem 

pub struct PoolItem {

    pub cfg: Vec<Attribute>,
    pub ident: Ident,
    pub modes: Vec<Ident>,
    pub deps: Vec<Dep>,
    pub source: TaskSource,
    pub policy: Expr,
    pub policy_ty: Option<Type>,
    pub executor: Option<Ident>,
    pub executor_defaulted: bool,
    pub resources: Vec<ResourceDecl>,
    pub slot_timeout: Option<Gated<slot_timeout, LitInt>>,
    pub ack_timeout: Option<Gated<ack_timeout, LitInt>>,
    pub reads: Vec<SignalDecl>,
    pub writes: Vec<SignalDecl>,
    pub min: Expr,
    pub max: Expr,
    pub state: Option<(state, Type, StateInit)>,
    pub cancel: bool,
    pub discover: Option<Gated<discover>>,
    pub dataflow: Vec<AdoptedFn>,
    pub fragment: Option<String>,
}

A parsed pool NAME = [Mode, ...], ...; declaration.

Fields

cfg: Vec<Attribute>

#[cfg(...)] attributes attached to the pool.

ident: Ident

The pool identifier.

modes: Vec<Ident>

The allowed member lifecycle modes.

deps: Vec<Dep>

The pool’s deps: list.

source: TaskSource

The task source (spawn: or task:).

policy: Expr

The scaling policy expression.

policy_ty: Option<Type>

The optional explicit scaling policy type.

executor: Option<Ident>

Spawning executor: either an explicit executor: clause or the graph’s inherited default.

executor_defaulted: bool

true if the executor was inherited from the default, not written.

resources: Vec<ResourceDecl>

The resources: list.

slot_timeout: Option<Gated<slot_timeout, LitInt>>

The slot_timeout: value in milliseconds, with any #[cfg(...)] gate.

ack_timeout: Option<Gated<ack_timeout, LitInt>>

The ack_timeout: value in milliseconds, with any #[cfg(...)] gate.

reads: Vec<SignalDecl>

The reads: signal list.

writes: Vec<SignalDecl>

The writes: signal list.

min: Expr

The min: expression for elastic scaling.

max: Expr

The max: expression for elastic scaling.

state: Option<(state, Type, StateInit)>

The state: declaration, if any.

cancel: bool

Whether pool members are marked cancel.

discover: Option<Gated<discover>>

The discover marker, if present, with any #[cfg(...)] gate.

dataflow: Vec<AdoptedFn>

Functions adopted via dataflow:.

fragment: Option<String>

The fragment name this pool belongs to, if any.

Trait Implementations

impl Clone for PoolItem

fn clone(&self) -> PoolItem

Returns a duplicate of the value.

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

Performs copy-assignment from source.