diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2022-10-04 10:04:50 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-10-04 10:04:50 +0200 |
| commit | 92cc0908b7ad6c94b08e6016f8815ab07cd1714d (patch) | |
| tree | b5edaff69212986265f9edc620e40bb8695f11eb /opendc-experiments/opendc-experiments-base/src/test/kotlin | |
| parent | 2d2a3854d355bd4b074ef651f291d34081e70d96 (diff) | |
| parent | bd476d11ab24fe745bb54e97a11133706bb96cb1 (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/kotlin')
| -rw-r--r-- | opendc-experiments/opendc-experiments-base/src/test/kotlin/org/opendc/experiments/ServiceRegistryTest.kt | 111 |
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)) } + ) + } +} |
