Philipp Oppermann
2495218cd3
Merge branch 'main' into url-source
3 years ago
Philipp Oppermann
0b00955ef4
Fix panic in tokio runtime
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
a37d3ee6c8
Don't parse operator source always as URI
Parsing as URI does not work for relative paths, e.g. `../../foo`.
3 years ago
Philipp Oppermann
13d3a91683
Implement support for downloading operator sources
Makes it possible to set an URL as operator source. The `dora-runtime` will then try to download the operator from the given URL when the dataflow is started.
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
5d89f81d86
Refactor control API as zenoh queries
Allows replying to requests. We use this to send the dataflow UUID back to the CLI after starting it.
3 years ago
Xavier Tao
44a7c16c21
Add Python Node API metadata ( #101 )
* Add a `dora-python-operator` crate to hold utils functions for dora python
* Remove python serialisation and deserialisation from `dora-runtime`
* Update `python` documentation
3 years ago
Philipp Oppermann
d8ff999dac
Merge pull request #97 from dora-rs/cli-start
Implement CLI `start` and `destroy` and make coordinator a daemon
3 years ago
haixuanTao
f98859bfc4
Adding `metrics` feature to `dora-runtime`
3 years ago
Philipp Oppermann
801e965dc8
Merge branch 'main' into cli-start
3 years ago
Xavier Tao
c2bb4c1f67
Runtime tracing ( #95 )
* add opentelemetry feature to python op
* modify `python-dataflow` to test opentelemetry
* change `timer` topic to `tick`
* adding tracing to `shared_libraries`
* example install refactoring
* Rename `input` to `dora_input` for python ex
3 years ago
Philipp Oppermann
963f39fa99
Implement cli `destroy` command using zenoh-based control channel
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
a31036eabf
Update cli to clap v4
3 years ago
Philipp Oppermann
4e30103215
Add a `--open` option `graph` command to open graph in browser automatically
3 years ago
Philipp Oppermann
b266b82b7c
Render graph as HTML to allow opening it in browser directly
3 years ago
Philipp Oppermann
6ab39e229b
Don't serialize data to provide true zero-copy reading and writing
3 years ago
Philipp Oppermann
d57cafadc4
Implement `dora graph` subcommand based on coordinator visualization code
3 years ago
Philipp Oppermann
4ed7eb2faa
Start creating boilerplate for new cli binary
3 years ago
Philipp Oppermann
7e9c3050f9
Use `tracing` for logging state of nodes, coordinator, and runtimes
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
848e136a75
Move communication layer implementation into separate library
To make it usable for other projects.
3 years ago
Philipp Oppermann
de2481d2cb
Update python node API to work with synchronous Rust node API
3 years ago
Philipp Oppermann
63cb32ed46
Make icoryx and zenoh communication layers optional
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
a2fd5b0ebd
Autogenerate the `operator_api.h` header file
3 years ago
Philipp Oppermann
1bf0be0140
Switch back to upstream version of `safer-ffi`
3 years ago
Philipp Oppermann
b0cf6fa4f5
Rework raw operator API on top of `safer-api` crate
Allows a higher-level interface
3 years ago
Philipp Oppermann
f5c1ddee8c
Avoid UNC paths on Windows
3 years ago
Philipp Oppermann
b7382c91f5
Merge pull request #66 from dora-rs/c++-example
Create C++ example dataflow
3 years ago
Philipp Oppermann
17f7af7e2b
Update zenoh version to latest `master` commit
3 years ago
Philipp Oppermann
331e521f5d
Add an example C++ operator based on the Rust API
3 years ago
Philipp Oppermann
4b383a18b8
Rename c++ example crate
3 years ago
Philipp Oppermann
09866cbb2b
Create an example C++ node based on Rust node API and `cxx` crate
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
Philipp Oppermann
3fa0c4bf81
Add a `c-dataflow` example
3 years ago
Philipp Oppermann
b2577acf14
Implement API functions for reading inputs and sending outputs
3 years ago
Philipp Oppermann
370cadee6b
Start creating a staticlib with a node API for C
3 years ago
Philipp Oppermann
474c1e2465
Remove unused dependency
3 years ago
Philipp Oppermann
3c8ee37795
Implement parsing of new dora timer input keys
3 years ago
haixuanTao
366ec10b1a
Adding `extension-module` for pyo3 extension
3 years ago
haixuanTao
9000e68111
Adding `__iter__` function
3 years ago
haixuanTao
f7d288ba69
init `dora-node-api-python`
3 years ago
haixuanTao
251fe6b20f
Replaced `dora-common` with `dora-core`
3 years ago
haixuanTao
c55ba344bd
Removing `git` repo in `cargo` in preparation of release
3 years ago