Skip to main content

CaptureProxy

amberfork_record

Struct CaptureProxy

pub struct CaptureProxy { /* private fields */ }

Expand description

A bound, running capture proxy.

Implementations§

impl CaptureProxy

pub async fn bind( id: impl Into<String>, upstream: &str, ) -> Result<Self, RecordError>

Bind a capture proxy on loopback, forwarding to upstream.

Loopback-only, like the serving edge: a proxy that relays an agent’s traffic — and holds the credential to do it — has no business being reachable off the machine. Port 0 lets the OS pick, which is what keeps concurrent recordings from colliding.

pub fn base_url(&self) -> String

The base URL to hand the agent, e.g. via OPENAI_BASE_URL.

pub fn addr(&self) -> SocketAddr

The address the proxy is bound to.

pub fn cassette(&self) -> Cassette

Snapshot the tape as a cassette. Takes &self so a recording can be inspected while the session is still open.

Auto Trait Implementations§

impl Freeze for CaptureProxy

impl RefUnwindSafe for CaptureProxy

impl Send for CaptureProxy

impl Sync for CaptureProxy

impl Unpin for CaptureProxy

impl UnsafeUnpin for CaptureProxy

impl UnwindSafe for CaptureProxy

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = !

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, !>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more