Philipp Oppermann
|
f0e31e2cc6
|
Report results of spawned nodes as events
|
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
|
672fb4d0b4
|
Close connections on errors
|
3 years ago |
Philipp Oppermann
|
ce4e5a1616
|
Send metadata through TCP for now
|
3 years ago |
Philipp Oppermann
|
1724c86af8
|
Also treat `BrokenPipe` error as stopped connection
|
3 years ago |
Philipp Oppermann
|
a0d0b21c1b
|
Map outputs to inputs of local nodes
|
3 years ago |
Philipp Oppermann
|
0ae5fc2ffa
|
Add dataflow ID to daemon messages
|
3 years ago |
Philipp Oppermann
|
cc1dc971ed
|
Update dora-coordinator to start dataflows through dora-daemon
|
3 years ago |
Philipp Oppermann
|
5ae18eae4c
|
Include dataflow ID in daemon to avoid node ID conflicts
|
3 years ago |
Philipp Oppermann
|
e5d7ac55e2
|
Bundle all nodes of a single machine in a single daemon spawn command
Avoids synchronization issues, e.g. if one node sends outputs before the receiver was launched and registered.
|
3 years ago |
Philipp Oppermann
|
3312af1941
|
Connect to dora-coordinator and implement command to spawn nodes
|
3 years ago |
Philipp Oppermann
|
2e7ef8b630
|
Implement shared memory mapping in node API
|
3 years ago |
Philipp Oppermann
|
e36f15e369
|
Add support to subscribe to messages in daemon
|
3 years ago |
Philipp Oppermann
|
c2e4948dd5
|
Update Rust node API to communicate through dora-daemon
|
3 years ago |
Philipp Oppermann
|
7d85b92b2a
|
Connect to dora-daemon from node API and register with node ID
|
3 years ago |
Philipp Oppermann
|
f7c6cca943
|
Move port number constant to `dora-core`
|
3 years ago |
Philipp Oppermann
|
9b65739ead
|
Start creating a `dora-daemon`
|
3 years ago |