wingfoil-python 4.0.1

python bindings for wingfoil - graph based stream processing framework
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

from . import _wingfoil as _ext


from .stream import *

from ._wingfoil import *
from ._wingfoil import Graph 

from .pandas_helpers import to_dataframe, build_dataframe

__doc__ = getattr(_ext, "__doc__", "")
__version__ = getattr(_ext, "__version__", None)

__all__ = list(getattr(_ext, "__all__", [])) + ["to_dataframe", "build_dataframe"]

# User-friendly aliases for CSV functions
csv_read = _ext.py_csv_read

# User-friendly aliases for etcd functions
etcd_sub = _ext.py_etcd_sub

# User-friendly aliases for ZMQ functions
zmq_sub = _ext.py_zmq_sub
zmq_sub_etcd = getattr(_ext, "py_zmq_sub_etcd", None)

# User-friendly aliases for KDB+ functions
kdb_read = _ext.py_kdb_read
kdb_write = _ext.py_kdb_write

# User-friendly aliases for iceoryx2 functions (feature-gated)
if hasattr(_ext, "py_iceoryx2_sub"):
    iceoryx2_sub = _ext.py_iceoryx2_sub
    Iceoryx2ServiceVariant = _ext.Iceoryx2ServiceVariant
    Iceoryx2Mode = _ext.Iceoryx2Mode
    __all__.extend(["iceoryx2_sub", "Iceoryx2ServiceVariant", "Iceoryx2Mode"])

# User-friendly aliases for FIX functions
fix_connect = _ext.py_fix_connect
fix_connect_tls = _ext.py_fix_connect_tls
fix_accept = _ext.py_fix_accept

# User-friendly aliases for OTLP
# (otlp_push is exposed as a stream method, no top-level sub function needed)

# User-friendly aliases for Prometheus
PrometheusExporter = _ext.PrometheusExporter
__all__.append("PrometheusExporter")