pub struct ReadTuning {
pub prefetch_window: i32,
pub buffer_messages: usize,
pub ack_interval_bytes: i64,
pub ack_interval_chunks: u32,
}Expand description
Per-stream tuning knobs for the sequential read path().
Carries the prefetch window, receive-buffer depth, and flow-control ACK
coalescing thresholds resolved from GoosefsConfig.
Fields§
§prefetch_window: i32Prefetch window in chunks sent on the initial ReadRequest().
buffer_messages: usizeReceive-buffer depth between the background drain task and the consumer, in messages().
ack_interval_bytes: i64ACK coalescing threshold in bytes().
ack_interval_chunks: u32ACK coalescing threshold in chunks().
Implementations§
Source§impl ReadTuning
impl ReadTuning
Sourcepub fn from_config(config: &GoosefsConfig) -> Self
pub fn from_config(config: &GoosefsConfig) -> Self
Resolve tuning knobs from the SDK config.
Trait Implementations§
Source§impl Clone for ReadTuning
impl Clone for ReadTuning
Source§fn clone(&self) -> ReadTuning
fn clone(&self) -> ReadTuning
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 moreimpl Copy for ReadTuning
Auto Trait Implementations§
impl Freeze for ReadTuning
impl RefUnwindSafe for ReadTuning
impl Send for ReadTuning
impl Sync for ReadTuning
impl Unpin for ReadTuning
impl UnsafeUnpin for ReadTuning
impl UnwindSafe for ReadTuning
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
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> 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