Use the new node syntax for examples dataflow

examples/benchmark/dataflow.yml

@@ -1,15 +1,14 @@
 nodes:
  - id: rust-node
- custom:
-  build: cargo build -p benchmark-example-node --release
-  source: ../../target/release/benchmark-example-node
- outputs:
-  - latency
- - throughput
+ build: cargo build -p benchmark-example-node --release
+ path: ../../target/release/benchmark-example-node
+ outputs:
+ - latency
+ - throughput
+
  - id: rust-sink
- custom:
- build: cargo build -p benchmark-example-sink --release
- source: ../../target/release/benchmark-example-sink
- inputs:
- latency: rust-node/latency
- throughput: rust-node/throughput
+ build: cargo build -p benchmark-example-sink --release
+ path: ../../target/release/benchmark-example-sink
+ inputs:
+ latency: rust-node/latency
+ throughput: rust-node/throughput

examples/c++-dataflow/dataflow.yml

@@ -1,18 +1,17 @@
 nodes:
  - id: cxx-node-rust-api
- custom:
-  source: build/node_rust_api
- inputs:
-  tick: dora/timer/millis/300
- outputs:
- - counter
+ path: build/node_rust_api
+ inputs:
+ tick: dora/timer/millis/300
+ outputs:
+ - counter
+
  - id: cxx-node-c-api
- custom:
- source: build/node_c_api
- inputs:
- tick: cxx-node-rust-api/counter
- outputs:
- - counter
+ path: build/node_c_api
+ inputs:
+ tick: cxx-node-rust-api/counter
+ outputs:
+ - counter
 
  - id: runtime-node-1
  operators:
@@ -23,6 +22,7 @@ nodes:
  counter_2: cxx-node-rust-api/counter
  outputs:
  - status
+
  - id: runtime-node-2
  operators:
  - id: operator-c-api

examples/c++-ros2-dataflow/dataflow.yml

@@ -1,8 +1,7 @@
 nodes:
  - id: cxx-node-rust-api
- custom:
- source: build/node_rust_api
- inputs:
- tick: dora/timer/millis/500
- outputs:
- - pose
+ path: build/node_rust_api
+ inputs:
+ tick: dora/timer/millis/500
+ outputs:
+ - pose

examples/c-dataflow/dataflow.yml

@@ -1,11 +1,11 @@
 nodes:
  - id: c_node
- custom:
-  source: build/c_node
- inputs:
-  timer: dora/timer/millis/50
- outputs:
- - message
+ path: build/c_node
+ inputs:
+ timer: dora/timer/millis/50
+ outputs:
+ - message
+
  - id: runtime-node
  operators:
  - id: c_operator
@@ -14,8 +14,8 @@ nodes:
  message: c_node/message
  outputs:
  - counter
+
  - id: c_sink
- custom:
- source: build/c_sink
- inputs:
- counter: runtime-node/c_operator/counter
+ path: build/c_sink
+ inputs:
+ counter: runtime-node/c_operator/counter

examples/cmake-dataflow/dataflow.yml

@@ -1,18 +1,17 @@
 nodes:
  - id: cxx-node-rust-api
- custom:
-  source: bin/node_rust_api
- inputs:
-  tick: dora/timer/millis/300
- outputs:
- - counter
+ path: bin/node_rust_api
+ inputs:
+ tick: dora/timer/millis/300
+ outputs:
+ - counter
+
  - id: cxx-node-c-api
- custom:
- source: bin/node_c_api
- inputs:
- tick: dora/timer/millis/300
- outputs:
- - counter
+ path: bin/node_c_api
+ inputs:
+ tick: dora/timer/millis/300
+ outputs:
+ - counter
 
  - id: runtime-node-1
  operators:
@@ -23,6 +22,7 @@ nodes:
  counter_2: cxx-node-rust-api/counter
  outputs:
  - status
