Enum PipelineStep 

pub enum PipelineStep {
    Resolve(ResolveConfig),
    Filter(FilterConfig),
    FanOut(FanOutConfig),
    Batch(BatchConfig),
    Deduplicate(DeduplicateConfig),
    Map(MapConfig),
    RateLimit(RateLimitConfig),
    Deliver(DeliverConfig),
}

A single step in the pipeline — wraps a PipelineOp with its config

Each step is a single-key YAML map where the key names the operator:

- resolve:
    from: target_id
    as: owner
- filter:
    condition: "source_id != owner.id"

Uses a custom Serialize/Deserialize to produce clean YAML (map keys instead of YAML tags).

Variants

Resolve(ResolveConfig)

Resolve an entity by ID or by following a link

Filter(FilterConfig)

Filter events based on a condition (drop if false)

FanOut(FanOutConfig)

Fan out to multiple recipients via link resolution (1→N)

Batch(BatchConfig)

Batch events by key within a time window

Deduplicate(DeduplicateConfig)

Deduplicate events by key within a sliding window

Map(MapConfig)

Transform the payload via a Tera template

RateLimit(RateLimitConfig)

Rate limit the flow

Deliver(DeliverConfig)

Deliver to one or more sinks

Trait Implementations

impl Clone for PipelineStep

fn clone(&self) -> PipelineStep

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineStep

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PipelineStep

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PipelineStep

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.