kiosk-ops-sdk/com.sarastarquant.kioskops.sdk.observability

Package-level declarations

Types

data class CorrelatedResult<T>(val value: T, val correlationId: String, val durationNanos: Long, val operationName: String)

Result of a correlated operation with timing and correlation metadata.

CorrelationContext

object CorrelationContext

Thread-local correlation context for distributed tracing and audit trail linkage.

CorrelationContextElement

class CorrelationContextElement(snapshot: Map<String, String> = CorrelationContext.snapshot()) : CoroutineContext.Element

Coroutine context element for propagating correlation context across dispatchers.

LoggingSinkConfig

sealed class LoggingSinkConfig

Configuration for logging sinks.

LogLevel

enum LogLevel : Enum<LogLevel>

Log severity levels for structured logging.

ObservabilityPolicy

data class ObservabilityPolicy(val tracingEnabled: Boolean = false, val otlpEndpoint: String? = null, val structuredLoggingEnabled: Boolean = false, val loggingSinks: List<LoggingSinkConfig> = listOf(LoggingSinkConfig.Logcat()), val correlationEnabled: Boolean = true, val metricsEnabled: Boolean = false, val metricsExportIntervalMs: Long, val debugFeaturesEnabled: Boolean = false, val networkLoggingEnabled: Boolean = false, val traceSampleRate: Double = 0.1)

Policy for SDK observability features including logging, tracing, and metrics.

Functions

correlatedBlock

inline fun <T> correlatedBlock(operationName: String, attributes: Map<String, String> = emptyMap(), block: () -> T): CorrelatedResult<T>

Execute a blocking operation with correlation context.

correlatedOperation

inline suspend fun <T> correlatedOperation(operationName: String, attributes: Map<String, String> = emptyMap(), context: CoroutineContext = EmptyCoroutineContext, crossinline block: suspend () -> T): CorrelatedResult<T>

Execute a suspending operation with automatic correlation context and timing.

trackedOperation

inline suspend fun <T> trackedOperation(operationName: String, attributes: Map<String, String> = emptyMap(), crossinline onSuccess: (T, String, Long) -> Unit = { _, _, _ -> }, crossinline onFailure: (Throwable, String, Long) -> Unit = { _, _, _ -> }, crossinline block: suspend () -> T): T

Execute a suspending operation with correlation, automatically recording success/failure to an optional callback.