+
  - id: runtime-node-2
  operators:
  - id: operator-c-api

examples/multiple-daemons/dataflow.yml

@@ -2,13 +2,13 @@ nodes:
  - id: rust-node
  _unstable_deploy:
  machine: A
- custom:
-  build: cargo build -p multiple-daemons-example-node
-  source: ../../target/debug/multiple-daemons-example-node
- inputs:
-  tick: dora/timer/millis/10
- outputs:
- - random
+ build: cargo build -p multiple-daemons-example-node
+ path: ../../target/debug/multiple-daemons-example-node
+ inputs:
+ tick: dora/timer/millis/10
+ outputs:
+ - random
+
  - id: runtime-node
  _unstable_deploy:
  machine: A
@@ -21,11 +21,11 @@ nodes:
  random: rust-node/random
  outputs:
  - status
+
  - id: rust-sink
  _unstable_deploy:
  machine: B
- custom:
- build: cargo build -p multiple-daemons-example-sink
- source: ../../target/debug/multiple-daemons-example-sink
- inputs:
- message: runtime-node/rust-operator/status
+ build: cargo build -p multiple-daemons-example-sink
+ path: ../../target/debug/multiple-daemons-example-sink
+ inputs:
+ message: runtime-node/rust-operator/status

examples/python-ros2-dataflow/dataflow.yml

@@ -1,17 +1,15 @@
 nodes:
  - id: turtle
- custom:
- source: ./random_turtle.py
- inputs:
- direction: control/direction
- outputs:
- - turtle_pose
+ path: ./random_turtle.py
+ inputs:
+ direction: control/direction
+ outputs:
+ - turtle_pose
 
  - id: control
- custom:
- source: ./control_node.py
- inputs:
- turtle_pose: turtle/turtle_pose
- tick: dora/timer/millis/500
- outputs:
- - direction
+ path: ./control_node.py
+ inputs:
+ turtle_pose: turtle/turtle_pose
+ tick: dora/timer/millis/500
+ outputs:
+ - direction

examples/rust-dataflow-url/dataflow.yml

@@ -1,11 +1,11 @@
 nodes:
  - id: rust-node
- custom:
-  source: https://github.com/dora-rs/dora/releases/download/v0.0.0-test.4/rust-dataflow-example-node
- inputs:
-  tick: dora/timer/millis/300
- outputs:
- - random
+ path: https://github.com/dora-rs/dora/releases/download/v0.0.0-test.4/rust-dataflow-example-node
+ inputs:
+ tick: dora/timer/millis/300
+ outputs:
+ - random
+
  - id: runtime-node
  operators:
  - id: rust-operator
@@ -15,9 +15,9 @@ nodes:
  random: rust-node/random
  outputs:
  - status
+
  - id: rust-sink
- custom:
- build: cargo build -p rust-dataflow-example-sink
- source: ../../target/debug/rust-dataflow-url-example-sink
- inputs:
- message: runtime-node/rust-operator/status
+ build: cargo build -p rust-dataflow-example-sink
+ path: ../../target/debug/rust-dataflow-url-example-sink
+ inputs:
+ message: runtime-node/rust-operator/status

examples/rust-dataflow/dataflow.yml

@@ -6,20 +6,22 @@ nodes:
  tick: dora/timer/millis/10
  outputs:
  - random
+
  - id: rust-status-node
- custom:
-  build: cargo build -p rust-dataflow-example-status-node
-  source: ../../target/debug/rust-dataflow-example-status-node
- inputs:
-  tick: dora/timer/millis/100
-  random: rust-node/random
- outputs:
- - status
+ build: cargo build -p rust-dataflow-example-status-node
+ path: ../../target/debug/rust-dataflow-example-status-node
+ inputs:
+ tick: dora/timer/millis/100
+ random: rust-node/random
+ outputs:
+ - status
+
  - id: rust-sink
  build: cargo build -p rust-dataflow-example-sink
  path: ../../target/debug/rust-dataflow-example-sink
  inputs:
  message: rust-status-node/status
