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 (30-server fan-out 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_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>

pub async fn execute_ssl(&self, domains: Vec<String>) -> Vec<BulkResult>

pub async fn execute_posture(&self, domains: Vec<String>) -> Vec<BulkResult>

pub async fn execute_confusables(&self, domains: Vec<String>) -> Vec<BulkResult>

Bulk look-alike scan. See BulkOperation::Confusables for the cost caveat — each domain fans out its own candidate scan.

pub async fn execute_caa(&self, domains: Vec<String>) -> Vec<BulkResult>

Trait Implementations

impl Clone for BulkExecutor

fn clone(&self) -> BulkExecutor

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.