tethys.core.transports.connectors.connector_local

Module Contents

class tethys.core.transports.connectors.connector_local.QueuesManager(address=None, authkey=None, serializer='pickle', ctx=None)[source]

Bases: multiprocessing.managers.BaseManager

Base class for managers

Initialize self. See help(type(self)) for accurate signature.

classmethod get_queue(cls, name)[source]
classmethod instance(cls)[source]
class tethys.core.transports.connectors.connector_local.LocalConnection(channel_id, recv_check_delay: float)[source]

Bases: tethys.core.transports.connectors.connector_base.ConnectionBase

Helper class that provides a standard way to create an ABC using inheritance.

Initialize self. See help(type(self)) for accurate signature.

property queue(self)[source]
recv_iter(self, **kwargs)[source]
send(self, data_packet, **kwargs)[source]
ack(self, message_key, **kwargs)[source]
open(self, **kwargs) → 'LocalConnection'[source]
close(self, **kwargs) → 'LocalConnection'[source]
class tethys.core.transports.connectors.connector_local.LocalConnector(recv_check_delay: float = 0.1)[source]

Bases: tethys.core.transports.connectors.connector_base.ConnectorBase

Initialize self. See help(type(self)) for accurate signature.

connect(self, channel_id: str, recv_check_delay: float = None, **kwargs) → 'LocalConnection'[source]