Struct LoopEvalSite 

pub struct LoopEvalSite { /* private fields */ }

An eval site that repeatedly runs its pipeline steps – up to max_iterations times – until the until predicate fires on a reply.

Implementations

impl LoopEvalSite

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

Creates a loop site answering at address over codecs, running steps at most max_iterations times or until until fires.

Trait Implementations

impl Clone for LoopEvalSite

fn clone(&self) -> LoopEvalSite

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EvalSite for LoopEvalSite

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 LoopEvalSite

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 LoopEvalSite

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.