OXIESEC PANEL
- Current Dir:
/
/
opt
/
alt
/
python311
/
lib
/
python3.11
/
site-packages
/
elastic_transport
/
_node
Server IP: 2a02:4780:11:1594:0:ef5:22d7:a
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
05/14/2024 03:17:35 PM
rwxr-xr-x
📄
__init__.py
1.19 KB
05/14/2024 03:17:35 PM
rw-r--r--
📁
__pycache__
-
05/14/2024 03:17:35 PM
rwxr-xr-x
📄
_base.py
10.98 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_base_async.py
1.47 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_http_aiohttp.py
10.13 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_http_httpx.py
7.15 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_http_requests.py
9.79 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_http_urllib3.py
7.94 KB
05/14/2024 03:17:35 PM
rw-r--r--
📄
_urllib3_chain_certs.py
5.95 KB
05/14/2024 03:17:35 PM
rw-r--r--
Editing: _base_async.py
Close
# Licensed to Elasticsearch B.V. under one or more contributor # license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright # ownership. Elasticsearch B.V. licenses this file to you under # the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, # software distributed under the License is distributed on an # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. from typing import Optional, Union from .._models import HttpHeaders from ..client_utils import DEFAULT, DefaultType from ._base import BaseNode, NodeApiResponse class BaseAsyncNode(BaseNode): """Base class for Async HTTP node implementations""" async def perform_request( # type: ignore[override] self, method: str, target: str, body: Optional[bytes] = None, headers: Optional[HttpHeaders] = None, request_timeout: Union[DefaultType, Optional[float]] = DEFAULT, ) -> NodeApiResponse: raise NotImplementedError() # pragma: nocover async def close(self) -> None: # type: ignore[override] raise NotImplementedError() # pragma: nocover