Module core 

Core event processing structures and traits

This module provides the fundamental types for event processing in the stream processor:

• ProcessorEvent: Wrapper around events with metadata
• EventKey: Different types of aggregation keys
• EventTimeExtractor: Trait for extracting event timestamps
• KeyExtractor: Trait for extracting aggregation keys

Structs

CloudEventKeyExtractor

Key extractor for CloudEvent based on source

CloudEventTimeExtractor

Default event time extractor for CloudEvent

FeedbackEventKeyExtractor

Key extractor for FeedbackEvent based on metadata

FeedbackEventTimeExtractor

Default event time extractor for FeedbackEvent

MetricPointKeyExtractor

Key extractor for MetricPoint based on tags

MetricPointTimeExtractor

Default event time extractor for MetricPoint

ProcessorEvent

Wrapper around events with metadata for stream processing

Enums

EventKey

Enum representing different types of aggregation keys

Traits

EventTimeExtractor

Trait for extracting event time from events

KeyExtractor

Trait for extracting aggregation keys from events