Trixy7/trixy_core/events/__init__.py

# -*- coding: utf-8 -*-
"""
Trixy Event-System.

Stellt ein zentrales Pub/Sub-System für Events bereit.
"""

from trixy_core.events.enums import EventPriority
from trixy_core.events.decorators import TrixyEvent, event_handler
from trixy_core.events.eventmanager import EventManager

# Middleware
from trixy_core.events.middleware import (
    EventMiddleware,
    MiddlewarePipeline,
    MiddlewareContext,
    MiddlewareResult,
    LoggingMiddleware,
    TimingMiddleware,
    ValidationMiddleware,
)

# Throttling
from trixy_core.events.throttling import (
    EventThrottler,
    ThrottleConfig,
    EventDebouncer,
    DebounceConfig,
)

# Persistence
from trixy_core.events.persistence import (
    EventStore,
    StoredEvent,
    InMemoryEventStore,
    FileEventStore,
    EventReplayer,
)

# DLQ
from trixy_core.events.dlq import (
    DeadLetterQueue,
    DeadLetterEntry,
    RetryStrategy,
    ExponentialBackoffStrategy,
)

# Filtering & Batching
from trixy_core.events.filtering import (
    EventFilter,
    FilterCondition,
    EventNameCondition,
)
from trixy_core.events.batching import (
    EventBatcher,
    BatchConfig,
    KeyedBatcher,
)

# Async Queue
from trixy_core.events.async_queue import (
    AsyncEventQueue,
    QueueConfig,
    WorkerPool,
    WorkerConfig,
)

__all__ = [
    # Core
    "EventPriority",
    "TrixyEvent",
    "event_handler",
    "EventManager",
    # Middleware
    "EventMiddleware",
    "MiddlewarePipeline",
    "MiddlewareContext",
    "MiddlewareResult",
    "LoggingMiddleware",
    "TimingMiddleware",
    "ValidationMiddleware",
    # Throttling
    "EventThrottler",
    "ThrottleConfig",
    "EventDebouncer",
    "DebounceConfig",
    # Persistence
    "EventStore",
    "StoredEvent",
    "InMemoryEventStore",
    "FileEventStore",
    "EventReplayer",
    # DLQ
    "DeadLetterQueue",
    "DeadLetterEntry",
    "RetryStrategy",
    "ExponentialBackoffStrategy",
    # Filtering & Batching
    "EventFilter",
    "FilterCondition",
    "EventNameCondition",
    "EventBatcher",
    "BatchConfig",
    "KeyedBatcher",
    # Async Queue
    "AsyncEventQueue",
    "QueueConfig",
    "WorkerPool",
    "WorkerConfig",
]