Struct EscalatingScrapingService 

pub struct EscalatingScrapingService { /* private fields */ }

A ScrapingService that tries multiple tiers in sequence, escalating from lightweight HTTP to a full stealth browser when anti-bot protections are detected.

Register it in the pipeline service registry under "http_escalating" so that pipeline nodes can use "service": "http_escalating" in their config.

Tier services are added via with_tier. If a tier has no service configured the next available higher tier is used automatically.

Example

use std::sync::Arc;
use stygian_graph::adapters::escalation::{
    DefaultEscalationPolicy, EscalationConfig, EscalatingScrapingService,
};
use stygian_graph::adapters::http::HttpAdapter;
use stygian_graph::ports::escalation::EscalationTier;

let policy = DefaultEscalationPolicy::new(EscalationConfig::default());
let svc = EscalatingScrapingService::new(policy)
    .with_tier(EscalationTier::HttpPlain, Arc::new(HttpAdapter::new()));

Implementations

impl EscalatingScrapingService

pub fn new(policy: DefaultEscalationPolicy) -> Self

Create an escalating service with no tier services registered.

Use with_tier to register a service for each tier.

pub fn with_tier( self, tier: EscalationTier, service: Arc<dyn ScrapingService>, ) -> Self

Register a concrete service for an escalation tier (builder style).

Trait Implementations

impl ScrapingService for EscalatingScrapingService

fn execute<'life0, 'async_trait>( &'life0 self, input: ServiceInput, ) -> Pin<Box<dyn Future<Output = Result<ServiceOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the scraping operation

fn name(&self) -> &'static str

Service name for identification in logs and metrics