o i @sddlZddlmZmZddlmZddlmZmZm Z m Z ddl m Z m Z dZdZhdZGd d d eZGd d d eZdS) N)ABCabstractmethod)ThreadPoolExecutor)AnyMappingOptionalUnion) HttpClient HttpResponsez)HttpClient/1.0 (+https://example.invalid)g>@>c@seZdZe    ddedeeeedeee e e e ffdeeeefdee de dee eff d d Ze    ddedeeeedeee e e e ffdeeeefdee de dee eff d d Ze      dded eedeeeefdeeeedeee e e e ffdeeeefdee de dee effddZe      dded eedeeeefdeeeedeee e e e ffdeeeefdee de dee effddZe      dded eedeeeefdeeeedeee e e e ffdeeeefdee de dee effddZe    ddededeeeedeee e e e ffdeeeefdeeeefdee de fddZdS)AsyncHTTPClientNTpathparamsheaderstimeout expect_jsonreturncdS)z! Invoke HTTP GET request.NselfrrrrrrrR/home/ubuntu/.local/lib/python3.10/site-packages/redis/asyncio/http/http_client.pyget zAsyncHTTPClient.getcr)z$ Invoke HTTP DELETE request.NrrrrrdeleterzAsyncHTTPClient.delete json_bodydatacr)z" Invoke HTTP POST request.Nrrrrr rrrrrrrpost,zAsyncHTTPClient.postcr)z! Invoke HTTP PUT request.Nrr!rrrput=r#zAsyncHTTPClient.putcr)z# Invoke HTTP PATCH request.Nrr!rrrpatchNr#zAsyncHTTPClient.patchmethodbodycr)z/ Invoke HTTP request with given method.Nr)rr&rrrr'rrrrrequest_szAsyncHTTPClient.requestNNNTNNNNNTNNNN)__name__ __module__ __qualname__rstrrrrintfloatboollisttupler rrrbytesr"r$r%r(rrrrr s             rc@seZdZdZddededdfddZ    d d ed ee ee deee e e effd ee eefd ee de de eeff ddZ    d d ed ee ee deee e e effd ee eefd ee de de eeff ddZ      d!d edeedee eefd ee ee deee e e effd ee eefd ee de de eeffddZ      d!d edeedee eefd ee ee deee e e effd ee eefd ee de de eeffddZ      d!d edeedee eefd ee ee deee e e effd ee eefd ee de de eeffddZ    d"ded ed ee ee deee e e effd ee eefdee eefd ee defddZdS)#AsyncHTTPClientWrapperzN An async wrapper around sync HTTP client with thread pool execution. client max_workersrNcCs||_t|d|_dS)a Initialize a new HTTP client instance. Args: client: Sync HTTP client instance. max_workers: Maximum number of concurrent requests. The client supports both regular HTTPS with server verification and mutual TLS authentication. For server verification, provide CA certificate information via ca_file, ca_path or ca_data. For mutual TLS, additionally provide a client certificate and key via client_cert_file and client_key_file. )r9N)r8r _executor)rr8r9rrr__init__us zAsyncHTTPClientWrapper.__init__Trrrrrc ,t}||j|jj|||||IdHSN)asyncioget_event_looprun_in_executorr:r8rrrrrrrlooprrrrs   zAsyncHTTPClientWrapper.getc r<r=)r>r?r@r:r8rrArrrrs  zAsyncHTTPClientWrapper.deleterr c 0t}||j|jj||||||| IdHSr=)r>r?r@r:r8r" rrrr rrrrrBrrrr"  zAsyncHTTPClientWrapper.postc rCr=)r>r?r@r:r8r$rDrrrr$rEzAsyncHTTPClientWrapper.putc rCr=)r>r?r@r:r8r%rDrrrr%rEzAsyncHTTPClientWrapper.patchr&r'c s.t}||j|jj||||||IdHSr=)r>r?r@r:r8r()rr&rrrr'rrBrrrr(s  zAsyncHTTPClientWrapper.request)r7r)r*r+)r,r-r.__doc__r r0r;r/rrrr1r2r3r4r rrrr5r"r$r%r(rrrrr6ps             r6)r>abcrrconcurrent.futuresrtypingrrrrredis.http.http_clientr r DEFAULT_USER_AGENTDEFAULT_TIMEOUTRETRY_STATUS_CODESrr6rrrrs c