kubernetes_asyncio.stream package

Submodules

• kubernetes_asyncio.stream.ws_client module
  • WsApiClient
    • WsApiClient.parse_error_data()
    • WsApiClient.request()
  • WsResponse
    • WsResponse.getheader()
    • WsResponse.getheaders()
  • get_websocket_url()
• kubernetes_asyncio.stream.ws_client_test module
  • WSClientTest
    • WSClientTest.test_exec_ws()
    • WSClientTest.test_exec_ws_with_heartbeat()
    • WSClientTest.test_parse_error_data_failure()
    • WSClientTest.test_parse_error_data_success()
    • WSClientTest.test_websocket_client()
  • WsMock

Module contents

class kubernetes_asyncio.stream.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.