1212"""
1313
1414from mistapi import APISession
15- from mistapi .websockets .__ws_client import _COMMON_WS_PARAMS_DOC , _MistWebsocket
15+ from mistapi .websockets .__ws_client import _MistWebsocket
1616
1717
1818class InsightsEvents (_MistWebsocket ):
19- f """WebSocket stream for organization insights events.
19+ """WebSocket stream for organization insights events.
2020
2121 Subscribes to the ``orgs/{org_id}/insights/summary`` channel and delivers
2222 real-time insights events for the given organization.
@@ -27,7 +27,21 @@ class InsightsEvents(_MistWebsocket):
2727 Authenticated API session.
2828 org_id : str
2929 UUID of the organization to stream events from.
30- { _COMMON_WS_PARAMS_DOC }
30+ ping_interval : int, default 30
31+ Interval in seconds to send WebSocket ping frames (keep-alive).
32+ ping_timeout : int, default 10
33+ Time in seconds to wait for a ping response before considering the connection dead.
34+ auto_reconnect : bool, default False
35+ Automatically reconnect on unexpected disconnections using exponential backoff.
36+ max_reconnect_attempts : int, default 5
37+ Maximum number of reconnect attempts before giving up.
38+ reconnect_backoff : float, default 2.0
39+ Base backoff delay in seconds. Doubles after each failed attempt.
40+ queue_maxsize : int, default 0
41+ Maximum number of messages buffered in the internal queue for the
42+ ``receive()`` generator. ``0`` means unbounded. When set,
43+ incoming messages are dropped with a warning when the queue is
44+ full, preventing memory growth on high-frequency streams.
3145
3246 EXAMPLE
3347 -----------
@@ -78,7 +92,7 @@ def __init__(
7892
7993
8094class MxEdgesStatsEvents (_MistWebsocket ):
81- f """WebSocket stream for organization MX edges stats events.
95+ """WebSocket stream for organization MX edges stats events.
8296
8397 Subscribes to the ``orgs/{org_id}/stats/mxedges`` channel and delivers
8498 real-time MX edges stats events for the given organization.
@@ -89,7 +103,21 @@ class MxEdgesStatsEvents(_MistWebsocket):
89103 Authenticated API session.
90104 org_id : str
91105 UUID of the organization to stream events from.
92- { _COMMON_WS_PARAMS_DOC }
106+ ping_interval : int, default 30
107+ Interval in seconds to send WebSocket ping frames (keep-alive).
108+ ping_timeout : int, default 10
109+ Time in seconds to wait for a ping response before considering the connection dead.
110+ auto_reconnect : bool, default False
111+ Automatically reconnect on unexpected disconnections using exponential backoff.
112+ max_reconnect_attempts : int, default 5
113+ Maximum number of reconnect attempts before giving up.
114+ reconnect_backoff : float, default 2.0
115+ Base backoff delay in seconds. Doubles after each failed attempt.
116+ queue_maxsize : int, default 0
117+ Maximum number of messages buffered in the internal queue for the
118+ ``receive()`` generator. ``0`` means unbounded. When set,
119+ incoming messages are dropped with a warning when the queue is
120+ full, preventing memory growth on high-frequency streams.
93121
94122 EXAMPLE
95123 -----------
@@ -140,7 +168,7 @@ def __init__(
140168
141169
142170class MxEdgesEvents (_MistWebsocket ):
143- f """WebSocket stream for org MX edges events.
171+ """WebSocket stream for org MX edges events.
144172
145173 Subscribes to the ``orgs/{org_id}/mxedges`` channel and delivers
146174 real-time MX edges events for the given org.
@@ -151,7 +179,21 @@ class MxEdgesEvents(_MistWebsocket):
151179 Authenticated API session.
152180 org_id : str
153181 UUID of the org to stream events from.
154- { _COMMON_WS_PARAMS_DOC }
182+ ping_interval : int, default 30
183+ Interval in seconds to send WebSocket ping frames (keep-alive).
184+ ping_timeout : int, default 10
185+ Time in seconds to wait for a ping response before considering the connection dead.
186+ auto_reconnect : bool, default False
187+ Automatically reconnect on unexpected disconnections using exponential backoff.
188+ max_reconnect_attempts : int, default 5
189+ Maximum number of reconnect attempts before giving up.
190+ reconnect_backoff : float, default 2.0
191+ Base backoff delay in seconds. Doubles after each failed attempt.
192+ queue_maxsize : int, default 0
193+ Maximum number of messages buffered in the internal queue for the
194+ ``receive()`` generator. ``0`` means unbounded. When set,
195+ incoming messages are dropped with a warning when the queue is
196+ full, preventing memory growth on high-frequency streams.
155197
156198 EXAMPLE
157199 -----------
0 commit comments