pub struct LatencyLoggerPlugin {
pub log: Mutex<Vec<u64>>,
}Expand description
A plugin that records per-request start/end timestamps (milliseconds since Unix epoch) into a shared latency log.
Call LatencyLoggerPlugin::record_start before inference and
LatencyLoggerPlugin::record_end after inference to append the elapsed
duration to the log.
Fields§
§log: Mutex<Vec<u64>>Accumulated latency samples in milliseconds.
Implementations§
Trait Implementations§
Source§impl Default for LatencyLoggerPlugin
impl Default for LatencyLoggerPlugin
Source§impl Plugin for LatencyLoggerPlugin
impl Plugin for LatencyLoggerPlugin
Source§fn on_request(&self, _req: &mut PromptRequest) -> Result<(), PluginError>
fn on_request(&self, _req: &mut PromptRequest) -> Result<(), PluginError>
Inspect and/or mutate the request before it reaches inference. Read more
Source§fn on_response(&self, _resp: &mut Vec<String>) -> Result<(), PluginError>
fn on_response(&self, _resp: &mut Vec<String>) -> Result<(), PluginError>
Inspect and/or mutate the response tokens after inference. Read more
Auto Trait Implementations§
impl !Freeze for LatencyLoggerPlugin
impl RefUnwindSafe for LatencyLoggerPlugin
impl Send for LatencyLoggerPlugin
impl Sync for LatencyLoggerPlugin
impl Unpin for LatencyLoggerPlugin
impl UnsafeUnpin for LatencyLoggerPlugin
impl UnwindSafe for LatencyLoggerPlugin
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request