core/io.devconsole.core

Package-level declarations

Types

class DevConsoleRuntime(runtimeGate: RuntimeGate)

enum EventBatchDropReason : Enum<EventBatchDropReason>

class EventBatchWriter(store: EventStore, scope: CoroutineScope, capacity: Int = DEFAULT_CAPACITY, maxBatchSize: Int = DEFAULT_BATCH_SIZE, flushIntervalMs: Long = DEFAULT_FLUSH_INTERVAL_MS, onDrop: (StoredEvent, EventBatchDropReason) -> Unit = { _, _ -> }, onStored: suspend (List<StoredEvent>) -> Unit = {})

Bounded persistence worker. It receives only EventEnvelope values emitted after the redaction boundary and commits 100 events or the pending batch every 250 ms.

EventDraft

data class EventDraft(val pluginId: String, val type: String, val severity: EventSeverity, val summary: String, val correlationId: String? = null, val tags: Map<String, String> = emptyMap(), val payloadRef: String? = null)

EventDropNotice

data class EventDropNotice(val droppedEventId: UUID, val droppedPluginId: String, val droppedSeverity: EventSeverity, val incomingPluginId: String, val reason: EventDropReason, val totalDroppedCount: Long)

EventDropReason

enum EventDropReason : Enum<EventDropReason>

EventDropSink

fun interface EventDropSink

EventOverflowStrategy

enum EventOverflowStrategy : Enum<EventOverflowStrategy>

EventPipeline

class EventPipeline(sessionId: UUID, capacity: Int, redactionEngine: RedactionEngine = RedactionEngine(RedactionPolicy.default()))

PluginOverflowPolicy

data class PluginOverflowPolicy(val maxBufferedEvents: Int, val strategy: EventOverflowStrategy = EventOverflowStrategy.DROP_OLDEST_LOWEST_SEVERITY)

RuntimeGate

sealed interface RuntimeGate

SdkHealth

data class SdkHealth(val initializationCount: Long = 0, val publishedEventCount: Long = 0, val droppedEventCount: Long = 0, val state: DevConsoleState = DevConsoleState.Uninitialized, val lastFailure: String? = null)