Distributed
1.0
▾ distributed
▸ actor
▸ asyncio
▸ batched
▸ bokeh
▸ cfexecutor
▸ cli
▸ client
▾ comm
▸ addressing
▾ core
class
Comm
class
CommClosedError
class
Connector
class
FatalCommClosedError
class
Listener
▸ inproc
▸ registry
▸ tcp
▸ tests
▸ ucx
▸ utils
▸ compatibility
▸ config
▸ core
▸ counter
▸ dashboard
▸ deploy
▸ diagnostics
▸ diskutils
▸ event
▸ http
▸ lock
▸ locket
▸ metrics
▸ nanny
▸ node
▸ preloading
▸ process
▸ proctitle
▸ profile
▸ protocol
▸ publish
▸ pubsub
▸ pytest_resourceleaks
▸ queues
▸ recreate_exceptions
▸ scheduler
▸ security
▸ semaphore
▸ sizeof
▸ stealing
▸ system
▸ system_monitor
▸ tests
▸ threadpoolexecutor
▸ utils
▸ utils_comm
▸ utils_perf
▸ utils_test
▸ variable
▸ versions
▸ worker
▸ worker_client
Class Listener
distributed
.
comm
.
core
.
Listener
Declaration
class
Listener(ABC)
source
link
Methods
▷
def
__await__
(
self
)
source
link
▶
def
contact_address
(
self
)
@abstractproperty
An address this listener can be contacted on. This can be different from `listen_address` if the latter is some wildcard address such as 'tcp://0.0.0.0:123'.
@abstractproperty
def
contact_address(
self
)
source
link
Overrides
This method is overriden in:
distributed
.
comm
.
tcp
.
BaseTCPListener
distributed
.
comm
.
inproc
.
InProcListener
distributed
.
comm
.
ucx
.
UCXListener
▶
def
listen_address
(
self
)
@abstractproperty
The listening address as a URI string.
@abstractproperty
def
listen_address(
self
)
source
link
Overrides
This method is overriden in:
distributed
.
comm
.
tcp
.
BaseTCPListener
distributed
.
comm
.
inproc
.
InProcListener
distributed
.
comm
.
ucx
.
UCXListener
▶
def
stop
(
self
)
@abstractmethod
Stop listening. This does not shutdown already established communications, but prevents accepting new ones.
@abstractmethod
def
stop(
self
)
source
link
Overrides
This method is overriden in:
distributed
.
comm
.
tcp
.
BaseTCPListener
distributed
.
comm
.
inproc
.
InProcListener
distributed
.
comm
.
ucx
.
UCXListener
Subclasses
distributed
.
comm
.
tcp
.
BaseTCPListener
distributed
.
comm
.
inproc
.
InProcListener
distributed
.
comm
.
ucx
.
UCXListener
Reexports
Imported in
distributed.comm.tcp
.
Imported in
distributed.comm.inproc
.
Imported in
distributed.comm.ucx
.
Generated by
nedoc
v0.9 at 2020-12-29 14:05