class xdk.streaming.StreamConfig
Configuración para conexiones de streaming con comportamiento de reintentos.
Parámetros
int
default:"10"
float
default:"1.0"
float
default:"64.0"
float
default:"2.0"
bool
default:"True"
float or None
default:"None"
int
default:"1024"
Callable[[], None] or None
default:"None"
Callable[[Exception or None], None] or None
default:"None"
Callable[[int, float], None] or None
default:"None"
Callable[[[StreamError
__init__
Parámetros
int
default:"10"
float
default:"1.0"
float
default:"64.0"
float
default:"2.0"
bool
default:"True"
float or None
default:"None"
int
default:"1024"
Callable[[], None] or None
default:"None"
Callable[[Exception or None], None] or None
default:"None"
Callable[[int, float], None] or None
default:"None"
Callable[[[StreamError
on_error : Callable[[[StreamError]
exception xdk.streaming.StreamError
Excepción lanzada para errores de streaming con clasificación.
Parámetros
str
StreamErrorType
__init__
Parámetros
str
StreamErrorType
class xdk.streaming.StreamErrorType
Clasificación de errores de streaming para decisiones de reintento.
Parámetros
Any
class xdk.streaming.StreamState
Estado interno de una conexión de streaming.
Parámetros
int
default:"0"
float
default:"1.0"
bool
default:"False"
int
default:"0"
StreamError
__init__
Parámetros
int
default:"0"
float
default:"1.0"
bool
default:"False"
int
default:"0"
StreamError
last_error : [StreamError]
xdk.streaming.stream_with_retry
Stream data from an endpoint with automatic reconnection and exponential backoff.
This function handles all connection management, including:
- Automatic reconnection on disconnects
- Exponential backoff with jitter for retry delays
- Classification of errors as retryable vs fatal
- Lifecycle callbacks for monitoring connection state
Parámetros
Session
The requests Session to use for HTTP calls.
str
HTTP method (typically “get”).
str
The full URL to stream from.
StreamConfig
StreamConfig with retry and callback settings.