v0.10.1

What's Changed

Changes since v0.10.0:

• chore: remove unused dependencies, bump to 0.10.1 (7e30d58)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.10.1"

📚 Documentation: docs.rs/streamweave

Full Changelog: v0.10.0...v0.10.1

v0.10.0

What's Changed

Changes since v0.9.0:

• Release 0.10.0 (b906b05)
• feat: update dependencies and enhance hooks for development workflow (7ad9a5e)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.10.0"

📚 Documentation: docs.rs/streamweave

Full Changelog: v0.9.0...v0.10.0

v0.9.0

What's Changed

Changes since v0.8.3:

• feat: enhance error handling and add pre-commit script (b435040)
• chore: bump version to 0.9.0 (1c488ab)
• refactor: update examples to utilize graph! macro for graph construction (43580fe)
• feat: introduce graph! macro for declarative graph construction (200c7b8)
• feat: add minimal syntax graph macro implementation documentation (daff943)
• refactor: clean up whitespace in string slicing and type operation tests (0b00ebc)
• feat: enhance string slicing functionality for Unicode support (03e3512)
• chore: add .cursorignore file and update .gitignore for better file management (8bb9023)
• refactor: update MCP server configuration and remove obsolete files (0c44aff)
• docs: update README with Graph API example and memory management features (1de88d5)
• feat: add debug_parse.rs for date and time parsing examples (f88b0c8)
• feat: add example for is_null_node (task 2.13.9 is_null_node) (5a772c7)
• feat: implement is_int_node (task 2.13.8 is_int_node) (33a29d0)
• feat: implement is_float_node (task 2.13.7 is_float_node) (ef6d08e)
• feat: add example for is_boolean_node (task 2.13.6 is_bool_node) (d17f627)
• feat: add example for is_array_node (task 2.13.5 is_array_node) (463c9dd)
• feat: add example for to_string_node (task 2.13.4 as_string_node) (a1218ec)
• feat: implement to_int_node (task 2.13.3 as_int_node) (39de190)
• feat: implement to_float_node (task 2.13.2 as_float_node) (ea45fd1)
• feat: add to_boolean_node example (task 2.13.1 as_bool_node) (e9648a8)
• feat: implement parse_time_node (task 2.12.3) (70ddf91)
• feat: implement format_time_node (task 2.12.2) (a9db2b6)
• feat: implement object_size_node (task 2.8.6) (496b841)
• feat: add timestamp_node example (task 2.12.4) (fc044a2)
• feat: add example program for StringConcatNode (e68a6e6)
• feat: add StringCharAtNode implementation with example (44a8c64)
• feat: add StringUppercaseNode implementation with example (52a7174)
• feat: add example program for StringTrimNode (e2105bf)
• feat: add example program for StringSliceNode (substring functionality) (b4403b7)
• feat: add example program for StringStartsWithNode (2fa5e66)
• feat: add example program for StringSplitNode (c2beccf)
• feat: add example program for StringReplaceNode (ad03123)
• feat: implement StringLowercaseNode (f251e22)
• feat: add example program for StringLengthNode (d44e49d)
• feat: implement StringLastIndexOfNode (c98a7e8)
• feat: implement StringIndexOfNode (86e70b4)
• feat: implement StringFormatNode (14eb41b)
• feat: add example program for StringEndsWithNode (4d8d4bd)
• feat: implement StringCapitalizeNode (7718789)
• feat: implement StringAppendNode (a0e1cd0)
• feat: add example program for ZipNode (8be5c49)
• feat: implement WindowNode for collecting items into fixed-size windows (d6f9abd)
• feat: implement ThrottleNode for rate-limiting stream emissions (04cd6ec)
• feat: implement LastNode for emitting only the last stream item (67b15ad)
• feat: implement FirstNode for emitting only the first stream item (c5f9995)
• feat: implement FilterMapNode for filtering and mapping stream items (b0866c8)
• feat: implement DistinctUntilChangedNode for filtering consecutive duplicates (70f8ee5)
• feat: implement DistinctNode for filtering duplicate stream items (014d384)
• feat: implement DebounceNode for stream debouncing (f780314)
• feat: implement BufferNode for batching stream items (03c6214)
• feat: implement ScanNode for reduction operations with intermediate results (f1d3da1)
• feat: add take_node example demonstrating stream taking functionality (20a300f)
• feat: add skip_node example demonstrating stream skipping functionality (a57a640)
• feat: add sample_node example to Cargo.toml (20788ae)
• feat: add drop_node example demonstrating DropNode usage with Graph API (30cfecf)
• fix: correct SyncNode configuration handling in tests (458a94a)
• refactor: rename remaining object test file and verify tests pass (0727296)
• feat: add ObjectSetPropertyNode example (set_node) using Graph API (3a339c8)
• feat: add ObjectMergeNode example (merge_node) using Graph API (753fff2)
• refactor: rename object node files to follow {StructName}_node.rs convention (d6d6729)
• feat: add ObjectKeysNode example (keys_node) using Graph API (dc95a32)
• feat: add ObjectHasPropertyNode example (has_node) using Graph API (4e3106b)
• feat: add ObjectPropertyNode example (get_node) using Graph API (940c4b3)
• feat: add SqrtNode example using Graph API (1d28e37)
• feat: add RoundNode example using Graph API (9c6cae5)
• feat: add MinNode example using Graph API (8130b3d)
• feat: add LogNode example using Graph API (755fe67)
• feat: add FloorNode example using Graph API (5b63094)
• feat: add ExpNode example using Graph API (a8afdec)
• feat: add CeilNode example using Graph API (f445b02)
• feat: add AbsNode example using Graph API (33f0b8b)
• feat: add NotEqualNode example using Graph API (73483b5)
• feat: add LessThanOrEqualNode example using Graph API (4eba3f7)
• feat: add LessThanNode example using Graph API (a9fb775)
• feat: add GreaterThanOrEqualNode example using Graph API (629c2da)
• feat: add GreaterThanNode example using Graph API (6a847e9)
• feat: add EqualNode example using Graph API (3a333d5)
• feat: add ArrayUniqueNode example using Graph API (a2acb37)
• feat: add ArraySplitNode example using Graph API (2c287a8)
• feat: add ArraySortNode example using Graph API (a9168c4)
• feat: add bin/test-examples script for comprehensive example testing (65870be)
• feat: add ArraySliceNode example using Graph API (fc33854)
• feat: add SumNode example using Graph API (b089c40)
• feat: complete Boolean Logic Nodes section (14e8ca5)
• feat: add XorNode example using Graph API (20409f2)
• feat: add OrNode example using Graph API (585889c)
• feat: add NotNode example using Graph API (f808ed3)
• feat: add NorNode example using Graph API (1a81e00)
• feat: add NandNode example using Graph API (6b6627d)
• feat: add AndNode example using Graph API (f674b6f)
• feat: add ArrayReverseNode example using Graph API (4e917a7)
• refactor: reorganize examples directory to mirror src/nodes structure (5a098de)
• feat: add ArrayLengthNode example using Graph API (e47117b)
• feat: add ArrayIndexOfNode example using Graph API (6866a5f)
• feat: add ArrayIndexNode example using Graph API (72028fc)
• feat: add ArrayFlattenNode example using Graph API (83e225b)
• feat: add ArrayContainsNode example using Graph API (448fd6c)
• feat: add ArrayConcatNode example using Graph API (8811f43)
• feat: add SubtractNode example using Graph API (6f2e955)
• feat: add PowerNode example using Graph API (81888ea)
• feat: add MultiplyNode example using Graph API (caf2edc)
• feat: add ModuloNode example using Graph API (35011bf)
• feat: add DivideNode example using Graph API (6e5074a)
• feat: add AddNode example using Graph API (ee626e8)
• feat: add MinAggregateNode example using Graph API (b48b2ab)
• feat: add MaxAggregateNode example using Graph API (1eab726)
• feat: add CountNode example using Graph API (94f3350)
• feat: add TryCatchNode example using Graph API (6d151a4)
• feat: add SwitchNode example using Graph API (4fecee7)
• feat: add RetryNode example using Graph API (ffca9c5)
• feat: add SyncNode example using Graph API (abff5bb)
• feat: add RangeNode example using Graph API (c18a040)
• feat: add JoinNode example using Graph API (fcd25d6)
• feat: add ErrorBranchNode example using Graph API (453b702)
• feat: add ContinueNode example using Graph API (1e9a006)
• feat: add ConditionNode example using Graph API (6efeb9a)
• feat: add BreakNode example using Graph API (5ac6d42)
• refactor: updated examples (b3f8f10)
• feat: add continue_node example demonstrating skip signal functionality (f4342a0)
• feat: add break_node example demonstrating break signal functionality (559636c)
• feat: add for_each_node example (82e66b0)
• feat: add filter_node example (8d67956)
• refactor: remove GraphBuilder API and update examples (b2eef2e)
• feat: add HTTP server examples and enhance GraphBuilder functionality (90561f4)
• feat: add comprehensive GraphBuilder test suite (4cab892)
• feat: implement GraphBuilder pattern for fluent graph construction (5fe11bd)
• chore: remove JsonConsumer module (a2bb01a)
• fix: resolve pre-commit issues and test failures (ce6dce7)
• refactor: current state (3bef9df)
• docs: add usage examples for node categories (task 11.2.3) (ccea16e)
• docs: verify all nodes have node-level documentation (task 11.2.2) (6b6a5a8)
• docs: add module-level documentation for all node categories (task 11.2.1) (dadeef0)
• docs: verify main nodes/mod.rs exports all categories (task 11.1.3) (8f653f1)
• docs: verify all module mod.rs files are properly organized (task 11.1.2) (5d978a8)
• docs: verify all module directories exist (task 11.1.1) (1c27f24)
• test: verify all advanced control tests pass (task 10.2.4) (19c984d)
• feat: implement RetryNode (task 10.2.3) (f4a1f74)
• feat: implement TryCatchNode (task 10.2.2) (fa172ff)
• fix: fix move errors in SwitchNode (faa2430)
• fix: fix compilation errors in SwitchNode (ade9c88)
• feat: implement SwitchNode (task 10.2.1) (55aa6f2)
• test: verify all advanced loop tests pass (task 10.1.4) (32e4b34)
• feat: implement ContinueNode (task 10.1.3) (44c030a)
• fix: fix unused variable warning in BreakNode (16ae997)
• feat: implement BreakNode (task 10.1.2) (784552d)
• fix: fix RepeatNode stream merging and test imports (9288f5b)
• feat: implement RepeatNode (task 10.1.1) (6f9c58c)
• test: verify all type conversion tests pass (task 9.2.5) (a3a5d7c)
• feat: implement ToArrayNode (task 9.2.4) (7e4693c)
• feat: implement ToBooleanNode (task 9.2.3) (288448b)
• feat: implement ToNumberNode (task 9.2.2) (4a3538f)
• feat: implement ToStringNode (task 9.2.1) (890bc79)
• fix: fix compilation errors in type_of_node_test.rs (task 9.1.8) (17eb68d)
• feat: implement IsNullNode (task 9.1.7) (13f9ab5)
• feat: implement IsObjectNode (task 9.1.6) (d7669fc)
• feat: implement IsArrayNode (task ...

v0.8.3

What's Changed

Changes since v0.8.2:

• chore: update version (5c87b0a)
• feat(graph): add trace logs and fix HTTP server request/response flow (77ee718)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.8.3"

📚 Documentation: docs.rs/streamweave

Full Changelog: v0.8.2...v0.8.3

v0.8.2

What's Changed

Changes since v0.8.1:

• chore: Update dependencies and improve documentation (65a2db4)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.8.2"

📚 Documentation: docs.rs/streamweave

Full Changelog: v0.8.1...v0.8.2

v0.2.2

What's Changed

Changes since v0.2.1:

• Configure mcp servers (#18) (8a3321d)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.2.2"

📚 Documentation: docs.rs/streamweave

What's Changed

Other Changes

• Configure mcp servers by @Industrial in #18

Full Changelog: v0.2.1...v0.2.2

v0.2.1

What's Changed

Changes since v0.2.0:

• chore(ci): Update publish workflow and documentation generation (#17) (b9ab0ae)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.2.1"

📚 Documentation: docs.rs/streamweave

What's Changed

Other Changes

• chore(ci): Update publish workflow and documentation generation by @Industrial in #17

Full Changelog: v0.2.0...v0.2.1

v0.2.0

What's Changed

Changes since v0.1.0:

• fix: random number tests (#16) (a79de23)
• fix: ci yml (#15) (e5000f6)
• chore(ci): Clean up WASM build section in CI workflow (#14) (a34e830)
• refactor(ci): Remove coverage job from CI workflow (#13) (969f800)
• deps(deps): update hyper-tungstenite requirement from 0.13 to 0.19 (#6) (7c7ca7c)
• deps(deps): update tokio-tungstenite requirement from 0.21 to 0.28 (#7) (df622a4)
• fix(deps): Add MIT-0 license to allowed licenses in cargo-deny (#12) (806fa59)
• ci: Ensure PRs run all CI checks before merging (bdc1427)
• deps(deps): update jsonschema requirement from 0.17 to 0.37 (#10) (5bbbff2)
• deps(deps): update thiserror requirement from 1.0.57 to 2.0.17 (#11) (859becb)
• ci: Add automatic branch rebasing workflow (b9fccda)
• fix(docs): Treat doctest compilation failures as warnings instead of errors (eed5af3)
• fix(clippy): Replace manual Default impls with derive and use is_multiple_of (ff400fc)
• fix(ci): Update WASM build script name in CI workflow (825b23b)
• fix(ci): Update cargo-deny configuration for v0.18.6 (eea9e78)
• fix(ci): Ignore RUSTSEC-2023-0071 in security audit (5f27259)
• fix(docs): Improve documentation verification script (5ea0297)
• fix(clippy): Fix clippy warnings in broadcast transformer tests (88f40f6)
• feat(tests): Convert broadcast transformer tests to proptest (b134c4f)
• test(ordered_merge): Convert tests to proptest (280ca65)
• test(visualization): Convert tests in exporter.rs to proptest (9eca266)
• Squashed commit of the following: (512c383)
• chore(taskmaster): Add git worktree and branch requirements to all tasks (eced883)
• test(distributed/partitioner): Convert tests to proptest (56bedc2)
• test(distributed/network/pool): Convert tests to proptest (c42f80e)
• test(distributed/network/discovery): Convert tests to proptest (012d606)
• test(distributed/network/connection): Convert tests to proptest (1c7844c)
• test(distributed/fault_tolerance/recovery): Convert tests to proptest (b2ec7ba)
• test(distributed/fault_tolerance/failure_detector): Convert tests to proptest (0ed977d)
• test(distributed/fault_tolerance/checkpoint): Convert tests to proptest (de0fe39)
• test(distributed/coordinator): Convert tests to proptest (c8c77cf)
• test(consumers/vec/input): Convert tests to proptest (73749ca)
• test: convert tests in consumers/vec/consumer.rs to proptest (8b5c8ac)
• test: convert tests in consumers/string/input.rs to proptest (2d89bb0)
• test: convert tests in consumers/string/consumer.rs to proptest (a3c002b)
• test: convert tests in consumers/redis_streams/redis_streams_consumer.rs to proptest (318451b)
• test: convert tests in consumers/parquet/parquet_consumer.rs to proptest (3797505)
• test: convert tests in consumers/parquet/consumer.rs to proptest (d39071b)
• test: convert tests in consumers/msgpack/msgpack_consumer.rs to proptest (8656e82)
• test: convert tests in consumers/msgpack/consumer.rs to proptest (454b479)
• test: convert tests in consumers/kafka/kafka_consumer.rs to proptest (8380462)
• test: convert tests in consumers/jsonl/jsonl_consumer.rs to proptest (e029224)
• test: convert tests in consumers/jsonl/consumer.rs to proptest (8d9382e)
• test: convert tests in consumers/hash_set/input.rs to proptest (53c175d)
• test: convert tests in consumers/hash_set/consumer.rs to proptest (7362c2f)
• test: convert tests in consumers/hash_map/input.rs to proptest (0c2a1ca)
• test: convert tests in consumers/hash_map/consumer.rs to proptest (c0525f2)
• test: convert tests in consumers/file/input.rs to proptest (35cab4e)
• test: convert tests in consumers/file/consumer.rs to proptest (8bbb841)
• test: convert tests in consumers/csv/csv_consumer.rs to proptest (77b94a2)
• test: convert tests in consumers/csv/consumer.rs to proptest (1d085f4)
• fix: ensure GitHub Actions supports Rust 2024 edition (c428234)
• test: convert array consumer tests to use proptest (9323dcd)
• test: convert consumer.rs tests to use proptest (334e26f)
• chore: complete task 1 - verify proptest configuration (3798409)
• feat: migrate test tasks to proptest and fix build issues (980ac3a)
• style: format code with rustfmt (0f582ad)
• fix: remove broken intra-doc links in window.rs module documentation (d70d1ce)
• ci(deps): bump actions/upload-pages-artifact from 3 to 4 (#3) (a34be56)
• ci(deps): bump actions/checkout from 4 to 6 (#2) (73b1dd8)
• deps(deps): update rand requirement from 0.8 to 0.9 (#8) (7ef7a8b)
• deps(deps): update jsonwebtoken requirement from 9.2 to 10.2 (#9) (ef36f79)
• chore: add pre-commit infrastructure and fix documentation issues (7e92c02)
• chore: update version to v0.2.0 (ae7eda5)
• feat(http-server): Enhance HTTP server integration with new example and error handling (6b8a701)
• fix: build and test pass (cd41839)
• fix: check passes (f8d74d7)
• fix: Update example pipelines to include identity transformers and improve consumer handling (fb757b3)
• feat: Add new example and scripts for environment setup (30fcba0)
• feat: kitchen sink (22729d1)
• feat(metrics): Complete subtask 11.1 - Define standard metrics (e7d615b)
• docs(tasks): Add example requirements to tasks 11-16 (7c24fd5)
• feat: Make examples runnable and fix WASM examples (4fda48b)
• fix(examples): Correct example name in basic_pipeline README (a52c575)
• feat(examples): Add Kafka integration example (4e9da4b)
• refactor(consumers): Simplify imports and improve configuration handling (1f0364c)
• feat(tasks): Add Task 16 - Implement HTTP Server Support (d2bb78f)
• feat(tasks): Add example requirement to all subtasks from Task 11 onwards (d40b40c)
• feat(tasks): Add Task 10 - Create Comprehensive Examples (5d7ee61)
• feat(database): Complete Task 9.3 - Add SQLite support and comprehensive tests (e6858ae)
• feat(database): Improve Task 9.3 - Database query producer query execution (6e110d6)
• feat(http-poll): Complete Task 9.4 - Implement HTTP polling producer (488fa91)
• feat(database): WIP - Task 9.3 - Database query producer structure (755f74b)
• feat(redis-streams): Complete Task 9.2 - Implement Redis Streams producer/consumer (367b848)
• feat(wasm): Complete Task 8.4 - Create WASM documentation and examples (643b371)
• feat(wasm): optimize bundle size and add size regression tests (Task 8.3) (b10ee1b)
• feat(distributed): implement fault tolerance (Task 7.4) (4e732da)
• feat(distributed): implement network communication (Task 7.3) (950647c)
• feat(distributed): implement data partitioning (Task 7.2) (fe158b8)
• chore: add build/test requirement to all remaining tasks (7.2+) (5a0ba7e)
• feat(wasm): add bundle size optimization profiles (2eecde6)
• feat(wasm): add WASM feature flags and conditional compilation (f3ad773)
• feat(formats): implement comprehensive data format support (Task 6) (46be867)
• feat(transformers): implement OrderedMergeTransformer for configurable merge (9678086)
• feat(transformers): implement RouterTransformer for content-based routing (6f1371c)
• feat(transformers): implement RoundRobinTransformer for load balancing (cdfdef1)
• feat(transformers): implement BroadcastTransformer for fan-out (6d2602b)
• feat(transformers): implement Join transformer (6f9b2a6)
• feat(window): implement watermarks and late data handling (6ed9aa1)
• feat: implement windowing trait system for stream processing (ff05e64)
• feat: implement transaction support for exactly-once processing (c0b637a)
• feat(offset): implement offset tracking for resumable pipelines (0def1da)
• feat(dedup): implement message deduplication transformer (8f1d23c)
• feat(message): implement message ID tracking for exactly-once processing (6362a83)
• feat(stateful): complete state checkpointing implementation (8b14780)
• feat(stateful): implement stateful processing (Task 1.1-1.3) (e40d1bd)
• Update task statuses and format dependencies in tasks.json (7c4ef5b)
• Add comprehensive prompts from lattice project (fa8114a)
• Initialize TaskMaster with comprehensive roadmap (d5e3277)
• Add chrome-devtools MCP server (d5869fa)
• Add Taskmaster MCP server setup for task management (74ed6db)
• Fix clippy collapsible_if warning in file consumer (85759c0)
• Refactor CI workflows to streamline Rust setup and improve clarity (1a83790)
• Refactor consumer and producer configurations for consistency (216ef62)
• Update README.md to include new CI and code coverage badges (b3af525)

---

📦 Install from crates.io:

[dependencies]
streamweave = "0.2.0"

📚 Documentation: docs.rs/streamweave

What's Changed

Other Changes

• fix(deps): Add MIT-0 license to allowed licenses in cargo-deny by @Industrial in #12
• fix(deps): Add MIT-0 license to allowed licenses in cargo-deny by @Industrial in #13
• chore(ci): Clean up WASM build section in CI workflow by @Industrial in #14
• fix: ci yml by @Industrial in #15
• fix: random number tests by @Industrial in #16

New Contributors

• @dependabot[bot] made their first contribution in #9
• @Industrial made their first contribution in #12

Full Changelog: v0.1.0...v0.2.0