Enum MapReduceEvent 

pub enum MapReduceEvent {
    MapPhaseStarted {
        total_items: usize,
        timestamp: DateTime<Utc>,
    },
    MapPhaseCompleted {
        successful: usize,
        failed: usize,
        timestamp: DateTime<Utc>,
    },
    AgentStarted {
        agent_id: String,
        item_id: String,
        timestamp: DateTime<Utc>,
    },
    AgentCompleted {
        agent_id: String,
        item_id: String,
        duration: Duration,
        timestamp: DateTime<Utc>,
        cleanup_status: Option<CleanupStatus>,
        commits: Vec<String>,
        json_log_location: Option<String>,
    },
    AgentFailed {
        agent_id: String,
        item_id: String,
        error: String,
        timestamp: DateTime<Utc>,
        failure_reason: FailureReason,
        json_log_location: Option<String>,
    },
    ReducePhaseStarted {
        timestamp: DateTime<Utc>,
    },
    ReducePhaseCompleted {
        timestamp: DateTime<Utc>,
    },
}

MapReduce execution events

Variants

MapPhaseStarted

Map phase started

Fields

total_items: usize

timestamp: DateTime<Utc>

MapPhaseCompleted

Map phase completed

Fields

successful: usize

failed: usize

timestamp: DateTime<Utc>

AgentStarted

Agent started processing an item

Fields

agent_id: String

item_id: String

timestamp: DateTime<Utc>

AgentCompleted

Agent completed processing

Fields

agent_id: String

item_id: String

duration: Duration

timestamp: DateTime<Utc>

cleanup_status: Option<CleanupStatus>

commits: Vec<String>

json_log_location: Option<String>

AgentFailed

Agent failed processing

Fields

agent_id: String

item_id: String

error: String

timestamp: DateTime<Utc>

failure_reason: FailureReason

json_log_location: Option<String>

ReducePhaseStarted

Reduce phase started

Fields

timestamp: DateTime<Utc>

ReducePhaseCompleted

Reduce phase completed

Fields

timestamp: DateTime<Utc>

Implementations

impl MapReduceEvent

pub fn map_phase_started(total_items: usize) -> Self

Create map phase started event

pub fn map_phase_completed(successful: usize, failed: usize) -> Self

Create map phase completed event

pub fn agent_started(agent_id: String, item_id: String) -> Self

Create agent started event

pub fn agent_completed( agent_id: String, item_id: String, duration: Duration, cleanup_status: Option<CleanupStatus>, commits: Vec<String>, json_log_location: Option<String>, ) -> Self

Create agent completed event

pub fn agent_failed( agent_id: String, item_id: String, error: String, failure_reason: FailureReason, json_log_location: Option<String>, ) -> Self

Create agent failed event

pub fn reduce_phase_started() -> Self

Create reduce phase started event

pub fn reduce_phase_completed() -> Self

Create reduce phase completed event

Trait Implementations

impl Clone for MapReduceEvent

fn clone(&self) -> MapReduceEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MapReduceEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MapReduceEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MapReduceEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.