pub struct BulkExecutor { /* private fields */ }Expand description
Executes bulk operations concurrently with rate limiting.
Implementations§
Source§impl BulkExecutor
impl BulkExecutor
pub fn new() -> Self
pub fn with_concurrency(self, concurrency: usize) -> Self
pub fn with_rate_limit(self, delay: Duration) -> Self
pub async fn execute( &self, operations: Vec<BulkOperation>, progress: Option<ProgressCallback>, ) -> Vec<BulkResult>
pub async fn execute_whois(&self, domains: Vec<String>) -> Vec<BulkResult>
pub async fn execute_rdap(&self, domains: Vec<String>) -> Vec<BulkResult>
pub async fn execute_dns( &self, domains: Vec<String>, record_type: RecordType, ) -> Vec<BulkResult>
pub async fn execute_propagation( &self, domains: Vec<String>, record_type: RecordType, ) -> Vec<BulkResult>
pub async fn execute_lookup(&self, domains: Vec<String>) -> Vec<BulkResult>
pub async fn execute_status(&self, domains: Vec<String>) -> Vec<BulkResult>
pub async fn execute_avail(&self, domains: Vec<String>) -> Vec<BulkResult>
pub async fn execute_info(&self, domains: Vec<String>) -> Vec<BulkResult>
Trait Implementations§
Source§impl Clone for BulkExecutor
impl Clone for BulkExecutor
Source§fn clone(&self) -> BulkExecutor
fn clone(&self) -> BulkExecutor
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for BulkExecutor
impl Debug for BulkExecutor
Auto Trait Implementations§
impl Freeze for BulkExecutor
impl !RefUnwindSafe for BulkExecutor
impl Send for BulkExecutor
impl Sync for BulkExecutor
impl Unpin for BulkExecutor
impl UnsafeUnpin for BulkExecutor
impl !UnwindSafe for BulkExecutor
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> 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::Request