kubernetes_asyncio.stream.ws_client module

class kubernetes_asyncio.stream.ws_client.WsApiClient(configuration: Configuration | None = None, header_name: str | None = None, header_value: str | None = None, cookie: str | None = None, pool_threads: int = 1, heartbeat: float | None = None)

Bases: ApiClient

classmethod parse_error_data(error_data: str | bytes) → int

Parse data received on ERROR_CHANNEL and return the command exit code.

async request(method, url, query_params=None, headers=None, post_params=None, body=None, _preload_content=True, _request_timeout=None) → WsResponse | _BaseRequestContextManager[ClientWebSocketResponse]

Makes the HTTP request using RESTClient.

class kubernetes_asyncio.stream.ws_client.WsResponse(status, data)

Bases: RESTResponse

getheader(name: str, default: str | None = None) → str | None

Returns a given response header.

getheaders() → CIMultiDictProxy

Returns a CIMultiDictProxy of the response headers.

kubernetes_asyncio.stream.ws_client.get_websocket_url(url: str) → str