summaryrefslogtreecommitdiff
path: root/tests/benchmarks
diff options
context:
space:
mode:
Diffstat (limited to 'tests/benchmarks')
l---------tests/benchmarks/deadletters/main.go1
-rw-r--r--tests/benchmarks/deadletters/q.go24
l---------tests/benchmarks/lookup/main.go1
-rw-r--r--tests/benchmarks/lookup/q.go24
l---------tests/benchmarks/multiple-consumers/main.go1
-rw-r--r--tests/benchmarks/multiple-consumers/q.go24
l---------tests/benchmarks/multiple-produces/main.go1
-rw-r--r--tests/benchmarks/multiple-produces/q.go24
l---------tests/benchmarks/reaper/main.go1
-rw-r--r--tests/benchmarks/reaper/q.go24
l---------tests/benchmarks/replay/main.go1
-rw-r--r--tests/benchmarks/replay/q.go24
l---------tests/benchmarks/single-consumer/main.go1
-rw-r--r--tests/benchmarks/single-consumer/q.go24
l---------tests/benchmarks/single-producer/main.go1
-rw-r--r--tests/benchmarks/single-producer/q.go24
l---------tests/benchmarks/subscribe/main.go1
-rw-r--r--tests/benchmarks/subscribe/q.go24
l---------tests/benchmarks/unsubscribe/main.go1
-rw-r--r--tests/benchmarks/unsubscribe/q.go24
l---------tests/benchmarks/waiter/main.go1
-rw-r--r--tests/benchmarks/waiter/q.go24
22 files changed, 275 insertions, 0 deletions
diff --git a/tests/benchmarks/deadletters/main.go b/tests/benchmarks/deadletters/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/deadletters/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/deadletters/q.go b/tests/benchmarks/deadletters/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/deadletters/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/lookup/main.go b/tests/benchmarks/lookup/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/lookup/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/lookup/q.go b/tests/benchmarks/lookup/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/lookup/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/multiple-consumers/main.go b/tests/benchmarks/multiple-consumers/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/multiple-consumers/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/multiple-consumers/q.go b/tests/benchmarks/multiple-consumers/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/multiple-consumers/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/multiple-produces/main.go b/tests/benchmarks/multiple-produces/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/multiple-produces/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/multiple-produces/q.go b/tests/benchmarks/multiple-produces/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/multiple-produces/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/reaper/main.go b/tests/benchmarks/reaper/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/reaper/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/reaper/q.go b/tests/benchmarks/reaper/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/reaper/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/replay/main.go b/tests/benchmarks/replay/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/replay/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/replay/q.go b/tests/benchmarks/replay/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/replay/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/single-consumer/main.go b/tests/benchmarks/single-consumer/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/single-consumer/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/single-consumer/q.go b/tests/benchmarks/single-consumer/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/single-consumer/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/single-producer/main.go b/tests/benchmarks/single-producer/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/single-producer/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/single-producer/q.go b/tests/benchmarks/single-producer/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/single-producer/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/subscribe/main.go b/tests/benchmarks/subscribe/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/subscribe/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/subscribe/q.go b/tests/benchmarks/subscribe/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/subscribe/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/unsubscribe/main.go b/tests/benchmarks/unsubscribe/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/unsubscribe/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/unsubscribe/q.go b/tests/benchmarks/unsubscribe/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/unsubscribe/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
diff --git a/tests/benchmarks/waiter/main.go b/tests/benchmarks/waiter/main.go
new file mode 120000
index 0000000..f67563d
--- /dev/null
+++ b/tests/benchmarks/waiter/main.go
@@ -0,0 +1 @@
+../../main.go \ No newline at end of file
diff --git a/tests/benchmarks/waiter/q.go b/tests/benchmarks/waiter/q.go
new file mode 100644
index 0000000..0c203bb
--- /dev/null
+++ b/tests/benchmarks/waiter/q.go
@@ -0,0 +1,24 @@
+package q
+
+import (
+ "flag"
+ "time"
+)
+
+
+
+var nFlag = flag.Int(
+ "n",
+ 1_000,
+ "The number of iterations to execute",
+)
+
+func MainTest() {
+ // FIXME
+ flag.Parse()
+ n := *nFlag
+
+ for i := 0; i < n; i++ {
+ time.Sleep(time.Millisecond * 1)
+ }
+}
generated by cgit v1.2.3 (git 2.49.0) at 2025-07-21 17:19:44 +0000