router.py 4.94 KB
Newer Older
1
from typing import Dict, List, Optional
2
3
4
5
6
7
8
9
10
11

from sglang_router_rs import PolicyType
from sglang_router_rs import Router as _Router


class Router:
    """
    A high-performance router for distributing requests across worker nodes.

    Args:
12
13
        worker_urls: List of URLs for worker nodes that will handle requests. Each URL should include
            the protocol, host, and port (e.g., ['http://worker1:8000', 'http://worker2:8000'])
14
15
16
        policy: Load balancing policy to use. Options:
            - PolicyType.Random: Randomly select workers
            - PolicyType.RoundRobin: Distribute requests in round-robin fashion
17
            - PolicyType.CacheAware: Distribute requests based on cache state and load balance
18
19
        host: Host address to bind the router server. Default: '127.0.0.1'
        port: Port number to bind the router server. Default: 3001
20
        worker_startup_timeout_secs: Timeout in seconds for worker startup. Default: 300
21
        worker_startup_check_interval: Interval in seconds between checks for worker initialization. Default: 10
22
23
24
        cache_threshold: Cache threshold (0.0-1.0) for cache-aware routing. Routes to cached worker
            if the match rate exceeds threshold, otherwise routes to the worker with the smallest
            tree. Default: 0.5
25
26
27
28
        balance_abs_threshold: Load balancing is triggered when (max_load - min_load) > abs_threshold
            AND max_load > min_load * rel_threshold. Otherwise, use cache aware. Default: 32
        balance_rel_threshold: Load balancing is triggered when (max_load - min_load) > abs_threshold
            AND max_load > min_load * rel_threshold. Otherwise, use cache aware. Default: 1.0001
29
30
        eviction_interval_secs: Interval in seconds between cache eviction operations in cache-aware
            routing. Default: 60
31
        max_payload_size: Maximum payload size in bytes. Default: 4MB
32
        max_tree_size: Maximum size of the approximation tree for cache-aware routing. Default: 2^24
33
        verbose: Enable verbose logging. Default: False
34
        log_dir: Directory to store log files. If None, logs are only output to console. Default: None
35
36
37
38
39
40
41
42
        service_discovery: Enable Kubernetes service discovery. When enabled, the router will
            automatically discover worker pods based on the selector. Default: False
        selector: Dictionary mapping of label keys to values for Kubernetes pod selection.
            Example: {"app": "sglang-worker"}. Default: {}
        service_discovery_port: Port to use for service discovery. The router will generate
            worker URLs using this port. Default: 80
        service_discovery_namespace: Kubernetes namespace to watch for pods. If not provided,
            watches pods across all namespaces (requires cluster-wide permissions). Default: None
43
44
        prometheus_port: Port to expose Prometheus metrics. Default: None
        prometheus_host: Host address to bind the Prometheus metrics server. Default: None
45
46
47
48
49
50
51
52
    """

    def __init__(
        self,
        worker_urls: List[str],
        policy: PolicyType = PolicyType.RoundRobin,
        host: str = "127.0.0.1",
        port: int = 3001,
53
        worker_startup_timeout_secs: int = 300,
54
        worker_startup_check_interval: int = 10,
55
        cache_threshold: float = 0.50,
56
57
        balance_abs_threshold: int = 32,
        balance_rel_threshold: float = 1.0001,
58
59
        eviction_interval_secs: int = 60,
        max_tree_size: int = 2**24,
60
        max_payload_size: int = 4 * 1024 * 1024,  # 4MB
61
        verbose: bool = False,
62
        log_dir: Optional[str] = None,
63
64
65
66
        service_discovery: bool = False,
        selector: Dict[str, str] = None,
        service_discovery_port: int = 80,
        service_discovery_namespace: Optional[str] = None,
67
68
        prometheus_port: Optional[int] = None,
        prometheus_host: Optional[str] = None,
69
    ):
70
71
72
        if selector is None:
            selector = {}

73
74
75
76
77
        self._router = _Router(
            worker_urls=worker_urls,
            policy=policy,
            host=host,
            port=port,
78
            worker_startup_timeout_secs=worker_startup_timeout_secs,
79
            worker_startup_check_interval=worker_startup_check_interval,
80
            cache_threshold=cache_threshold,
81
82
            balance_abs_threshold=balance_abs_threshold,
            balance_rel_threshold=balance_rel_threshold,
83
84
            eviction_interval_secs=eviction_interval_secs,
            max_tree_size=max_tree_size,
85
            max_payload_size=max_payload_size,
86
            verbose=verbose,
87
            log_dir=log_dir,
88
89
90
91
            service_discovery=service_discovery,
            selector=selector,
            service_discovery_port=service_discovery_port,
            service_discovery_namespace=service_discovery_namespace,
92
93
            prometheus_port=prometheus_port,
            prometheus_host=prometheus_host,
94
95
96
97
98
99
100
101
        )

    def start(self) -> None:
        """Start the router server.

        This method blocks until the server is shut down.
        """
        self._router.start()