Loading src/telemetry/backend/service/collectors/gnmi_oc/SubscriptionNew.py +2 −2 Viewed Changes for src/telemetry/backend/service/collectors/gnmi_oc/SubscriptionNew.py: 2 added lines, 2 removed lines. Original line number Diff line number Diff line Loading @@ -41,7 +41,7 @@ class Subscription: metric_queue: Queue, mode: str = "stream", sample_interval_ns: int = 10_000_000_000, heartbeat_interval_ns: int | None = None, # ← NEW heartbeat_interval_ns: Optional[int] = None, # ← NEW encoding: str = "json_ietf", on_update: Optional[Callable[[dict], None]] = None, ) -> None: Loading Loading @@ -82,7 +82,7 @@ class Subscription: path_list: List[str], mode: str, sample_interval_ns: int, heartbeat_interval_ns: int | None, heartbeat_interval_ns: Optional[int], encoding: str, on_update: Optional[Callable[[dict], None]], ) -> None: # pragma: no cover Loading src/telemetry/backend/collectors/intcollector/INTCollector.py→src/telemetry/backend/service/collectors/intcollector/INTCollector.py +1 −1 Viewed Changes for src/telemetry/backend/service/collectors/intcollector/INTCollector.py: 1 added line, 1 removed line. Original line number Diff line number Diff line Loading @@ -20,7 +20,7 @@ from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.jobstores.memory import MemoryJobStore from apscheduler.executors.pool import ThreadPoolExecutor from datetime import datetime from telemetry.backend.collector_api._Collector import _Collector from telemetry.backend.service.collector_api._Collector import _Collector from scapy.all import * import struct Loading src/telemetry/backend/collectors/intcollector/INTCollectorCommon.py→src/telemetry/backend/service/collectors/intcollector/INTCollectorCommon.py +0 −0 Viewed File moved. View file src/telemetry/backend/collectors/intcollector/__init__.py→src/telemetry/backend/service/collectors/intcollector/__init__.py +0 −0 Viewed File moved. View file src/telemetry/backend/service/collectors/__init__.py +1 −2 Viewed Changes for src/telemetry/backend/service/collectors/__init__.py: 1 added line, 2 removed lines. Original line number Diff line number Diff line Loading @@ -49,7 +49,7 @@ if LOAD_ALL_DEVICE_DRIVERS: ) if LOAD_ALL_DEVICE_DRIVERS: from ...collectors.intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position from .intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position COLLECTORS.append( (INTCollector, [ { Loading @@ -58,4 +58,3 @@ if LOAD_ALL_DEVICE_DRIVERS: } ]) ) Loading
src/telemetry/backend/service/collectors/gnmi_oc/SubscriptionNew.py +2 −2 Viewed Changes for src/telemetry/backend/service/collectors/gnmi_oc/SubscriptionNew.py: 2 added lines, 2 removed lines. Original line number Diff line number Diff line Loading @@ -41,7 +41,7 @@ class Subscription: metric_queue: Queue, mode: str = "stream", sample_interval_ns: int = 10_000_000_000, heartbeat_interval_ns: int | None = None, # ← NEW heartbeat_interval_ns: Optional[int] = None, # ← NEW encoding: str = "json_ietf", on_update: Optional[Callable[[dict], None]] = None, ) -> None: Loading Loading @@ -82,7 +82,7 @@ class Subscription: path_list: List[str], mode: str, sample_interval_ns: int, heartbeat_interval_ns: int | None, heartbeat_interval_ns: Optional[int], encoding: str, on_update: Optional[Callable[[dict], None]], ) -> None: # pragma: no cover Loading
src/telemetry/backend/collectors/intcollector/INTCollector.py→src/telemetry/backend/service/collectors/intcollector/INTCollector.py +1 −1 Viewed Changes for src/telemetry/backend/service/collectors/intcollector/INTCollector.py: 1 added line, 1 removed line. Original line number Diff line number Diff line Loading @@ -20,7 +20,7 @@ from apscheduler.schedulers.background import BackgroundScheduler from apscheduler.jobstores.memory import MemoryJobStore from apscheduler.executors.pool import ThreadPoolExecutor from datetime import datetime from telemetry.backend.collector_api._Collector import _Collector from telemetry.backend.service.collector_api._Collector import _Collector from scapy.all import * import struct Loading
src/telemetry/backend/collectors/intcollector/INTCollectorCommon.py→src/telemetry/backend/service/collectors/intcollector/INTCollectorCommon.py +0 −0 Viewed File moved. View file
src/telemetry/backend/collectors/intcollector/__init__.py→src/telemetry/backend/service/collectors/intcollector/__init__.py +0 −0 Viewed File moved. View file
src/telemetry/backend/service/collectors/__init__.py +1 −2 Viewed Changes for src/telemetry/backend/service/collectors/__init__.py: 1 added line, 2 removed lines. Original line number Diff line number Diff line Loading @@ -49,7 +49,7 @@ if LOAD_ALL_DEVICE_DRIVERS: ) if LOAD_ALL_DEVICE_DRIVERS: from ...collectors.intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position from .intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position COLLECTORS.append( (INTCollector, [ { Loading @@ -58,4 +58,3 @@ if LOAD_ALL_DEVICE_DRIVERS: } ]) )