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