persistence/io.neuralheads.kmpworker.persistence/SqlDelightTelemetryCollector

SqlDelightTelemetryCollector

class SqlDelightTelemetryCollector(database: KmpWorkerDatabase) : TelemetryCollector

SQLDelight-backed implementation of TelemetryCollector.

Persists execution records in the execution_history table, enabling post-mortem analysis, analytics uploads, and debugging.

val db = KmpWorkerDatabaseFactory.create(context)
val telemetry = SqlDelightTelemetryCollector(db)
val worker = AndroidKmpWorker(context, telemetry = telemetry)

// Later:
val last50 = telemetry.getHistory(50)
val failures = telemetry.getHistory(10, stateFilter = "FAILED")

Constructors

SqlDelightTelemetryCollector

constructor(database: KmpWorkerDatabase)

Functions

clearHistory

open suspend override fun clearHistory()

getHistory

open suspend override fun getHistory(limit: Int, stateFilter: String?): List<ExecutionRecord>

onTaskCompleted

open suspend override fun onTaskCompleted(taskId: String, state: TaskState, timestamp: Long, retryCount: Int)

onTaskStarted

open suspend override fun onTaskStarted(taskId: String, timestamp: Long)

pruneHistory

open suspend override fun pruneHistory(olderThanMillis: Long)