openai4s/telemetry/gate.py

• transmitting · function · L61-L69 — def transmitting() -> Iterator[None]
• revoking · function · L73-L83 — def revoking() -> Iterator[None]
• submit · function · L86-L100 — def submit(store: Any, payload: Any) -> bool
• discard_pending · function · L103-L114 — def discard_pending() -> int
• pending · function · L117-L118 — def pending() -> int
• dropped · function · L121-L123 — def dropped() -> int
• wait_idle · function · L126-L131 — def wait_idle(timeout: float = 5.0) -> bool
• _ensure_worker · function · L134-L142 — def _ensure_worker() -> None
• _worker_loop · function · L145-L167 — def _worker_loop() -> None
• pause_worker · function · L170-L182 — def pause_worker(timeout: float = 5.0) -> None
• resume_worker · function · L185-L187 — def resume_worker() -> None
• _reset_for_tests · function · L190-L195 — def _reset_for_tests() -> None