communication package

Communication library for sending arbitrary Python data types over HTTP(S).

communication.init_pool()

Initializes a new Pool object.

Return type:

Pool

Returns:

new Pool object.

Subpackages

• communication.serializer_plugins package
  • Submodules
    • communication.serializer_plugins.bitarray module
      • bitarray_deserialize()
      • bitarray_serialize()
      • register()
    • communication.serializer_plugins.gmpy module
      • gmpy_deserialize()
      • gmpy_serialize()
      • register()
    • communication.serializer_plugins.int module
      • int_deserialize()
      • int_serialize()
      • register()
    • communication.serializer_plugins.numpy module
      • numpy_deserialize()
      • numpy_serialize()
      • register()
    • communication.serializer_plugins.pandas module
      • pandas_deserialize_dataframe()
      • pandas_deserialize_series()
      • pandas_serialize_dataframe()
      • pandas_serialize_series()
      • register()
    • communication.serializer_plugins.tuple module
      • register()
      • tuple_deserialize()
      • tuple_serialize()

Submodules

• communication.exceptions module
  • AnnotationError
  • OptionalImportError
  • RepetitionError
• communication.functions module
  • handle_sigterm()
  • init()
  • redirect_importerror_to_optionalimporterror()
• communication.httphandlers module
  • AbstractPool
    • AbstractPool.handlers_lookup
    • AbstractPool.http_server
    • AbstractPool.loop
  • HTTPClient
    • HTTPClient.__eq__()
    • HTTPClient.__init__()
    • HTTPClient.recv()
    • HTTPClient.send()
    • HTTPClient.shutdown()
  • HTTPServer
    • HTTPServer.__init__()
    • HTTPServer.run_server()
    • HTTPServer.shutdown()
• communication.pool module
  • Pool
    • Pool.__init__()
    • Pool.add_http_client()
    • Pool.add_http_server()
    • Pool.arecv()
    • Pool.arecv_all()
    • Pool.asend()
    • Pool.async_broadcast()
    • Pool.broadcast()
    • Pool.create_ssl_context()
    • Pool.get_port()
    • Pool.recv()
    • Pool.recv_all()
    • Pool.send()
    • Pool.shutdown()
    • Pool.update_msg_prefix()
• communication.serialization module
  • Serialization
    • Serialization.clear_serialization_logic()
    • Serialization.collection_deserialize()
    • Serialization.default_deserialize()
    • Serialization.default_serialize()
    • Serialization.deserialize()
    • Serialization.pack()
    • Serialization.register()
    • Serialization.register_class()
    • Serialization.serialize()
    • Serialization.unpack()
  • SupportsSerialization
    • SupportsSerialization.deserialize()
    • SupportsSerialization.serialize()