iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Logging

Browse Source
This commit is contained in:
Brage 2023-07-23 22:21:23 +02:00
parent 64eeda69fc
commit 3de9fff34e
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
View File

@ -2,6 +2,7 @@ package no.iktdev.streamit.content.encode.runner
import no.iktdev.streamit.content.encode.EncodeEnv import no.iktdev.streamit.content.encode.EncodeEnv
import kotlinx.coroutines.runBlocking import kotlinx.coroutines.runBlocking
import mu.KotlinLogging
import no.iktdev.streamit.content.common.CommonConfig import no.iktdev.streamit.content.common.CommonConfig
import no.iktdev.streamit.content.common.dto.reader.work.EncodeWork import no.iktdev.streamit.content.common.dto.reader.work.EncodeWork
import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork import no.iktdev.streamit.content.common.dto.reader.work.ExtractWork
@ -19,6 +20,7 @@ import java.util.concurrent.TimeUnit
@Service @Service
class RunnerCoordinator { class RunnerCoordinator {
private val logger = KotlinLogging.logger {}
val producer = DefaultProducer(CommonConfig.kafkaTopic) val producer = DefaultProducer(CommonConfig.kafkaTopic)
@ -91,7 +93,7 @@ class RunnerCoordinator {
} }
override fun onProgress(referenceId: String, work: EncodeWork, progress: Progress) { override fun onProgress(referenceId: String, work: EncodeWork, progress: Progress) {
// TODO: Pass to listener logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Progress: ${progress.speed}" }
} }
override fun onEnded(referenceId: String, work: EncodeWork) { override fun onEnded(referenceId: String, work: EncodeWork) {