kubernetes.aio.watch.watch_test module

class kubernetes.aio.watch.watch_test.WatchTest(methodName='runTest')

Bases: IsolatedAsyncioTestCase

async test_unmarshal_bookmark_succeeds_and_preserves_resource_version()

async test_unmarshal_job_bookmark_succeeds_and_preserves_resource_version()

async test_unmarshal_with_custom_object()

async test_unmarshal_with_empty_return_type()

async test_unmarshal_with_float_object()

async test_unmarshal_without_return_type()

async test_unmarshall_job_bookmark_malformed_object_fails()

async test_unmarshall_k8s_error_response()

Never parse messages of type ERROR.

This test uses an actually recorded error, in this case for an outdated resource version.

async test_unmarshall_k8s_error_response_401_gke()

Never parse messages of type ERROR.

This test uses an actually recorded error returned by GKE.

async test_watch_for_follow()

async test_watch_k8s_empty_response()

Stop the iterator when the response is empty.

This typically happens when the user supplied timeout expires.

async test_watch_retry_410()

async test_watch_retry_timeout()

async test_watch_timeout_with_resource_version()

async test_watch_with_decode()

async test_watch_with_exception()