From c6b671b4ee1ad645655b9133ed82b4b043b2756e Mon Sep 17 00:00:00 2001
From: haixuanTao <tao.xavier@outlook.com>
Date: Fri, 29 Jul 2022 13:35:36 +0200
Subject: [PATCH] moving `node` examples into a specific folder

---
 binaries/coordinator/Cargo.toml                      | 12 ++++++++++++
 .../coordinator/examples/nodes/python/printer.py     |  9 +++++++++
 binaries/coordinator/examples/nodes/python/timer.py  | 10 ++++++++++
 .../examples/{ => nodes/rust}/random_number.rs       |  0
 .../examples/{ => nodes/rust}/rate_limit.rs          |  0
 .../rust/sink_logger.rs}                             |  0
 .../rust/source_timer.rs}                            |  0
 7 files changed, 31 insertions(+)
 create mode 100644 binaries/coordinator/examples/nodes/python/printer.py
 create mode 100644 binaries/coordinator/examples/nodes/python/timer.py
 rename binaries/coordinator/examples/{ => nodes/rust}/random_number.rs (100%)
 rename binaries/coordinator/examples/{ => nodes/rust}/rate_limit.rs (100%)
 rename binaries/coordinator/examples/{example_sink_logger.rs => nodes/rust/sink_logger.rs} (100%)
 rename binaries/coordinator/examples/{example_source_timer.rs => nodes/rust/source_timer.rs} (100%)

diff --git a/binaries/coordinator/Cargo.toml b/binaries/coordinator/Cargo.toml
index 1dcca35e..03c35919 100644
--- a/binaries/coordinator/Cargo.toml
+++ b/binaries/coordinator/Cargo.toml
@@ -22,3 +22,15 @@ time = "0.3.9"
 futures-concurrency = "2.0.3"
 rand = "0.8.5"
 dora-core = { version = "0.1.0", path = "../../libraries/core" }
+
+[[example]]
+name = "source_timer"
+path = "examples/nodes/rust/source_timer.rs"
+
+[[example]]
+name = "sink_logger"
+path = "examples/nodes/rust/sink_logger.rs"
+
+[[example]]
+name = "random_number"
+path = "examples/nodes/rust/random_number.rs"
diff --git a/binaries/coordinator/examples/nodes/python/printer.py b/binaries/coordinator/examples/nodes/python/printer.py
new file mode 100644
index 00000000..1a782847
--- /dev/null
+++ b/binaries/coordinator/examples/nodes/python/printer.py
@@ -0,0 +1,9 @@
+from dora import PyDoraNode
+
+node = PyDoraNode.init_from_env()
+
+for i in range(100):
+    value = node.next()
+    print(value) if value is not [] else None
+
+print("printer finished")
diff --git a/binaries/coordinator/examples/nodes/python/timer.py b/binaries/coordinator/examples/nodes/python/timer.py
new file mode 100644
index 00000000..4ac1596c
--- /dev/null
+++ b/binaries/coordinator/examples/nodes/python/timer.py
@@ -0,0 +1,10 @@
+from dora import PyDoraNode
+
+node = PyDoraNode.init_from_env()
+import time
+
+for i in range(100):
+    node.send_output("time", b"awef")
+    time.sleep(0.1)
+
+print("printer finished")
diff --git a/binaries/coordinator/examples/random_number.rs b/binaries/coordinator/examples/nodes/rust/random_number.rs
similarity index 100%
rename from binaries/coordinator/examples/random_number.rs
rename to binaries/coordinator/examples/nodes/rust/random_number.rs
diff --git a/binaries/coordinator/examples/rate_limit.rs b/binaries/coordinator/examples/nodes/rust/rate_limit.rs
similarity index 100%
rename from binaries/coordinator/examples/rate_limit.rs
rename to binaries/coordinator/examples/nodes/rust/rate_limit.rs
diff --git a/binaries/coordinator/examples/example_sink_logger.rs b/binaries/coordinator/examples/nodes/rust/sink_logger.rs
similarity index 100%
rename from binaries/coordinator/examples/example_sink_logger.rs
rename to binaries/coordinator/examples/nodes/rust/sink_logger.rs
diff --git a/binaries/coordinator/examples/example_source_timer.rs b/binaries/coordinator/examples/nodes/rust/source_timer.rs
similarity index 100%
rename from binaries/coordinator/examples/example_source_timer.rs
rename to binaries/coordinator/examples/nodes/rust/source_timer.rs