summaryrefslogtreecommitdiff
path: root/opendc-experiments/opendc-experiments-base/src/test
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2022-10-04 10:04:50 +0200
committerGitHub <noreply@github.com>2022-10-04 10:04:50 +0200
commit92cc0908b7ad6c94b08e6016f8815ab07cd1714d (patch)
treeb5edaff69212986265f9edc620e40bb8695f11eb /opendc-experiments/opendc-experiments-base/src/test
parent2d2a3854d355bd4b074ef651f291d34081e70d96 (diff)
parentbd476d11ab24fe745bb54e97a11133706bb96cb1 (diff)
merge: Add provisioning tool for experiments (#104)
This pull request implements a new tool to help provision and manage the experimental environment. ## Implementation Notes :hammer_and_pick: * Add service registry for cloud services * Add provisioning tool for experiments * Add provisioning step for workflow service * Add provisioners for FaaS service * Use experiment base for Capelin experiments * Use experiment base for web runner * Integrate compute workload classes * Remove Topology interface ## Breaking API Changes :warning: * Removal of the `opendc-compute-workload`, `opendc-faas-workload`, and `opendc-workflow-workload` modules. These are now located inside `opendc-experiments` * Removal of `ComputeServiceHelper`. Use `Provisioner` to provision a `ComputeService`.
Diffstat (limited to 'opendc-experiments/opendc-experiments-base/src/test')
-rw-r--r--opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/ServiceRegistryTest.kt111
1 files changed, 111 insertions, 0 deletions
diff --git a/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/ServiceRegistryTest.kt b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/ServiceRegistryTest.kt
new file mode 100644
index 00000000..f69c07c1
--- /dev/null
+++ b/opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/ServiceRegistryTest.kt
@@ -0,0 +1,111 @@
+/*
+ * Copyright (c) 2022 AtLarge Research
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
+package org.opendc.experiments
+
+import org.junit.jupiter.api.Assertions.*
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.assertThrows
+import org.opendc.experiments.internal.ServiceRegistryImpl
+
+/**
+ * Test suite for the [ServiceRegistry] implementation.
+ */
+class ServiceRegistryTest {
+ @Test
+ fun testRetrievalSuccess() {
+ val registry = ServiceRegistryImpl()
+
+ registry.register("opendc.org", String::class.java, "Comment")
+
+ assertEquals("Comment", registry.resolve("opendc.org", String::class.java))
+ }
+
+ @Test
+ fun testRetrievalFailure() {
+ val registry = ServiceRegistryImpl()
+ assertNull(registry.resolve("opendc.org", String::class.java))
+ }
+
+ @Test
+ fun testDuplicate() {
+ val registry = ServiceRegistryImpl()
+
+ registry.register("opendc.org", String::class.java, "Comment")
+
+ assertThrows<IllegalStateException> { registry.register("opendc.org", String::class.java, "Comment2") }
+ }
+
+ @Test
+ fun testRemove() {
+ val registry = ServiceRegistryImpl()
+
+ registry.register("opendc.org", String::class.java, "Comment")
+ registry.remove("opendc.org", String::class.java)
+
+ assertAll(
+ { assertDoesNotThrow { registry.remove("opendc.org", String::class.java) } },
+ { assertNull(registry.resolve("opendc.org", String::class.java)) }
+ )
+ }
+
+ @Test
+ fun testRemoveNonExistent() {
+ val registry = ServiceRegistryImpl()
+
+ assertAll(
+ { assertNull(registry.resolve("opendc.org", String::class.java)) },
+ { assertDoesNotThrow { registry.remove("opendc.org", String::class.java) } }
+ )
+ }
+
+ @Test
+ fun testRemoveAll() {
+ val registry = ServiceRegistryImpl()
+
+ registry.register("opendc.org", String::class.java, "Comment")
+ registry.register("opendc.org", Int::class.java, 1)
+
+ println(registry)
+
+ registry.remove("opendc.org")
+
+ assertAll(
+ { assertNull(registry.resolve("opendc.org", String::class.java)) },
+ { assertNull(registry.resolve("opendc.org", Int::class.java)) },
+ )
+ }
+
+ @Test
+ fun testClone() {
+ val registry = ServiceRegistryImpl()
+ registry.register("opendc.org", String::class.java, "Comment")
+
+ val clone = registry.clone()
+ clone.remove("opendc.org")
+
+ assertAll(
+ { assertEquals("Comment", registry.resolve("opendc.org", String::class.java)) },
+ { assertNull(clone.resolve("opendc.org", String::class.java)) }
+ )
+ }
+}