Struct PipelineEvalSite 

pub struct PipelineEvalSite { /* private fields */ }

An eval site that threads each request through an ordered chain of connection steps, feeding each step’s reply into the next.

Implementations

impl PipelineEvalSite

pub fn new( address: ServerAddress, codecs: Vec<Symbol>, steps: Vec<Connection>, ) -> Self

Creates a pipeline site answering at address over codecs, running the given ordered steps.

pub fn steps(&self) -> &[Connection]

Returns the pipeline’s ordered connection steps.

Trait Implementations

impl Clone for PipelineEvalSite

fn clone(&self) -> PipelineEvalSite

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EvalSite for PipelineEvalSite

fn site_kind(&self) -> &'static str

Returns a short label naming the kind of site.

fn address(&self) -> &ServerAddress

Returns the address this site answers at.

fn codecs(&self) -> &[Symbol]

Returns the codecs this site can decode and encode.

fn answer(&self, cx: &mut Cx, frame: ServerFrame) -> Result<ServerFrame>

Answers frame, returning the reply frame.

fn as_any(&self) -> &dyn Any

Returns the site as &dyn Any for downcasting.

fn answer_with_timeout( &self, cx: &mut Cx, frame: ServerFrame, _timeout: Option<Duration>, ) -> Result<ServerFrame>

Answers frame with an optional deadline. Defaults to EvalSite::answer.

fn close_connection(&self, _cx: &mut Cx) -> Result<()>

Closes any connection backing the site. Defaults to a no-op.

fn stream( &self, cx: &mut Cx, frame: ServerFrame, sink: &mut dyn StreamSink, ) -> Result<()>

Streams the answer to frame into sink. The default path answers once and emits a single chunk followed by end.

fn as_eval_fabric(&self) -> Option<&dyn EvalFabric>

Returns this site as an EvalFabric when it backs one. Defaults to None.

impl Site for PipelineEvalSite

fn kind(&self) -> SiteKind

Returns the SiteKind of this site.

fn run_fragment( &self, cx: &mut Cx, fragment: &PlacedFragment, ) -> Result<Vec<StreamEnvelope>>

Realizes fragment: feeds its input edges, evaluates its node, and emits a result envelope per output edge.

fn realize_fragment_node( &self, cx: &mut Cx, fragment: &PlacedFragment, ) -> Result<EvalReply>

Evaluates the fragment’s node and returns its reply, with no deadline.

fn realize_fragment_node_with_timeout( &self, cx: &mut Cx, fragment: &PlacedFragment, timeout: Option<Duration>, ) -> Result<EvalReply>

Evaluates the fragment’s node and returns its reply, honoring timeout.

impl StreamEndpoint for PipelineEvalSite

fn endpoint_id(&self) -> Symbol

Returns the endpoint’s stable identifier.

fn endpoint_kind(&self) -> StreamEndpointKind

Returns the role this endpoint plays.

fn clock_domain(&self) -> ClockDomain

Returns the clock domain this endpoint runs in.

fn latency_class(&self) -> LatencyClass

Returns the latency class this endpoint targets.

fn accept_input_edges(&self, edges: &[StreamEdge]) -> Result<(), Error>

Validates that each input edge’s clock domain matches this endpoint.

fn output_envelopes( &self, fragment: &PlacedFragment, ) -> Result<Vec<StreamEnvelope>, Error>

Returns the envelopes this endpoint emits for fragment.