suspend fun enqueueDetailed(type: String, payloadJson: String, stableEventId: String? = null, idempotencyKeyOverride: String? = null, userId: String? = null): EnqueueResult

Enqueue an event through the v0.5.0 pipeline:

enqueueDetailedBlocking

@JvmOverloads

fun enqueueDetailedBlocking(type: String, payloadJson: String, stableEventId: String? = null, idempotencyKeyOverride: String? = null, userId: String? = null): CompletableFuture<EnqueueResult>

Java-friendly wrapper for enqueueDetailed.

exportDiagnostics

suspend fun exportDiagnostics(): File

Threading: Main-safe. File IO dispatched internally.

exportSignedAuditRange

suspend fun exportSignedAuditRange(fromTs: Long, toTs: Long): File

Export a range of signed audit events to a file.

getAbTestVariant

fun getAbTestVariant(experimentId: String, variants: List<String>): String

Get A/B test variant for an experiment.

getAuditStatistics

suspend fun getAuditStatistics(): AuditStatistics

Get statistics about the persistent audit trail.

getConfigVersionHistory

suspend fun getConfigVersionHistory(): List<ConfigVersion>

Get available config versions for rollback.

getRemainingDiagnosticsTriggersToday

fun getRemainingDiagnosticsTriggersToday(): Int

Get remaining remote diagnostics triggers allowed today.

healthCheck

suspend fun healthCheck(): HealthCheckResult

Returns a structured health snapshot of the SDK.

healthCheckBlocking

fun healthCheckBlocking(): CompletableFuture<HealthCheckResult>

Java-friendly wrapper for healthCheck.

healthStatusFlow

fun healthStatusFlow(intervalMs: Long = 10000): Flow<HealthCheckResult>

Observe SDK health status as a kotlinx.coroutines.flow.Flow.

heartbeat

@JvmOverloads

suspend fun heartbeat(reason: String = "periodic")

Maximalist heartbeat:

heartbeatBlocking

@JvmOverloads

fun heartbeatBlocking(reason: String = "periodic"): CompletableFuture<Unit>

Java-friendly wrapper for heartbeat.

logger

fun logger(): RingLog

processRemoteDiagnosticsTrigger

@JvmOverloads

suspend fun processRemoteDiagnosticsTrigger(triggerId: String, metadata: Map<String, String> = emptyMap()): TriggerResult

Process a remote diagnostics trigger request.

quarantinedEvents

@JvmOverloads

suspend fun quarantinedEvents(limit: Int = 50): List<QuarantinedEventSummary>

Returns lightweight metadata for quarantined events (no payload). Useful for support dashboards and diagnostics.

queueDepth

suspend fun queueDepth(): Long

Threading: Main-safe.

queueDepthBlocking

fun queueDepthBlocking(): CompletableFuture<Long>

Java-friendly wrapper for queueDepth.

queueDepthFlow

fun queueDepthFlow(intervalMs: Long = 5000): Flow<Long>

Observe queue depth as a Room-reactive kotlinx.coroutines.flow.Flow.

rollbackConfig

suspend fun rollbackConfig(targetVersion: Long): ConfigRollbackResult

Rollback to a previous configuration version.

setAnomalyDetector

fun setAnomalyDetector(detector: AnomalyDetector?)

Set a custom anomaly detector implementation.

setDataRightsAuthorizer

fun setDataRightsAuthorizer(authorizer: DataRightsAuthorizer?)

Set the authorization callback for data rights operations.

setDiagnosticsUploader

fun setDiagnosticsUploader(uploader: DiagnosticsUploader?)

setErrorListener

fun setErrorListener(listener: KioskOpsErrorListener?)

Set a listener for non-fatal SDK operational errors.

setPiiDetector

fun setPiiDetector(detector: PiiDetector?)

Set a custom PII detector implementation.

shutdown

suspend fun shutdown()

Gracefully shut down the SDK.

syncOnce

suspend fun syncOnce(): TransportResult<SyncOnceResult>

Opt-in network sync.

syncOnceBlocking

fun syncOnceBlocking(): CompletableFuture<TransportResult<SyncOnceResult>>

Java-friendly wrapper for syncOnce.

uploadDiagnosticsNow

@JvmOverloads

suspend fun uploadDiagnosticsNow(metadata: Map<String, String> = emptyMap()): Boolean

Host-controlled diagnostics upload.

verifyAuditIntegrity

@JvmOverloads

suspend fun verifyAuditIntegrity(fromTs: Long? = null, toTs: Long? = null): ChainVerificationResult

Verify the integrity of the persistent audit trail.