wingfoil-python 8.0.0

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
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
77
78

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"]

# Latency measurement classes
Latency = _ext.Latency
TracedBytes = _ext.TracedBytes
__all__.extend(["Latency", "TracedBytes"])

# 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 Fluvio functions
fluvio_sub = _ext.py_fluvio_sub

# User-friendly aliases for Kafka functions
kafka_sub = _ext.py_kafka_sub

# User-friendly aliases for Redis functions
redis_sub = _ext.py_redis_sub
redis_stream_read = _ext.py_redis_stream_read

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

# User-friendly aliases for PostgreSQL functions
postgres_read = _ext.py_postgres_read
postgres_sub = _ext.py_postgres_sub
postgres_write = _ext.py_postgres_write
postgres_notify_trigger_sql = _ext.py_postgres_notify_trigger_sql

# 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 Aeron functions (feature-gated)
if hasattr(_ext, "py_aeron_sub"):
    aeron_sub = _ext.py_aeron_sub
    AeronMode = _ext.AeronMode
    __all__.extend(["aeron_sub", "AeronMode"])

# 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")

# User-friendly aliases for the web adapter
WebServer = _ext.WebServer
__all__.append("WebServer")