Class UCXListener

Declaration

class UCXListener(Listener)

▶ def __init__(self, address: str, comm_handler: None, deserialize=False, ...)
def __init__(
self,
address: str,
comm_handler: None,
deserialize=False,
allow_offload=True,
**connection_args,
)
source link
▷ def address(self) @property
@property
def address(self)
source link
▷ def bound_address(self) @property
@property
def bound_address(self)
source link
▶ def contact_address(self) override @property
inherited doc 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'.
@property
def contact_address(self)
source link
This method overrides distributed.comm.core.Listener.contact_address.
▷ def get_host_port(self)
source link
▶ def listen_address(self) override @property
inherited doc The listening address as a URI string.
@property
def listen_address(self)
source link
This method overrides distributed.comm.core.Listener.listen_address.
▷ def port(self) @property
@property
def port(self)
source link
▶ def stop(self) override
inherited doc Stop listening. This does not shutdown already established communications, but prevents accepting new ones.
source link
This method overrides distributed.comm.core.Listener.stop.