Metadata-Version: 2.1
Name: electron-rpc
Version: 0.0.2
Summary: Rapid RPC Framework for your Python services using Asyncio + MsgPack
Home-page: https://github.com/dvf/electron
Author: Daniel van Flymen
Author-email: vanflymen@gmail.com
License: UNKNOWN
Platform: UNKNOWN
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: Implementation :: CPython
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Description-Content-Type: text/markdown

# ⚡️electron

Rapid RPC Framework for building Python 3.7+ services using Asyncio + [MsgPack](https://msgpack.org/index.html)

# Installation

```
$ pip install electron-rpc
```

# How does it work?

Create a server instance with a single endpoint `sum()` which outputs the sum of two values:

```python
from electron.server import Server

app = Server()


@app.endpoint("sum")
async def sum(a, b, **kwargs):
    return f"Result: {a + b}"


app.run()
```

```
        __          __                      
  ___  / /__  _____/ /__________  ____      
 / _ \/ / _ \/ ___/ __/ ___/ __ \/ __ \     
/  __/ /  __/ /__/ /_/ /  / /_/ / / / /     
\___/_/\___/\___/\__/_/   \____/_/ /_/      

⚡ electron build v0.0.1-beta                              

Listening on 127.0.0.1:9999

Registered Endpoints:
- sum
```

## Calling the endpoint from a client

electron uses MsgPack-RPC, so craft a payload and send it over TCP:

```python
import socket

from electron.messages import RemoteProcedureCall

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

sock.connect(("127.0.0.1", 9999))
sock.send(RemoteProcedureCall(endpoint="sum", args=[1, 2]).encode())

data = sock.recv(1024)
print(f"Received: \n{data.decode()}")
sock.close()
```
```
Received: 
Result: 3
```

# Background Tasks

To create a background task, decorate it with `@app.background(time_in_seconds)`:

```python
@app.background(3)
async def some_background_task():
    print("Running background task every 3 seconds")
```

Now the task will execute every 3 seconds.


