mocra 0.3.0

A distributed, event-driven crawling and data collection framework
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::engine::events::{EventEnvelope, EventPhase};
use log::{debug, error, warn};
use tokio::sync::mpsc::Receiver;

pub struct ConsoleLogHandler;

impl ConsoleLogHandler {
    pub async fn start(mut rx: Receiver<EventEnvelope>, _level: String) {
        tokio::spawn(async move {
            while let Some(event) = rx.recv().await {
                let event_key = event.event_key();
                let ts = event.timestamp_ms;
                match event.phase {
                    EventPhase::Failed => error!("Event: {} | Time: {}", event_key, ts),
                    EventPhase::Retry => warn!("Event: {} | Time: {}", event_key, ts),
                    _ => debug!("Event: {} | Time: {}", event_key, ts),
                }
            }
        });
    }
}