pub struct Config<C> {
pub partition: String,
pub items_per_section: NonZeroU64,
pub compression: Option<u8>,
pub codec_config: C,
pub page_cache: CacheRef,
pub write_buffer: NonZeroUsize,
pub replay_buffer: NonZeroUsize,
}Expand description
Configuration for Queue.
Fields§
§partition: StringThe storage partition name for the queue’s journal.
items_per_section: NonZeroU64The number of items to store in each journal section.
Larger values reduce file overhead but increase minimum pruning granularity. Once set, this value cannot be changed across restarts.
compression: Option<u8>Optional zstd compression level for stored items.
If set, items will be compressed before storage. Higher values provide better compression but use more CPU.
Keep the choice between None and Some(_) fixed while stored items are retained.
Only the compression level may change between initializations when compression is enabled.
codec_config: CCodec configuration for encoding/decoding items.
page_cache: CacheRefPage cache for buffering reads from the underlying journal.
write_buffer: NonZeroUsizeWrite buffer size for each section.
replay_buffer: NonZeroUsizeBuffer size for sequential reads during recovery.
Trait Implementations§
Auto Trait Implementations§
impl<C> !RefUnwindSafe for Config<C>
impl<C> !UnwindSafe for Config<C>
impl<C> Freeze for Config<C>where
C: Freeze,
impl<C> Send for Config<C>where
C: Send,
impl<C> Sync for Config<C>where
C: Sync,
impl<C> Unpin for Config<C>where
C: Unpin,
impl<C> UnsafeUnpin for Config<C>where
C: UnsafeUnpin,
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
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
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> ⓘ
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> ⓘ
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