Metadata-Version: 2.1
Name: remrpc
Version: 0.1.9
Summary: Lightweight RPC on Redis using Msgpack.
Home-page: https://github.com/shixiongfei/remrpc
Author: Xiongfei Shi
Author-email: jenson.shixf@gmail.com
Maintainer: Xiongfei Shi
Maintainer-email: jenson.shixf@gmail.com
License: UNKNOWN
Keywords: Msgpack,Redis,RPC
Platform: UNKNOWN
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: Apache Software License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Topic :: Software Development :: Object Brokering
Classifier: Topic :: System :: Distributed Computing
Requires-Dist: redis
Requires-Dist: msgpack
Requires-Dist: gevent

remrpc
======

REdis Msgpack RPC

Installation
------------

.. code-block:: python

    pip install remrpc

Example
-------

.. code-block:: python

    import redis
    import remrpc

    def add(a, b):
        return a + b

    def sub(a, b):
        return a - b

    def multi():
        return "Hello", "World"

    def kvfunc(k="key", v="val"):
        return "{0} = {1}".format(k, v)

    def nonreturn():
        print("Non Return")

    class CallObject:
        def __call__(self, name):
            return "Hello {0}".format(name)

    if __name__ == "__main__":
        pool = redis.ConnectionPool(host="127.0.0.1",
                                    port=6379,
                                    password="123456")
        rpc1 = remrpc.RPC(redis.Redis(connection_pool=pool), "channel:rpc1")
        rpc2 = remrpc.RPC(redis.Redis(connection_pool=pool), "channel:rpc2")

        rpc1.register(add)
        rpc1.register(sub)
        rpc1.register(multi)
        rpc1.register(kvfunc)
        rpc1.register(CallObject(), 'sayhello')
        rpc1.register(nonreturn)

        try:
            invoker = rpc2.invoker("channel:rpc1")

            print(invoker.add(1, 2))
            print(invoker.sub(9, 5))
            print(invoker.multi())
            print(invoker.kvfunc(k="KEY", v="VALUE"))
            print(invoker.sayhello("World"))
            print(invoker.nonreturn())
            print(invoker.nonexistent())
        except remrpc.TimedoutRPC as e:
            print("> RPC Timedout: {0}".format(e))
        except remrpc.CallErrorRPC as e:
            print("> RPC Call Error: {0}".format(e))
        except remrpc.ExceptionRPC as e:
            print("> RPC Exception: {0}".format(e))

        rpc1.close()
        rpc2.close()


