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 !RefUnwindSafe for PersistedQueueArgs
impl !UnwindSafe for PersistedQueueArgs
impl Freeze for PersistedQueueArgs
impl Send for PersistedQueueArgs
impl Sync for PersistedQueueArgs
impl Unpin for PersistedQueueArgs
impl UnsafeUnpin 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> 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 moreSource§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