Struct PinnedClient 

pub struct PinnedClient { /* private fields */ }

InferenceClient middleware enforcing a ModelPin.

Implementations

impl PinnedClient

pub fn new( inner: Arc<dyn InferenceClient>, resolver: Arc<dyn ModelResolver>, ) -> Self

pub fn pin_model(self, pin: ModelPin) -> Self

Pin the model (see crate::Agent wiring as pin_model).

pub fn strict(self, strict: bool) -> Self

Require a pin to be set, else refuse to run.

pub fn refuse_on_drift(self, refuse: bool) -> Self

Make drift a hard refusal in addition to an emitted event.

pub fn with_telemetry( self, telemetry: Telemetry, run_id: impl Into<String>, ) -> Self

pub fn pin(&self) -> Option<&ModelPin>

The pin this client carries, if any (for stamping into records).

pub fn revalidate(&self) -> Option<DriftKind>

Re-validate the pin against a freshly resolved version (heartbeat). Returns the drift kind if the provider has drifted.

Trait Implementations

impl InferenceClient for PinnedClient

fn provider(&self) -> Provider

fn run<'life0, 'async_trait>( &'life0 self, batch: ExecuteBatch, ) -> Pin<Box<dyn Future<Output = Result<TurnResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,