Chrislearn Young
26f9973ae3
cargo fmt
5 months ago
Chrislearn Young
bcf591deb4
Remove rust--toolchain.toml and use rust-version in Cargo.toml
6 months ago
haixuantao
d155ee789a
Fix stop in example nodes
7 months ago
yjhmelody
ca614753a1
chore: use workspace edition
1 year ago
Philipp Oppermann
3ec1e45119
Ensure that we don't publish example crates
1 year ago
Philipp Oppermann
89f980e753
Simplify arrow array construction through new `IntoArrow` trait
2 years ago
Philipp Oppermann
6154415cbc
Update Rust APIs and rust-dataflow-example to use arrow types
2 years ago
Philipp Oppermann
e3d0e0c82e
Enable node tracing for dataflow example
2 years ago
Philipp Oppermann
d334c6f243
Make `daemon` module of Rust node API private and reexport symbols
2 years ago
Philipp Oppermann
1e07a73a64
Merge branch 'main' into unify-nodes-and-operators
2 years ago
dependabot[bot]
b74a524031
Bump tokio from 1.23.1 to 1.24.2
Bumps [tokio](https://github.com/tokio-rs/tokio ) from 1.23.1 to 1.24.2.
- [Release notes](https://github.com/tokio-rs/tokio/releases )
- [Commits](https://github.com/tokio-rs/tokio/commits )
---
updated-dependencies:
- dependency-name: tokio
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <support@github.com>
3 years ago
dependabot[bot]
ae161e644c
Bump tokio from 1.21.2 to 1.23.1
Bumps [tokio](https://github.com/tokio-rs/tokio ) from 1.21.2 to 1.23.1.
- [Release notes](https://github.com/tokio-rs/tokio/releases )
- [Commits](https://github.com/tokio-rs/tokio/compare/tokio-1.21.2...tokio-1.23.1 )
---
updated-dependencies:
- dependency-name: tokio
dependency-type: direct:production
...
Signed-off-by: dependabot[bot] <support@github.com>
3 years ago
Philipp Oppermann
7888b7d0e4
Remove uneeded breaks from other examples too
3 years ago
Philipp Oppermann
df5dcfb342
Merge branch 'main' into unify-nodes-and-operators
3 years ago
Philipp Oppermann
33c4cc0b60
Fix: enable required node-api features for examples
3 years ago
Philipp Oppermann
424561e74b
Update rust-dataflow example to work with latest daemon code
3 years ago
Philipp Oppermann
3cd1b4de65
Notify downstream nodes about closed inputs
3 years ago
Philipp Oppermann
433b7b4ed7
Merge branch 'main' into unify-nodes-and-operators
3 years ago
Philipp Oppermann
ce4fd8b027
Set dora subcrate dependencies as workspace dependencies
3 years ago
Philipp Oppermann
d8260d5d2c
Inherit package version from workspace root
This way, we don't need to update the version manually in all sub-crates on every release.
3 years ago
haixuanTao
9a0b303e98
Replace all versions to `v0.1.1`
3 years ago
Philipp Oppermann
d01dc38134
Update nodes of rust example to new API
3 years ago
Philipp Oppermann
5375628930
Allow operators to stop the full dataflow
Useful in case of emergencies.
3 years ago
Philipp Oppermann
8fbe60acf0
Merge branch 'main' into uhlc
3 years ago
Philipp Oppermann
c4da2cbdad
Refactor: Move configuration to `core` crate
3 years ago
Philipp Oppermann
1c1891446a
Add `uhlc` timestamp to message metadata
3 years ago
Philipp Oppermann
6ab39e229b
Don't serialize data to provide true zero-copy reading and writing
3 years ago
Philipp Oppermann
0df06fce86
Send metadata in messages encoded with capnproto
Changes the message format from raw data bytes to a higher-level `Message` struct serialized with capnproto. In addition to the raw data, which is sent as a byte array as before, the `Message` struct features `metadata` field. This metadata field can be used to pass open telemetry contexts, deadlines, etc.
3 years ago
Philipp Oppermann
03348c5be8
Redesign communication layer to be synchronous and add support for iceoryx
3 years ago
Philipp Oppermann
8e21a990d0
Create a Rust dataflow example
The example shows how to use the dora node and operator APIs.
3 years ago