API Reference¶

Auto-generated from Python docstrings.

Core¶

::: datafun_streaming.core.types

Data Validation¶

::: datafun_streaming.data_validation.types ::: datafun_streaming.data_validation.validation_utils ::: datafun_streaming.data_validation.reference ::: datafun_streaming.data_validation.errors

IO¶

::: datafun_streaming.io.io_utils ::: datafun_streaming.io.errors

Kafka¶

::: datafun_streaming.kafka.kafka_settings ::: datafun_streaming.kafka.kafka_producer_utils ::: datafun_streaming.kafka.kafka_consumer_utils ::: datafun_streaming.kafka.kafka_admin_utils ::: datafun_streaming.kafka.kafka_connection_utils ::: datafun_streaming.kafka.kafka_error_messages

Stats¶

::: datafun_streaming.stats.stats_utils

Storage¶

::: datafun_streaming.storage.duckdb_utils

Visualization¶

::: datafun_streaming.visualization.chart_utils