Struct PipelineContext 

pub struct PipelineContext {
    pub request_id: String,
    pub query: String,
    pub file_path: Option<String>,
    pub max_results: usize,
    pub timeout: Duration,
    pub started_at: Instant,
    pub sla_deadline: Instant,
}

Pipeline execution context with zero-copy semantics

Fields

request_id: String

query: String

file_path: Option<String>

max_results: usize

timeout: Duration

started_at: Instant

sla_deadline: Instant

Implementations

impl PipelineContext

pub fn new(request_id: String, query: String, timeout_ms: u64) -> Self

pub fn with_file_path(self, file_path: String) -> Self

pub fn with_max_results(self, max_results: usize) -> Self

pub fn elapsed(&self) -> Duration

pub fn remaining_time(&self) -> Duration

pub fn is_deadline_exceeded(&self) -> bool

pub fn time_budget_percent(&self) -> f64

Trait Implementations

impl Clone for PipelineContext

fn clone(&self) -> PipelineContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.