Struct Isolate 

pub struct Isolate<Inner = PipeHandle> {
    pub inner: Inner,
    pub timeout: Option<Duration>,
    pub panic_barrier: bool,
}

blast-radius barrier around an inner Pipe. enforces:

• time budget — proxima_core::time::timeout drops the inner future and returns 503 when exceeded; the rest of the chain stays healthy.
• panic barrier — catch_unwind converts a panic in the inner future into a 500 response instead of unwinding through the chain.

either guard is independently optional; with both off this is a pass-through.

generic over the inner handle so the same wrapper composes a Send inner (PipeHandle, the default — yields impl Handler) or a per-thread !Send-tolerant inner (ThreadLocalPipeHandle — yields impl ThreadLocalHandler). The Send variant participates in cross-thread bootstrap; the per-thread variant lets DPDK / per-core runtimes hold Rc/RefCell/!Send impl state.

Fields

inner: Inner

timeout: Option<Duration>

panic_barrier: bool

Implementations

impl<Inner> Isolate<Inner>

pub fn new(inner: Inner) -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn with_panic_barrier(self, enabled: bool) -> Self

impl Isolate<PipeHandle>

pub fn from_spec(inner: PipeHandle, value: &Value) -> Result<Self, ProximaError>

Trait Implementations

impl Pipe for Isolate<ThreadLocalPipeHandle>

type In = Request<Bytes>

Input the pipe consumes.

type Out = Response<Bytes>

Output the pipe produces.

type Err = ProximaError

Error the pipe can fail with. Debug + 'static; Send is added only on the cross-core SendPipe form.

fn call( &self, request: Request<Bytes>, ) -> impl Future<Output = Result<Response<Bytes>, ProximaError>>

Apply the pipe. The returned future is NOT required to be Send.

impl<Inner> SendPipe for Isolate<Inner>

where Inner: Handler + Clone,

type In = Request<Bytes>

Input the pipe consumes.

type Out = Response<Bytes>

Output the pipe produces.

type Err = ProximaError

Error the pipe can fail with — Send here so it can cross cores.

fn call( &self, request: Request<Bytes>, ) -> impl Future<Output = Result<Response<Bytes>, ProximaError>> + Send

Apply the pipe. The returned future IS Send.