BatchConfig

Struct BatchConfig 

Source
pub struct BatchConfig { /* private fields */ }
Expand description

Configuration for bulk operation batching and limits.

Controls various aspects of bulk operations including batch sizes, timeouts, processing limits, and UI behavior. Provides sensible defaults for all configuration values.

§Examples

use quetty_server::bulk_operations::BatchConfig;

// Use default configuration
let config = BatchConfig::default();

// Create custom configuration
let config = BatchConfig::new(100, 600);

// Access configuration values
println!("Max batch size: {}", config.max_batch_size());
println!("Timeout: {}s", config.operation_timeout_secs());

Implementations§

Source§

impl BatchConfig

Source

pub fn new(max_batch_size: u32, operation_timeout_secs: u64) -> Self

Creates a new BatchConfig with specified batch size and timeout.

Other configuration values will use their defaults when accessed.

§Arguments
  • max_batch_size - Maximum number of messages per batch
  • operation_timeout_secs - Timeout for bulk operations in seconds
§Returns

A new BatchConfig with the specified values

Source

pub fn max_batch_size(&self) -> u32

Get the maximum batch size for bulk operations

Source

pub fn operation_timeout_secs(&self) -> u64

Get the timeout for bulk operations

Source

pub fn bulk_chunk_size(&self) -> usize

Get the chunk size for bulk processing operations

Source

pub fn bulk_processing_time_secs(&self) -> u64

Get the processing time limit for bulk operations in seconds

Source

pub fn lock_timeout_secs(&self) -> u64

Get the timeout for lock operations in seconds

Source

pub fn max_messages_to_process(&self) -> usize

Get the maximum messages to process in bulk operations

Source

pub fn auto_reload_threshold(&self) -> usize

Get the threshold for triggering auto-reload after bulk operations

Source

pub fn receive_timeout_secs(&self) -> u64

Get the timeout for individual receive message operations in seconds

Trait Implementations§

Source§

impl Clone for BatchConfig

Source§

fn clone(&self) -> BatchConfig

Returns a duplicate of the value. Read more
1.0.0 · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl Debug for BatchConfig

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
Source§

impl Default for BatchConfig

Source§

fn default() -> BatchConfig

Returns the “default value” for a type. Read more
Source§

impl<'de> Deserialize<'de> for BatchConfig

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<D> DeserializeWith<JsonFormat> for D

Source§

fn deserialize_with<'async_trait>( body: ResponseBody, ) -> Pin<Box<dyn Future<Output = Result<D, Error>> + Send + 'async_trait>>
where D: 'async_trait,

Source§

impl<D> DeserializeWith<JsonFormat> for D

Source§

fn deserialize_with<'async_trait>( body: ResponseBody, ) -> Pin<Box<dyn Future<Output = Result<D, Error>> + Send + 'async_trait>>
where D: 'async_trait,

Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> SendBound for T
where T: Send,