Module comm

Re-exported Classes

• class Comm
  A message-oriented communication object, representing an established
  [distributed.comm.core.Comm]
• class CommClosedError
  [distributed.comm.core.CommClosedError]

Re-exported Functions

• def get_address_host(addr)
  Return a hostname / IP address identifying the machine this address is located on.
  [distributed.comm.addressing.get_address_host]
• def get_address_host_port(addr, strict=False)
  Get a (host, port) tuple out of the given address.
  [distributed.comm.addressing.get_address_host_port]
• def get_local_address_for(addr)
  Get a local listening address suitable for reaching *addr*.
  [distributed.comm.addressing.get_local_address_for]
• def get_tcp_server_address(tcp_server)
  Get the bound address of a started Tornado TCPServer.
  [distributed.comm.utils.get_tcp_server_address]
• def listen(addr, handle_comm, deserialize=True, **kwargs)
  Create a listener object with the given parameters. When its ``start()``
  [distributed.comm.core.listen]
• def normalize_address(addr)
  Canonicalize address, adding a default scheme if necessary.
  [distributed.comm.addressing.normalize_address]
• def parse_address(addr, strict=False)
  Split address into its scheme and scheme-dependent location string.
  [distributed.comm.addressing.parse_address]
• def parse_host_port(address, default_port=None)
  Parse an endpoint address given in the form "host:port".
  [distributed.comm.addressing.parse_host_port]
• def resolve_address(addr)
  Apply scheme-specific address resolution to *addr*, replacing all symbolic references with concrete location specifiers.
  [distributed.comm.addressing.resolve_address]
• def unparse_address(scheme, loc)
  Undo parse_address().
  [distributed.comm.addressing.unparse_address]
• def unparse_host_port(host, port=None)
  Undo parse_host_port().
  [distributed.comm.addressing.unparse_host_port]

Submodules

• Module distributed.comm.addressing
• Module distributed.comm.core
• Module distributed.comm.inproc
• Module distributed.comm.registry
• Module distributed.comm.tcp
• Module distributed.comm.tests
• Module distributed.comm.ucx
  :ref:`UCX`_ based communications for distributed.
• Module distributed.comm.utils

Generated by nedoc v0.9 at 2020-12-29 14:05