proxy.core.work.task package

Submodules

• proxy.core.work.task.handler module
  • proxy.py
• proxy.core.work.task.local module
  • proxy.py
• proxy.core.work.task.remote module
  • proxy.py
• proxy.core.work.task.task module
  • proxy.py

Module contents

proxy.py

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

copyright

3. 2013-present by Abhinav Singh and contributors.

license

BSD, see LICENSE for more details.

class proxy.core.work.task.LocalTaskExecutor(*args: Any, **kwargs: Any)

Bases: proxy.core.work.local.BaseLocalExecutor

We’ll define a local executor which is capable of receiving log lines over a non blocking queue.

_abc_impl = <_abc._abc_data object>

work(*args: Any) → None

class proxy.core.work.task.RemoteTaskExecutor(*args: Any, **kwargs: Any)

Bases: proxy.core.work.remote.BaseRemoteExecutor

_abc_impl = <_abc._abc_data object>

work(*args: Any) → None

class proxy.core.work.task.SingleProcessTaskExecutor(**kwargs: Any)

Bases: multiprocessing.context.Process

run() → None

Method to be run in sub-process; can be overridden in sub-class

class proxy.core.work.task.Task(payload: bytes)

Bases: object

Task object which known how to process the payload.

class proxy.core.work.task.TaskHandler(work: proxy.core.work.work.T, flags: argparse.Namespace, event_queue: Optional[proxy.core.event.queue.EventQueue] = None, uid: Optional[str] = None, upstream_conn_pool: Optional[UpstreamConnectionPool] = None)

Bases: proxy.core.work.work.Work[proxy.core.work.task.task.Task]

Task handler.

_abc_impl = <_abc._abc_data object>

static create(*args: Any) → proxy.core.work.task.task.Task

Work core doesn’t know how to create work objects for us. Example, for task module scenario, it doesn’t know how to create Task objects for us.

class proxy.core.work.task.ThreadedTaskExecutor(**kwargs: Any)

Bases: threading.Thread

run() → None

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.