refactor: use full package name for src/main/kotlin/runner

rdf-connect · Jul 20, 2024 · 781e0f8 · 781e0f8
1 parent 7658e99
commit 781e0f8
Show file tree

Hide file tree

Showing 8 changed files with 11 additions and 11 deletions.
diff --git a/src/main/kotlin/Orchestrator.kt b/src/main/kotlin/Orchestrator.kt
@@ -1,18 +1,17 @@
 package technology.idlab
 
 import kotlinx.coroutines.TimeoutCancellationException
-import kotlinx.coroutines.cancel
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.withTimeout
-import runner.Runner
 import technology.idlab.intermediate.IRPipeline
 import technology.idlab.intermediate.IRProcessor
 import technology.idlab.intermediate.IRRunner
 import technology.idlab.intermediate.IRStage
+import technology.idlab.runner.Runner
 import technology.idlab.util.Log
 
 class Orchestrator(

diff --git a/src/main/kotlin/runner/Runner.kt b/src/main/kotlin/runner/Runner.kt
@@ -1,4 +1,4 @@
-package runner
+package technology.idlab.runner
 
 import kotlinx.coroutines.channels.Channel
 import technology.idlab.intermediate.IRProcessor

diff --git a/src/main/kotlin/runner/impl/grpc/GRPCRunner.kt b/src/main/kotlin/runner/impl/grpc/GRPCRunner.kt
@@ -13,9 +13,9 @@ import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.receiveAsFlow
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
-import runner.Runner
 import technology.idlab.intermediate.IRProcessor
 import technology.idlab.intermediate.IRStage
+import technology.idlab.runner.Runner
 import technology.idlab.util.Log
 
 /**

diff --git a/src/main/kotlin/runner/impl/grpc/HostedGRPCRunner.kt b/src/main/kotlin/runner/impl/grpc/HostedGRPCRunner.kt
@@ -5,6 +5,7 @@ import kotlin.random.Random
 import kotlin.random.nextUInt
 import kotlinx.coroutines.channels.Channel
 import technology.idlab.extensions.rawPath
+import technology.idlab.runner.Runner
 import technology.idlab.util.ManagedProcess
 
 /**
@@ -14,7 +15,7 @@ import technology.idlab.util.ManagedProcess
 class HostedGRPCRunner
 private constructor(
     /** The channel to send messages to. */
-    fromProcessors: Channel<Payload>,
+    fromProcessors: Channel<Runner.Payload>,
     /** The process which contains the gRPC server. */
     process: ManagedProcess,
     /** The configuration of the gRPC server. */

diff --git a/src/main/kotlin/runner/impl/jvm/JVMRunner.kt b/src/main/kotlin/runner/impl/jvm/JVMRunner.kt
@@ -2,17 +2,16 @@ package technology.idlab.runner.impl.jvm
 
 import arrow.core.zip
 import kotlinx.coroutines.TimeoutCancellationException
-import kotlinx.coroutines.cancel
 import kotlinx.coroutines.channels.Channel
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withTimeout
-import runner.Runner
 import technology.idlab.intermediate.IRArgument
 import technology.idlab.intermediate.IRParameter
 import technology.idlab.intermediate.IRProcessor
 import technology.idlab.intermediate.IRStage
+import technology.idlab.runner.Runner
 import technology.idlab.util.Log
 
 private const val STAGE_NO_CLASS = "Processor has no class key set."

diff --git a/src/main/kotlin/runner/impl/jvm/Writer.kt b/src/main/kotlin/runner/impl/jvm/Writer.kt
@@ -1,12 +1,12 @@
 package technology.idlab.runner.impl.jvm
 
 import kotlinx.coroutines.channels.Channel
-import runner.Runner.Payload
+import technology.idlab.runner.Runner
 import technology.idlab.util.Log
 
-class Writer(private val channel: Channel<Payload>, private val channelURI: String) {
+class Writer(private val channel: Channel<Runner.Payload>, private val channelURI: String) {
   suspend fun push(value: ByteArray) {
     Log.shared.debug("'${value.decodeToString()}' -> [$channelURI]")
-    channel.send(Payload(channelURI, value))
+    channel.send(Runner.Payload(channelURI, value))
   }
 }
diff --git a/src/test/kotlin/runner/RunnerTest.kt b/src/test/kotlin/runner/RunnerTest.kt
@@ -11,6 +11,7 @@ import technology.idlab.intermediate.IRArgument
 import technology.idlab.intermediate.IRParameter
 import technology.idlab.intermediate.IRProcessor
 import technology.idlab.intermediate.IRStage
+import technology.idlab.runner.Runner
 import technology.idlab.util.Log
 
 abstract class RunnerTest {

diff --git a/src/test/kotlin/runner/impl/jvm/JVMRunnerTest.kt b/src/test/kotlin/runner/impl/jvm/JVMRunnerTest.kt
@@ -1,8 +1,8 @@
 package runner.impl.jvm
 
 import kotlinx.coroutines.channels.Channel
-import runner.Runner
 import runner.RunnerTest
+import technology.idlab.runner.Runner
 import technology.idlab.runner.impl.jvm.JVMRunner
 
 class JVMRunnerTest : RunnerTest() {