pub struct DecoderConfig {
pub cache_repetition_index: bool,
pub validate_on_decode: bool,
pub inline_scheduling: Option<bool>,
}Expand description
Configuration for decoder behavior
Fields§
§cache_repetition_index: boolWhether to cache repetition indices for better performance.
This defaults to the LANCE_READ_CACHE_REPETITION_INDEX environment variable
when present and is enabled by default. Set the env var to a non-truthy
value (for example 0 or false) to disable it. The env var is read
once per process.
validate_on_decode: boolWhether to validate decoded data
inline_scheduling: Option<bool>Override the strategy used to dispatch the scheduling work in
schedule_and_decode.
schedule_and_decode always awaits the scheduler’s initialize (which
performs metadata I/O) before returning. This flag controls what
happens with the subsequent (synchronous) work of pushing decoder
messages into the channel that feeds the decode stream.
None- default behavior: the scheduling work runs inline (as part of theschedule_and_decodeawait) when the request is small (controlled by theLANCE_INLINE_SCHEDULING_THRESHOLDenv var) and is dispatched onto a spawned task otherwise.Some(true)- always run scheduling inline. The await ofschedule_and_decodedoes not return until every decoder message has been queued.Some(false)- always spawn a task for scheduling so that it can overlap with consumption of the decode stream.
Trait Implementations§
Source§impl Clone for DecoderConfig
impl Clone for DecoderConfig
Source§fn clone(&self) -> DecoderConfig
fn clone(&self) -> DecoderConfig
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for DecoderConfig
impl Debug for DecoderConfig
Auto Trait Implementations§
impl Freeze for DecoderConfig
impl RefUnwindSafe for DecoderConfig
impl Send for DecoderConfig
impl Sync for DecoderConfig
impl Unpin for DecoderConfig
impl UnsafeUnpin for DecoderConfig
impl UnwindSafe for DecoderConfig
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more