Metadata-Version: 1.2
Name: remrpc
Version: 0.1.5
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
Description: 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()
        
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