+
  - id: dora-record
  build: cargo build -p dora-record
  path: ../../target/debug/dora-record

examples/rust-dataflow/dataflow_dynamic.yml

@@ -1,31 +1,30 @@
 nodes:
  - id: rust-node
- custom:
-  build: cargo build -p rust-dataflow-example-node
-  source: ../../target/debug/rust-dataflow-example-node
- inputs:
-  tick: dora/timer/millis/100
- outputs:
- - random
+ build: cargo build -p rust-dataflow-example-node
+ path: ../../target/debug/rust-dataflow-example-node
+ inputs:
+ tick: dora/timer/millis/100
+ outputs:
+ - random
+
  - id: rust-status-node
- custom:
-  build: cargo build -p rust-dataflow-example-status-node
-  source: ../../target/debug/rust-dataflow-example-status-node
- inputs:
-  tick: dora/timer/millis/100
-  random: rust-node/random
- outputs:
- - status
+ build: cargo build -p rust-dataflow-example-status-node
+ path: ../../target/debug/rust-dataflow-example-status-node
+ inputs:
+ tick: dora/timer/millis/100
+ random: rust-node/random
+ outputs:
+ - status
+
  - id: rust-sink-dynamic
- custom:
-  build: cargo build -p rust-dataflow-example-sink-dynamic
-  source: dynamic
- inputs:
- message: rust-status-node/status
+ build: cargo build -p rust-dataflow-example-sink-dynamic
+ path: dynamic
+ inputs:
+ message: rust-status-node/status
+
  - id: dora-record
- custom:
- build: cargo build -p dora-record
- source: ../../target/debug/dora-record
- inputs:
- message: rust-status-node/status
- random: rust-node/random
+ build: cargo build -p dora-record
+ path: ../../target/debug/dora-record
+ inputs:
+ message: rust-status-node/status
+ random: rust-node/random

examples/rust-dataflow/dataflow_socket.yml

@@ -1,7 +1,6 @@
 communication:
- _unstable_local:
- UnixDomain
-
+ _unstable_local: UnixDomain
+
 nodes:
  - id: rust-node
  build: cargo build -p rust-dataflow-example-node
@@ -10,20 +9,22 @@ nodes:
  tick: dora/timer/millis/10
  outputs:
  - random
+
  - id: rust-status-node
- custom:
-  build: cargo build -p rust-dataflow-example-status-node
-  source: ../../target/debug/rust-dataflow-example-status-node
- inputs:
-  tick: dora/timer/millis/100
-  random: rust-node/random
- outputs:
- - status
+ build: cargo build -p rust-dataflow-example-status-node
+ path: ../../target/debug/rust-dataflow-example-status-node
+ inputs:
+ tick: dora/timer/millis/100
+ random: rust-node/random
+ outputs:
+ - status
+
  - id: rust-sink
  build: cargo build -p rust-dataflow-example-sink
  path: ../../target/debug/rust-dataflow-example-sink
  inputs:
  message: rust-status-node/status
+
  - id: dora-record
  build: cargo build -p dora-record
  path: ../../target/debug/dora-record

examples/rust-ros2-dataflow/dataflow.yml

@@ -1,10 +1,9 @@
 nodes:
  - id: rust-node
- custom:
- build: cargo build -p rust-ros2-dataflow-example-node --features ros2
- source: ../../target/debug/rust-ros2-dataflow-example-node
- inputs:
- tick: dora/timer/millis/500
- service_timer: dora/timer/secs/1
- outputs:
- - pose
+ build: cargo build -p rust-ros2-dataflow-example-node --features ros2
+ path: ../../target/debug/rust-ros2-dataflow-example-node
+ inputs:
+ tick: dora/timer/millis/500
+ service_timer: dora/timer/secs/1
+ outputs:
+ - pose