pyridis-api 0.3.5

iridis, with python
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

import pyarrow as pa

from abc import ABC, abstractmethod
from datetime import datetime

from typing import Callable, Dict, Any

class Header:
    @property
    def source_node(self) -> str:
        pass

    @property
    def source_io(self) -> str:
        pass

    @property
    def timestamp(self) -> datetime:
        pass

    @property
    def elapsed(self) -> int:
        pass

class PyDataflowMessage:
    @property
    def data(self) -> pa.Array:
        pass

    @property
    def header(self) -> Header:
        pass

class Node(ABC):
    def __init__(self):
        pass

    @abstractmethod
    async def new(self, inputs: Inputs, outputs: Outputs, queries: Queries, queryables: Queryables, config: Dict[str, Any]):
        pass

    @abstractmethod
    async def start(self):
        pass

class Inputs:
    async def with_input(self, input: str) -> Input:
        pass

class Outputs:
    async def with_output(self, output: str) -> Output:
        pass

class Queries:
    async def with_query(self, query: str) -> Query:
        pass

class Queryables:
    async def with_queryable(self, queryable: str) -> Queryable:
        pass

class Input:
    async def recv(self) -> PyDataflowMessage:
        pass

class Output:
    async def send(self, message: PyDataflowMessage):
        pass

class Query:
    async def query(self, message: PyDataflowMessage) -> PyDataflowMessage:
        pass

class Queryable:
    async def on_query(self, func: Callable[[PyDataflowMessage], pa.Array]):
        pass