Philipp Oppermann
631019f8d3
Fix some clippy warnings
2 years ago
Philipp Oppermann
9a10280595
Simplify reading of primitive and string types from arrow arrays
- introduce a new `ArrayData` wrapper struct
- implement `TryFrom` to convert to primitive types and strings
- update examples to use the new conversion functions
2 years ago
Philipp Oppermann
6154415cbc
Update Rust APIs and rust-dataflow-example to use arrow types
2 years ago
Philipp Oppermann
7d96e03eed
Start to make Rust node API typed using arrow
2 years ago
Philipp Oppermann
62319f1ec1
Add support for Rust operators again
3 years ago
Philipp Oppermann
d334c6f243
Make `daemon` module of Rust node API private and reexport symbols
3 years ago
Philipp Oppermann
7888b7d0e4
Remove uneeded breaks from other examples too
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
2e7ef8b630
Implement shared memory mapping in node API
3 years ago
Philipp Oppermann
d01dc38134
Update nodes of rust example to new API
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
03348c5be8
Redesign communication layer to be synchronous and add support for iceoryx
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