kn: observability (#1234)

Author: lauzadis

runtime/build.gradle.kts

@@ -62,7 +62,7 @@ subprojects {
                 }
             }
 
-            named("jvmTest") {
+            findByName("jvmTest")?.run {
                 dependencies {
                     implementation(libraries.kotlinx.coroutines.debug)
                     implementation(libraries.kotest.assertions.core.jvm)

runtime/observability/logging-crt/build.gradle.kts

@@ -0,0 +1,18 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+description = "Logging provider based on CRT"
+extra["displayName"] = "Smithy :: Kotlin :: Observability :: CRT"
+extra["moduleName"] = "aws.smithy.kotlin.runtime.telemetry.logging.crt"
+
+kotlin {
+    sourceSets {
+        nativeMain {
+            dependencies {
+                api(project(":runtime:observability:telemetry-api"))
+                api(libs.crt.kotlin)
+            }
+        }
+    }
+}

runtime/observability/logging-crt/native/src/aws/smithy/kotlin/runtime/telemetry/logging/crt/CrtLogRecordBuilder.kt

@@ -0,0 +1,47 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package aws.smithy.kotlin.runtime.telemetry.logging.crt
+
+import aws.smithy.kotlin.runtime.telemetry.logging.LogLevel
+import aws.smithy.kotlin.runtime.telemetry.logging.LogRecordBuilder
+import aws.smithy.kotlin.runtime.telemetry.logging.MessageSupplier
+
+public class CrtLogRecordBuilder(
+    private val delegate: CrtLogger,
+    private val level: LogLevel,
+) : LogRecordBuilder {
+    private var cause: Throwable? = null
+    private var msg: (() -> String)? = null
+
+    override fun setCause(ex: Throwable) {
+        cause = ex
+    }
+
+    override fun setMessage(message: String) {
+        msg = { message }
+    }
+
+    override fun setMessage(message: MessageSupplier) {
+        msg = message
+    }
+
+    // CRT logger does not support setting key-value pairs
+    override fun setKeyValuePair(key: String, value: Any) { }
+
+    override fun emit() {
+        val message = requireNotNull(msg) { "no message provided to LogRecordBuilder" }
+
+        val logMethod = when (level) {
+            LogLevel.Trace -> delegate::trace
+            LogLevel.Debug -> delegate::debug
+            LogLevel.Info -> delegate::info
+            LogLevel.Warning -> delegate::warn
+            LogLevel.Error -> delegate::error
+        }
+
+        logMethod(cause, message)
+    }
+}

runtime/observability/logging-crt/native/src/aws/smithy/kotlin/runtime/telemetry/logging/crt/CrtLogger.kt

@@ -0,0 +1,27 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package aws.smithy.kotlin.runtime.telemetry.logging.crt
+
+import aws.sdk.kotlin.crt.WithCrt
+import aws.sdk.kotlin.crt.log
+import aws.smithy.kotlin.runtime.telemetry.logging.LogLevel
+import aws.smithy.kotlin.runtime.telemetry.logging.LogRecordBuilder
+import aws.smithy.kotlin.runtime.telemetry.logging.Logger
+import aws.smithy.kotlin.runtime.telemetry.logging.MessageSupplier
+import aws.sdk.kotlin.crt.Config as CrtConfig
+import aws.sdk.kotlin.crt.LogLevel as CrtLogLevel
+
+public class CrtLogger(public val name: String, public val config: CrtConfig) :
+    WithCrt(),
+    Logger {
+    override fun trace(t: Throwable?, msg: MessageSupplier): Unit = log(CrtLogLevel.Trace, msg())
+    override fun debug(t: Throwable?, msg: MessageSupplier): Unit = log(CrtLogLevel.Debug, msg())
+    override fun info(t: Throwable?, msg: MessageSupplier): Unit = log(CrtLogLevel.Info, msg())
+    override fun warn(t: Throwable?, msg: MessageSupplier): Unit = log(CrtLogLevel.Warn, msg())
+    override fun error(t: Throwable?, msg: MessageSupplier): Unit = log(CrtLogLevel.Error, msg())
+    override fun isEnabledFor(level: LogLevel): Boolean = config.logLevel.ordinal >= level.ordinal
+    override fun atLevel(level: LogLevel): LogRecordBuilder = CrtLogRecordBuilder(this, level)
+}

runtime/observability/logging-crt/native/src/aws/smithy/kotlin/runtime/telemetry/logging/crt/CrtLoggerProvider.kt

@@ -0,0 +1,14 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package aws.smithy.kotlin.runtime.telemetry.logging.crt
+
+import aws.smithy.kotlin.runtime.telemetry.logging.*
+import aws.sdk.kotlin.crt.Config as CrtConfig
+
+public class CrtLoggerProvider : LoggerProvider {
+    override fun getOrCreateLogger(name: String): Logger = CrtLogger(name, CrtConfig())
+    public fun getOrCreateLogger(name: String, config: CrtConfig): Logger = CrtLogger(name, config)
+}

runtime/observability/logging-slf4j2/build.gradle.kts

@@ -4,7 +4,7 @@
  */
 description = "Logging provider based on SLF4J"
 extra["displayName"] = "Smithy :: Kotlin :: Observability :: SLF4J binding"
-extra["moduleName"] = "aws.smithy.kotlin.runtime.telemetry"
+extra["moduleName"] = "aws.smithy.kotlin.runtime.telemetry.slf4j"
 
 kotlin {
     sourceSets {

runtime/observability/telemetry-defaults/build.gradle.kts

@@ -24,6 +24,12 @@ kotlin {
             }
         }
 
+        nativeMain {
+            dependencies {
+                implementation(project(":runtime:observability:logging-crt"))
+            }
+        }
+
         all {
             languageSettings.optIn("aws.smithy.kotlin.runtime.InternalApi")
         }

runtime/observability/telemetry-defaults/native/src/aws/smithy/kotlin/runtime/telemetry/logging/DefaultLoggerProviderNative.kt

@@ -5,4 +5,6 @@
 
 package aws.smithy.kotlin.runtime.telemetry.logging
 
-internal actual val DefaultLoggerProvider: LoggerProvider = TODO("Not yet implemented")
+import aws.smithy.kotlin.runtime.telemetry.logging.crt.CrtLoggerProvider
+
+internal actual val DefaultLoggerProvider: LoggerProvider = CrtLoggerProvider()

runtime/protocol/http-client-engines/http-client-engine-default/build.gradle.kts

@@ -16,19 +16,28 @@ kotlin {
                 implementation(project(":runtime:runtime-core"))
             }
         }
+
         jvmMain {
             dependencies {
                 // okhttp works on both JVM and Android
                 implementation(project(":runtime:protocol:http-client-engines:http-client-engine-okhttp"))
             }
         }
+
         jvmTest {
             dependencies {
                 implementation(project(":runtime:protocol:http-client-engines:http-client-engine-crt"))
             }
         }
+
         all {
             languageSettings.optIn("aws.smithy.kotlin.runtime.InternalApi")
         }
+
+        nativeMain {
+            dependencies {
+                implementation(project(":runtime:protocol:http-client-engines:http-client-engine-crt"))
+            }
+        }
     }
 }

runtime/protocol/http-client-engines/http-client-engine-default/native/src/aws/smithy/kotlin/runtime/http/engine/DefaultHttpEngineNative.kt

@@ -5,5 +5,6 @@
 
 package aws.smithy.kotlin.runtime.http.engine
 
-internal actual fun newDefaultHttpEngine(block: (HttpClientEngineConfig.Builder.() -> Unit)?): CloseableHttpClientEngine =
-    TODO("Not yet implemented")
+import aws.smithy.kotlin.runtime.http.engine.crt.CrtHttpEngine
+
+internal actual fun newDefaultHttpEngine(block: (HttpClientEngineConfig.Builder.() -> Unit)?): CloseableHttpClientEngine = CrtHttpEngine()