Struct CaptureObserver 

pub struct CaptureObserver<'a, B, F> { /* private fields */ }

Borrows the existing capture owner. Backends provide native primitives and a typed error conversion; this adapter owns no completion or native recovery state.

Implementations

impl<'a, B, F> CaptureObserver<'a, B, F>

pub fn new(session: &'a mut CaptureSession, backend: B, map_error: F) -> Self

Creates an observer that forwards all value/control hooks to the shared run.

Trait Implementations

impl<B, E, F> ActivationObserver<<B as CaptureBackend>::Tensor, E> for CaptureObserver<'_, B, F>

where B: InterventionBackend, F: Fn(CaptureExecutionError<B::Error>) -> E,

fn observe(&mut self, path: &str, value: &B::Tensor) -> Result<(), E>

Observes a named backend-native tensor.

fn intervene( &mut self, path: &str, value: &B::Tensor, ) -> Result<Option<B::Tensor>, E>

Optionally replaces an activation before it is consumed or returned.

fn routing_control( &mut self, path: &str, rows: u64, ) -> Result<Option<GroupSelectionControl>, E>

Obtains a validated control before the selector dispatches any experts. The default ordinary path allocates and materializes nothing.

fn routing_applied( &mut self, path: &str, original: Option<RoutingDecision<'_, B::Tensor>>, effective: RoutingDecision<'_, B::Tensor>, ) -> Result<(), E>

Receives original/effective decisions before they reach the expert provider.

fn routing_failed(&mut self, path: &str, message: &str)

Records a failed control under the enclosing forward pass’s failure owner.

fn finish(&mut self) -> Result<(), E>

Completes an ordinary forward pass under its existing failure owner. Scheduled-but-missing interventions must fail before prediction commitment.

fn observe_routing( &mut self, routing: RoutingObservation<'_, B::Tensor>, ) -> Result<(), E>

Observes normalized routed-expert decisions and contributions.