rpyc_mem.connect package

Submodules

rpyc_mem.connect.rpyc_mem_connect module

RPyC Memory Connect

class rpyc_mem.connect.rpyc_mem_connect.RpycMemConnect(hostname, port, max_retry=4, retry_delay=3, ignore_version=False)

Bases: object

Wrapper around rpyc.connect to connect with RpycMemService. RpycMemConnect does some basic error recovery and validations on behalf of the user.

Parameters

  • hostname (str) – RPyC memory service hostname

  • port (int) – RPyC memory service port

  • max_retry (int) – Number of times to retry upon connection failure.

  • retry_delay (int) – Retry delay in seconds between each re-connect attempt

  • ignore_version (bool) – Do not validate the server RPyC version with the client

__getattr__(name)

Search an undefined attribute in underlying rpyc connection object (rpyc_conn). The attributes of rpyc memory service are directly searched in rpyc_conn.root. Example: rmem_connect.get, rmem_connect.root.get are similar

Parameters

name (str) – The name of attribute to search in underlying rpyc memory connection.

Returns

close()

Close underlying RPyC connection. Exceptions are no more handled (until re-setup) after this operation.

Returns

rmem_except_handler(rmem_fn=None, on_reconnect=None)
Function decorator for handling rpyc memory service related exceptions. Can be invoked as follows:
+ @rmem_except_handler -> sets on_reconnect to None
+ @rmem_except_handler(on_reconnect=reconnect_hook) -> sets on_reconnect to reconnect_hook
+ @rmem_except_handler() -> Same as @rmem_except_handler
+ @rmem_except_handler(func) -> Ambiguous case, breaks the code.
Parameters

  • rmem_fn – Function to be wrapped

  • on_reconnect – Reconnect hook to be called when connection is re-established

Returns

Wrapped function

setup_rmem_conn()

Setup RPyC memory connection

Returns

Module contents