18 lines
467 B
Python
18 lines
467 B
Python
from __future__ import annotations
|
|
|
|
from fastapi import APIRouter
|
|
|
|
from app.streaming.binance_hub import hub as binance_hub
|
|
from app.streaming.alpha_hub import alpha_hub
|
|
|
|
router = APIRouter(prefix="/admin", tags=["Admin"])
|
|
|
|
|
|
@router.get("/streams")
|
|
async def streams_status():
|
|
"""Return current streaming hubs status (Binance and Alpha Vantage)."""
|
|
return {
|
|
"binance": binance_hub.get_status(),
|
|
"alpha_vantage": alpha_hub.get_status(),
|
|
}
|