Struct EventProcessor 

pub struct EventProcessor { /* private fields */ }

Processes and generates history events for execution tracking.

Implementations

impl EventProcessor

pub fn new() -> Self

Create a new event processor.

pub fn format_timestamp(timestamp: DateTime<Utc>) -> String

Format a timestamp as ISO 8601 string with millisecond precision in UTC.

Arguments

• timestamp - The DateTime to format

Returns

A string in the format “2025-12-03T22:58:35.094Z”

pub fn current_timestamp() -> String

Get the current timestamp formatted as ISO 8601 string.

pub fn create_nodejs_event( &mut self, event_type: NodeJsEventType, operation: Option<&Operation>, details: NodeJsEventDetails, ) -> NodeJsHistoryEvent

Create a Node.js-compatible history event.

This method generates events with sequential EventId starting from 1, matching the Node.js SDK’s event format.

Arguments

• event_type - The type of event (e.g., ExecutionStarted, StepSucceeded)
• operation - Optional operation this event relates to
• details - Event-specific details

Returns

The created Node.js-compatible history event.

pub fn process_operation_update( &mut self, update: &OperationUpdate, operation: &Operation, ) -> Vec<NodeJsHistoryEvent>

Process an operation update and generate appropriate Node.js-compatible events.

This method maps (OperationAction, OperationType) combinations to the appropriate NodeJsEventType according to the design specification:

Action	Type	EventType
Start	Execution	ExecutionStarted
Succeed	Execution	ExecutionSucceeded
Fail	Execution	ExecutionFailed
Start	Step	StepStarted
Succeed	Step	StepSucceeded
Fail	Step	StepFailed
Start	Wait	WaitStarted
Succeed	Wait	WaitSucceeded
Start	Callback	CallbackStarted
Start	Context	ContextStarted
Succeed	Context	ContextSucceeded
Fail	Context	ContextFailed

Arguments

• update - The operation update containing action and type
• operation - The operation being updated

Returns

A vector of generated Node.js-compatible history events.

pub fn get_nodejs_events(&self) -> &[NodeJsHistoryEvent]

Get all Node.js-compatible events.

pub fn into_nodejs_events(self) -> Vec<NodeJsHistoryEvent>

Get Node.js-compatible events as owned vector.

pub fn nodejs_event_count(&self) -> u64

Get the current Node.js event count.

pub fn clear_nodejs_events(&mut self)

Clear all Node.js-compatible events.

pub fn create_history_event<T: Serialize>( &mut self, event_type: EventType, operation_id: Option<&str>, details_type: &str, details: T, ) -> HistoryEvent

Create a history event.

Arguments

• event_type - The type of event
• operation_id - Optional operation ID this event relates to
• details_type - The details type name
• details - The event details (will be serialized to JSON)

Returns

The created history event.

pub fn get_events(&self) -> &[HistoryEvent]

Get all events.

pub fn into_events(self) -> Vec<HistoryEvent>

Get events as owned vector.

pub fn clear(&mut self)

Clear all events.

pub fn event_count(&self) -> u64

Get the current event count.

Trait Implementations

impl Debug for EventProcessor

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

Formats the value using the given formatter.

impl Default for EventProcessor

fn default() -> EventProcessor

Returns the “default value” for a type.