⚡⚡⚡ Fast, Lightweight, Pluggable, TLS interception capable proxy server focused on Network monitoring, controls & Application development, testing, debugging.

  1. 2013-present by Abhinav Singh and contributors.


BSD, see LICENSE for more details.

class*args: Any, **kwargs: Any)[source]#


A threadless executor implementation which receives work over a connection.

NOTE: RemoteExecutor uses recv_handle to accept file descriptors.

TODO: Refactor and abstract recv_handle part so that a threaded remote executor can also accept work over a connection. Currently, remote executors must be running in a process.

_abc_impl = <_abc._abc_data object>#
_loop: Optional[asyncio.AbstractEventLoop]#
_total: int#
_upstream_conn_filenos: Set[int]#
_upstream_conn_pool: Optional['UpstreamConnectionPool']#
cleanup_inactive_timeout: float#
close_work_queue() None[source]#

Only called if work_queue_fileno returns an integer. If an fd is select-able for work queue, make sure to close the work queue fd now.

property loop: Optional[]#
receive_from_work_queue() bool[source]#

Work queue is ready to receive new work.

Receive it and call work_on_tcp_conn.

Return True to tear down the loop.

registered_events_by_work_ids: Dict[int, SelectableEvents]#
selector: Optional[selectors.DefaultSelector]#
unfinished: Set['asyncio.Task[bool]']#
wait_timeout: float#
work_queue_fileno() Optional[int][source]#

If work queue must be selected before calling receive_from_work_queue then implementation must return work queue fd.

works: Dict[int, 'Work[Any]']#