orchestrata_ultimate.kernel.performance

Reference › orchestrata_ultimate › kernel › performance › init

The initialiser of the performance package. It was created when the single performance_manager module was decomposed, and it re-exports the public names of manager, metrics, resources, cluster, scaling, sla, chaos and _common. The shim performance_manager imports from here.

At a glance

Class diagram

No classes; see Functions.

Dependency diagram

API

No public API: the module defines no classes, functions or constants.

Source

Permalink: https://gitlab.com/MSamy/orchestrata-ultimate-architecture/-/blob/a4cbc2bdf/src/orchestrata_ultimate/kernel/performance/__init__.py

# mypy: ignore-errors
"""Performance and scalability subsystem (decomposed from performance_manager)."""

from orchestrata_ultimate.kernel.performance._common import (
    AUTOSCALER_DECISIONS_HISTORY_SIZE,
    AUTOSCALER_DEFAULT_COOLDOWN_SECONDS,
    AUTOSCALER_DEFAULT_MAX_INSTANCES,
    AUTOSCALER_DEFAULT_SCALE_DOWN_THRESHOLD,
    AUTOSCALER_DEFAULT_SCALE_UP_THRESHOLD,
    AUTOSCALER_RECENT_DECISIONS_DEFAULT_COUNT,
    BACKPRESSURE_CRITICAL_THRESHOLD,
    BACKPRESSURE_SHEDDING_THRESHOLD,
    BACKPRESSURE_WARNING_THRESHOLD,
    BATCH_PROCESSOR_DEFAULT_MAX_SIZE,
    BATCH_PROCESSOR_DEFAULT_MAX_WAIT_MS,
    CACHE_DEFAULT_MAX_SIZE,
    CACHE_DEFAULT_TTL_SECONDS,
    CLUSTER_DEFAULT_HEARTBEAT_INTERVAL_SECONDS,
    CONNECTION_POOL_DEFAULT_MAX_IDLE_SECONDS,
    CONNECTION_POOL_DEFAULT_MAX_SIZE,
    CONSISTENT_HASH_DEFAULT_REPLICAS,
    LATENCY_TRACKER_MAX_SAMPLES,
    T,
    _logger,
    _utc_now,
)
from orchestrata_ultimate.kernel.performance.chaos import ChaosController
from orchestrata_ultimate.kernel.performance.cluster import (
    ClusterManager,
    ConsistentHash,
    LeaderElection,
    NodeHealth,
)
from orchestrata_ultimate.kernel.performance.manager import PerformanceManager
from orchestrata_ultimate.kernel.performance.metrics import (
    LatencyMeasurement,
    LatencyTracker,
    MemoryTracker,
    ThroughputTracker,
    UptimeTracker,
)
from orchestrata_ultimate.kernel.performance.resources import (
    BackpressureController,
    BatchProcessor,
    ConnectionPool,
    LRUCache,
    RingBuffer,
)
from orchestrata_ultimate.kernel.performance.scaling import AutoScaler, ScalingDecision
from orchestrata_ultimate.kernel.performance.sla import (
    DEFAULT_SLA_THRESHOLDS,
    SLATarget,
    SLAThreshold,
)

__all__ = [
    "AUTOSCALER_DECISIONS_HISTORY_SIZE",
    "AUTOSCALER_DEFAULT_COOLDOWN_SECONDS",
    "AUTOSCALER_DEFAULT_MAX_INSTANCES",
    "AUTOSCALER_DEFAULT_SCALE_DOWN_THRESHOLD",
    "AUTOSCALER_DEFAULT_SCALE_UP_THRESHOLD",
    "AUTOSCALER_RECENT_DECISIONS_DEFAULT_COUNT",
    "AutoScaler",
    "BACKPRESSURE_CRITICAL_THRESHOLD",
    "BACKPRESSURE_SHEDDING_THRESHOLD",
    "BACKPRESSURE_WARNING_THRESHOLD",
    "BATCH_PROCESSOR_DEFAULT_MAX_SIZE",
    "BATCH_PROCESSOR_DEFAULT_MAX_WAIT_MS",
    "BackpressureController",
    "BatchProcessor",
    "CACHE_DEFAULT_MAX_SIZE",
    "CACHE_DEFAULT_TTL_SECONDS",
    "CLUSTER_DEFAULT_HEARTBEAT_INTERVAL_SECONDS",
    "CONNECTION_POOL_DEFAULT_MAX_IDLE_SECONDS",
    "CONNECTION_POOL_DEFAULT_MAX_SIZE",
    "CONSISTENT_HASH_DEFAULT_REPLICAS",
    "ChaosController",
    "ClusterManager",
    "ConnectionPool",
    "ConsistentHash",
    "DEFAULT_SLA_THRESHOLDS",
    "LATENCY_TRACKER_MAX_SAMPLES",
    "LRUCache",
    "LatencyMeasurement",
    "LatencyTracker",
    "LeaderElection",
    "MemoryTracker",
    "NodeHealth",
    "PerformanceManager",
    "RingBuffer",
    "SLATarget",
    "SLAThreshold",
    "ScalingDecision",
    "T",
    "ThroughputTracker",
    "UptimeTracker",
    "_logger",
    "_utc_now",
]