Changelog

[Unreleased]

Added

MCP server integration for AI agents
More SQL functions
Performance optimizations

[0.1.0] - 2026-05-27

Added

Core streaming engine
SQL support via DataFusion
Kafka source/sink
State management (Memory, RocksDB)
Checkpointing
CLI tool
gRPC server
Flink DataStream API compatibility
Examples and documentation

Architecture

fungi-common: Shared types, errors, configuration
fungi-state: State backends (Memory, RocksDB)
fungi-streaming: Watermarks, windows, timers
fungi-execution: Operator graph, task executor
fungi-checkpoint: Checkpoint coordinator
fungi-sql: DataFusion integration
fungi-flink: Flink DataStream API compatibility
fungi-server: gRPC server with REST API
fungi-runtime: Embedded and server modes
fungi-cli: Command-line interface
fungi-connector: Kafka source/sink

Features

SQL query execution
Kafka integration
State management
Checkpointing
CLI tool
gRPC API
Flink-compatible DataStream API

Performance

Zero GC pauses
Predictable latency
Low memory footprint
SIMD-optimized (via Arrow)

Documentation

Quickstart guide
Architecture documentation
CLI reference
SDK reference
Kafka integration guide
MCP integration guide
Examples

[0.0.1] - 2026-05-20

Added

Initial project setup
Basic crate structure