pub struct PersistedQueueArgs {
pub root_path: PathBuf,
pub max_on_disk_bytes: u64,
pub storage_max_disk_ratio: f64,
pub disk_usage_retriever: Arc<dyn DiskUsageRetriever + Send + Sync>,
pub max_age_days: u32,
}Expand description
Arguments for constructing a persisted retry queue.
Fields§
§root_path: PathBufRoot path under which the queue directory is created.
max_on_disk_bytes: u64Maximum total bytes the queue may occupy on disk.
storage_max_disk_ratio: f64Maximum fraction of the disk that may be used before writes stop.
disk_usage_retriever: Arc<dyn DiskUsageRetriever + Send + Sync>Provider for total- and available-disk-space queries.
max_age_days: u32Maximum age of retry files in days; files older than this are removed on startup.
Setting this to 0 removes all retry files (cutoff = now), matching the behavior of the
core Agent’s FileRemovalPolicy with outdatedFileDayCount = 0.
Auto Trait Implementations§
impl Freeze for PersistedQueueArgs
impl !RefUnwindSafe for PersistedQueueArgs
impl Send for PersistedQueueArgs
impl Sync for PersistedQueueArgs
impl Unpin for PersistedQueueArgs
impl !UnwindSafe for PersistedQueueArgs
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> 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> Pointable for T
impl<T> Pointable for T
Source§impl<T> Track for T
impl<T> Track for T
Source§fn track_resources(self, token: ResourceGroupToken) -> Tracked<Self>
fn track_resources(self, token: ResourceGroupToken) -> Tracked<Self>
Instruments this type by attaching the given resource group token, returning a
Tracked wrapper. Read moreSource§fn in_current_resource_group(self) -> Tracked<Self>
fn in_current_resource_group(self) -> Tracked<Self>
Instruments this type by attaching the current resource group, returning a
Tracked wrapper. Read more