flux.rpc module

class flux.rpc.RPC(flux_handle, topic, payload=None, nodeid=flux.constants.FLUX_NODEID_ANY, flags=0)

Bases: Future

An RPC state object

class RPCInnerWrapper(handle=None, match=_flux._core.ffi.typeof, filter_match=True, prefixes=None, destructor=<bound method Wrapper.__getattr__.<locals>.wrap_class of <flux.core.inner.Core object>>)

Bases: Wrapper

check_wrap(fun, name)

get()

get_str(*args, **kwargs)