Struct BulkExecutor 

pub struct BulkExecutor { /* private fields */ }

Executes bulk operations concurrently with rate limiting.

Implementations

impl BulkExecutor

pub fn new() -> Self

pub fn from_config(config: &SeerConfig) -> Self

Builds an executor honoring ~/.seer/config.toml settings.

Reads bulk.concurrency (clamped to 1–50) and bulk.rate_limit_ms for dispatch pacing, plus every per-protocol timeout (timeouts.whois_secs / rdap_secs / dns_secs / http_secs) for the internal sub-clients. The propagation checker deliberately keeps its own tuned timeouts (a fan-out to every server in its list has different latency characteristics than a single query).

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_streaming( &self, operations: Vec<BulkOperation>, on_result: ResultCallback, ) -> Vec<BulkResult>

Like execute, but also invokes on_result with each BulkResult as soon as it completes (completion order). Enables live streaming of rows to a UI while the batch is still running.

pub async fn execute_each( &self, domains: Vec<String>, op: impl FnMut(String) -> BulkOperation, ) -> Vec<BulkResult>

Runs one operation per domain, built by op — shorthand for mapping a domain list into BulkOperations and calling execute without a progress callback:

use seer_core::bulk::BulkOperation;
use seer_core::dns::RecordType;

let domains = vec!["example.com".to_string()];
let results = executor
    .execute_each(domains, |domain| BulkOperation::Dns {
        domain,
        record_type: RecordType::MX,
    })
    .await;

Trait Implementations

impl Clone for BulkExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BulkExecutor

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

Formats the value using the given formatter.

impl Default for BulkExecutor

fn default() -> Self

Returns the “default value” for a type.