Struct Pipeline 

pub struct Pipeline {
    pub routing: RoutingConfig,
    pub providers: HashMap<String, Arc<dyn Provider>>,
}

The part of a client that a config reload replaces: the routing rules and the providers they name. Swapped as one unit, so a signal never sees new routes with old providers.

Fields

routing: RoutingConfig

providers: HashMap<String, Arc<dyn Provider>>

Implementations

impl Pipeline

pub fn from_config(config: &Config) -> Self

Registers the configured providers. console is always present because routing falls back to it.

pub fn preview( &self, signal: &Signal, only: Option<&str>, ) -> Result<Vec<(String, Option<Value>)>, SignalError>

What each provider signal routes to would be sent, in plan order, without sending anything or recording the signal; with only, just that provider whether or not a route picks it. A provider that can’t show its payload has None.