Struct ProcessingEvent

pub struct ProcessingEvent {
    pub timestamp: SystemTime,
    pub shard_id: String,
    pub event_type: ProcessingEventType,
}

Represents a monitoring event from the Kinesis processor

Fields

timestamp: SystemTime

When the event occurred

shard_id: String

ID of the shard this event relates to

event_type: ProcessingEventType

The type of event and its details

Implementations

impl ProcessingEvent

pub fn batch_complete( shard_id: String, successful_count: usize, failed_count: usize, duration: Duration, ) -> Self

pub fn batch_start(shard_id: String) -> Self

pub fn batch_metrics(shard_id: String, metrics: BatchMetrics) -> Self

pub fn batch_error(shard_id: String, error: String, duration: Duration) -> Self

pub fn record_success( shard_id: String, sequence_number: String, checkpoint_success: bool, ) -> Self

pub fn record_failure( shard_id: String, sequence_number: String, error: String, ) -> Self

pub fn checkpoint_failure( shard_id: String, sequence_number: String, error: String, ) -> Self

pub fn record_attempt( shard_id: String, sequence_number: String, success: bool, attempt_number: u32, duration: Duration, error: Option<String>, is_final_attempt: bool, ) -> Self

Create a new record processing event

pub fn shard_event( shard_id: String, event_type: ShardEventType, details: Option<String>, ) -> Self

Create a new shard event

pub fn checkpoint( shard_id: String, sequence_number: String, success: bool, error: Option<String>, ) -> Self

Create a new checkpoint event

pub fn iterator( shard_id: String, event_type: IteratorEventType, error: Option<String>, ) -> Self

Create a new iterator event

Trait Implementations

impl Clone for ProcessingEvent

fn clone(&self) -> ProcessingEvent

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ProcessingEvent

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

Formats the value using the given formatter.