Philipp Oppermann
bb8d6edb40
Use more reliable `InputClosed` event instead of timer as exit condition
We might not receive any `random` input if the startup of the operator is delayed and the source node is already finished.
2 years ago
Philipp Oppermann
62319f1ec1
Add support for Rust operators again
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
Philipp Oppermann
f43809f993
Reduce log output
2 years ago
Philipp Oppermann
556e2e2ec2
Unify daemon listener implementations to avoid code duplication
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
5db784ff27
Move descriptor reading to dora daemon + add cli arg to run dataflow
3 years ago
Philipp Oppermann
611103b211
Add more logging to `rust-dataflow` example
3 years ago
Philipp Oppermann
550062917b
Create test/examples entry point for daemon and use it to run rust-dataflow example
3 years ago
Philipp Oppermann
33c4cc0b60
Fix: enable required node-api features for examples
3 years ago
Philipp Oppermann
871a4bc3dc
Decrease timer frequency in rust dataflow example
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
a10fd0b1cb
Implement timer messages
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
Philipp Oppermann
2e7ef8b630
Implement shared memory mapping in node API
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
2495218cd3
Merge branch 'main' into url-source
3 years ago
Philipp Oppermann
8fbe60acf0
Merge branch 'main' into uhlc
3 years ago
Philipp Oppermann
64cf49703b
Implement download support for custom nodes
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
46ec035764
Add a daemon mode for coordinator
3 years ago
Philipp Oppermann
2a9495cb68
Merge pull request #84 from dora-rs/cli
Start creating command line interface with `check`, `build`, `graph` and `templates` commands
3 years ago
Philipp Oppermann
dd50d2ebd8
Add support for build command to nodes and operator definitions
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
f473c856c1
Fix clippy warnings across whole projects
3 years ago
Philipp Oppermann
71c3b9436d
Run examples in debug mode to speed up compilation
3 years ago
Philipp Oppermann
03348c5be8
Redesign communication layer to be synchronous and add support for iceoryx
3 years ago
Philipp Oppermann
9866328bf8
Merge branch 'main' into safer-ffi
3 years ago
Philipp Oppermann
76964d09cc
Update rust-dataflow example for new operator API
3 years ago
Philipp Oppermann
3fbe544115
Add shared library prefix and extension automatically
3 years ago
Philipp Oppermann
596e713045
Check format of received messages in sink example
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