Skip to main content

ModelRunner

sim_lib_agent

Trait ModelRunner 

Source 
pub trait ModelRunner: Send + Sync {
    // Required methods
    fn card(&self) -> ModelCard;
    fn infer(
        &self,
        cx: &mut Cx,
        request: ModelRequest,
    ) -> Result<ModelResponse, Error>;

    // Provided methods
    fn infer_request(
        &self,
        cx: &mut Cx,
        request: EvalRequest,
    ) -> Result<ModelResponse, Error> { ... }
    fn infer_stream(
        &self,
        cx: &mut Cx,
        request: ModelRequest,
        sink: &mut dyn ModelEventSink,
    ) -> Result<ModelResponse, Error> { ... }
    fn infer_stream_request(
        &self,
        cx: &mut Cx,
        request: EvalRequest,
        sink: &mut dyn ModelEventSink,
    ) -> Result<ModelResponse, Error> { ... }
    fn bid(&self, _request: &ModelRequest) -> Result<ModelBid, Error> { ... }
}
Expand description

Executable contract for a model backend or model-like runtime surface.

Required Methods§

Source

fn card(&self) -> ModelCard

Returns metadata describing the runner’s advertised model surface.

Source

fn infer( &self, cx: &mut Cx, request: ModelRequest, ) -> Result<ModelResponse, Error>

Executes one non-streaming inference request.

Provided Methods§

Source

fn infer_request( &self, cx: &mut Cx, request: EvalRequest, ) -> Result<ModelResponse, Error>

Executes one non-streaming inference request with its full eval envelope.

Implementations that need the caller’s capability ceiling can override this method. The default keeps existing model-only runners compatible.

Source

fn infer_stream( &self, cx: &mut Cx, request: ModelRequest, sink: &mut dyn ModelEventSink, ) -> Result<ModelResponse, Error>

Executes one streaming inference request.

The default implementation falls back to Self::infer and emits a synthesized final event.

Source

fn infer_stream_request( &self, cx: &mut Cx, request: EvalRequest, sink: &mut dyn ModelEventSink, ) -> Result<ModelResponse, Error>

Executes one streaming inference request with its full eval envelope.

The default preserves existing streaming behavior after decoding the model request from the envelope.

Source

fn bid(&self, _request: &ModelRequest) -> Result<ModelBid, Error>

Returns an availability and score hint for market-style routing.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§