isagellm-control-plane 0.1.0

sageLLM Control Plane - Intelligent request routing, scheduling, and engine lifecycle management

sageLLM Control Plane

Intelligent request routing, scheduling, and engine lifecycle management for sageLLM.

Features

• 🎯 Scheduling Policies - FIFO, Priority, SLO-aware, Cost-optimized, Adaptive
• ⚖️ Load Balancing - Intelligent request routing across multiple engine instances
• 📈 Autoscaling - SLA-based autoscaling for Prefill/Decode instances
• 🔄 Engine Lifecycle - Spawn, stop, health check, auto-restart
• 📊 Observability - Metrics collection, performance monitoring
• 🧩 Parallelism - TP, PP, DP, EP strategy optimization

Installation

pip install isagellm-control-plane

# With GPU monitoring
pip install isagellm-control-plane[gpu]

# With Prometheus metrics
pip install isagellm-control-plane[metrics]

Quick Start

from sagellm_control import ControlPlaneManager

# Create manager with mock mode (no GPU required)
manager = ControlPlaneManager(
    scheduling_policy="adaptive",
    routing_strategy="load_balanced",
    mode="local",  # Use local async executor
)

# Register a mock engine
manager.register_engine(
    engine_id="engine-001",
    model_id="mock-model",
    host="localhost",
    port=8000,
)

# Schedule a request
decision = await manager.schedule_request(
    request_id="req-001",
    prompt="Hello, world!",
    max_tokens=128,
)

print(f"Scheduled to: {decision.instance_id}")

Architecture

sagellm_control/
├── types.py           # Core data types (RequestMetadata, EngineInfo, etc.)
├── strategies/        # Scheduling policies (FIFO, Priority, SLO, etc.)
├── executors/         # Execution coordinators (HTTP, LocalAsync, Mock)
├── router.py          # Request routing and load balancing
├── autoscaler.py      # SLA-based autoscaling
├── parallelism.py     # Parallelism strategy optimization
├── manager.py         # Main ControlPlaneManager
└── engine_lifecycle.py # Engine lifecycle management

Mock-First Development

All modules support mock mode for testing without GPU:

from sagellm_control.executors import MockExecutionCoordinator

# Use mock executor for CI/CD
executor = MockExecutionCoordinator()
result = await executor.execute(request)

License

Proprietary - IntelliStream