Philipp Oppermann
f473c856c1
Fix clippy warnings across whole projects
3 years ago
Philipp Oppermann
c54209ff98
Pass `SendOutput` by reference
3 years ago
Philipp Oppermann
933affaf16
Rename type
3 years ago
Philipp Oppermann
dcd3f8f18d
Rework raw operator API to support the `#[ffi_export]` attribute of `safer-ffi`
Requires removing the lifetime of the `SendOutput` type. We now use a `'static` Arc-owned closure instead.
To make sure that all types show up in the C header files that we'll generate, we make sure that all the top-level types use `#[repr(C)]` instead of `#[repr(transparent)]`.
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
8e21a990d0
Create a Rust dataflow example
The example shows how to use the dora node and operator APIs.
4 years ago
Philipp Oppermann
825e9a8d7b
Allow operators to stop themselves through a special return value
Useful for source operators that take timers as inputs. Without an explicit stop instructions, they would always run forever.
4 years ago
haixuanTao
28a902d83a
Moving folders in correspondance with #41
Simply moving crate to mirror our discussion without touching at names
4 years ago