pub struct JournalQueueConfig {
pub max_size: usize,
pub batch_size: usize,
pub flush_interval_ms: u64,
}Expand description
Configuration for the journal event queue
Fields§
§max_size: usizeMaximum number of events to buffer
batch_size: usizeMaximum batch size for drain_batch
flush_interval_ms: u64Flush interval in milliseconds (for reference, not enforced by queue)
Implementations§
Trait Implementations§
Source§impl Clone for JournalQueueConfig
impl Clone for JournalQueueConfig
Source§impl Debug for JournalQueueConfig
impl Debug for JournalQueueConfig
Auto Trait Implementations§
impl Freeze for JournalQueueConfig
impl RefUnwindSafe for JournalQueueConfig
impl Send for JournalQueueConfig
impl Sync for JournalQueueConfig
impl Unpin for JournalQueueConfig
impl UnsafeUnpin for JournalQueueConfig
impl UnwindSafe for JournalQueueConfig
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> 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> ⓘ
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::RequestSource§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