keel-core/com.keel.kernel.observability

Package-level declarations

Types

@Serializable

data class ClusterInsightMetrics(val overallUtilizationPercent: Double = 0.0, val throughputPerSecond: Double = 0.0, val networkErrorRatePercent: Double = 0.0, val uptimeScore: Double = 0.0)

CustomEvent

@Serializable

data class CustomEvent(val type: String, val payload: JsonElement)

FlowEvent

@Serializable

data class FlowEvent(val traceId: String, val spanId: String, val parentSpanId: String? = null, val service: String, val operation: String, val startEpochMs: Long, val endEpochMs: Long? = null, val status: String, val attributes: Map<String, String> = emptyMap(), val edgeFrom: String, val edgeTo: String)

JvmNode

@Serializable

data class JvmNode(val id: String, val kind: String, val label: String, val pluginId: String? = null, val pid: Long? = null, val runtimeMode: String? = null, val healthState: String? = null, val lifecycleState: String? = null, val startedAtEpochMs: Long? = null, val inflightInvocations: Int = 0, val eventQueueDepth: Int = 0, val droppedLogCount: Long = 0, val labels: Map<String, String> = emptyMap())

KeelObservability

interface KeelObservability

KernelProcessMetrics

@Serializable

data class KernelProcessMetrics(val processCpuLoad: Double? = null, val systemLoadAverage: Double? = null, val availableProcessors: Int = 1, val heapUsedBytes: Long = 0, val heapMaxBytes: Long = 0, val heapUsedPercent: Double = 0.0, val threadCount: Int = 0)

LatencyHistogram

@Serializable

data class LatencyHistogram(val buckets: List<LatencyHistogramBucket>, val totalCount: Int, val avgMs: Double, val p50Ms: Long, val p95Ms: Long, val p99Ms: Long)

LatencyHistogramBucket

@Serializable

data class LatencyHistogramBucket(val label: String, val maxValueMs: Long, val count: Int, val percentOfTotal: Double)

LatencyMetrics

@Serializable

data class LatencyMetrics(val avgMs: Double = 0.0, val p95Ms: Long = 0, val p99Ms: Long = 0, val errorRate: Double = 0.0, val completedSpanCount: Int = 0, val histogram: LatencyHistogram? = null)

LogEvent

@Serializable

data class LogEvent(val timestamp: Long, val level: String, val source: String, val message: String, val throwable: String? = null, val traceId: String? = null, val spanId: String? = null, val pluginId: String? = null, val attributes: Map<String, String> = emptyMap())

LogExplorerSnapshot

@Serializable

data class LogExplorerSnapshot(val page: LogSnapshotPage, val histogram: LogHistogramSnapshot, val summary: LogExplorerSummary, val availableLevels: List<String> = emptyList())

LogExplorerSummary

@Serializable

data class LogExplorerSummary(val totalMatched: Int, val showingCount: Int, val availableLevels: List<String> = emptyList(), val activeWindow: String = "1h")

LogHistogramBucket

@Serializable

data class LogHistogramBucket(val startEpochMs: Long, val endEpochMs: Long, val totalCount: Int, val levelCounts: Map<String, Int> = emptyMap())

LogHistogramSnapshot

@Serializable

data class LogHistogramSnapshot(val windowStartEpochMs: Long, val windowEndEpochMs: Long, val bucketSizeMs: Long, val buckets: List<LogHistogramBucket>)

LogSnapshotPage

@Serializable

data class LogSnapshotPage(val items: List<StructuredLogRecord>, val total: Int, val limit: Int, val page: Int = 1, val pageSize: Int = limit, val totalPages: Int = if (total == 0) 0 else 1, val hasPrev: Boolean = false, val hasNext: Boolean = false)

NodeAssetMetadata

@Serializable

data class NodeAssetMetadata(val assetId: String? = null, val address: String? = null, val zone: String? = null, val region: String? = null, val role: String? = null, val roleDescription: String? = null, val featured: Boolean = false)

NodeDashboardItem

@Serializable

data class NodeDashboardItem(val node: JvmNode, val summary: NodeSummary, val asset: NodeAssetMetadata, val resource: NodeResourceMetrics, val degradationReason: String? = null, val primaryAction: String, val secondaryAction: String? = null)

NodeDashboardSnapshot

@Serializable

data class NodeDashboardSnapshot(val windowMs: Long, val activeCount: Int, val degradedCount: Int, val pageTotal: Int, val featuredNodeId: String? = null, val throughputPerSecond: Double = 0.0, val networkThroughputBytesPerSecond: Double? = null, val networkErrorRatePercent: Double = 0.0, val uptimeScore: Double = 0.0, val items: List<NodeDashboardItem>)

NodeResourceMetrics

@Serializable

data class NodeResourceMetrics(val cpuPercent: Double? = null, val memoryUsedBytes: Long? = null, val memoryMaxBytes: Long? = null, val memoryPercent: Double? = null, val metricsDerived: Boolean = false)

NodeSummary

@Serializable

data class NodeSummary(val node: JvmNode, val recentFlowCount: Int = 0, val recentTraceCount: Int = 0, val errorCount: Int = 0, val loadPercent: Int = 0, val memoryPressurePercent: Int = 0, val uptimeMs: Long? = null, val processAlive: Boolean? = null, val lastHealthLatencyMs: Long? = null, val lastAdminLatencyMs: Long? = null, val lastEventAtEpochMs: Long? = null)

ObservabilityConfig

data class ObservabilityConfig(val traceBufferSize: Int = 500, val flowBufferSize: Int = 500, val statusPollIntervalMs: Long = 2000)

ObservabilityHub

class ObservabilityHub(config: ObservabilityConfig = ObservabilityConfig.fromSystem()) : KeelObservability

ObservabilityMetricsSnapshot

@Serializable

data class ObservabilityMetricsSnapshot(val windowMs: Long, val runtimeNodeCount: Int, val externalNodeCount: Int, val totalInflight: Int, val totalQueueDepth: Int, val droppedLogCount: Long, val kernel: KernelProcessMetrics, val latency: LatencyMetrics, val traffic: TrafficMetrics, val cluster: ClusterInsightMetrics = ClusterInsightMetrics(), val nodes: List<NodeSummary>)

ObservabilityStreamEvent

data class ObservabilityStreamEvent(val type: String, val dataJson: String)

ObservabilityTracing

object ObservabilityTracing

PanelInfo

@Serializable

data class PanelInfo(val id: String, val title: String, val dataEndpoint: String)

StructuredLogRecord

@Serializable

data class StructuredLogRecord(val timestamp: Long, val level: String, val source: String, val message: String, val throwable: String? = null, val traceId: String? = null, val spanId: String? = null, val pluginId: String? = null, val service: String? = null, val cluster: String? = null, val instance: String? = null, val payload: JsonElement? = null, val meta: JsonElement? = null, val attributes: Map<String, String> = emptyMap())

TopEdgeMetric

@Serializable

data class TopEdgeMetric(val edgeFrom: String, val edgeTo: String, val count: Int, val errorCount: Int = 0)

TraceDashboardSnapshot

@Serializable

data class TraceDashboardSnapshot(val summary: TraceDashboardSummary = TraceDashboardSummary(), val filters: TraceFilterOptions = TraceFilterOptions(), val traces: List<TraceListItem> = emptyList(), val selectedTraceId: String? = null, val selectedSpanId: String? = null, val timeline: TraceTimeline? = null, val spanDetail: TraceSpanDetail? = null)

TraceDashboardSummary

@Serializable

data class TraceDashboardSummary(val totalTraces: Int = 0, val p99LatencyMs: Long = 0, val errorRatePercent: Double = 0.0, val activeSpanCount: Int = 0)

TraceFilterOptions

@Serializable

data class TraceFilterOptions(val window: String = "1h", val query: String = "", val status: String = "all", val service: String = "", val limit: Int = 40, val availableServices: List<String> = emptyList(), val availableStatuses: List<String> = listOf("all", "ok", "error", "slow", "active"))

TraceListItem

@Serializable

data class TraceListItem(val traceId: String, val operation: String, val service: String, val startEpochMs: Long, val durationMs: Long = 0, val spanCount: Int = 0, val status: String = "UNSET", val badgeLabel: String = "UNSET", val httpStatusCode: Int? = null, val errorCount: Int = 0, val activeSpanCount: Int = 0, val slow: Boolean = false)

TraceListSnapshot

@Serializable

data class TraceListSnapshot(val filters: TraceFilterOptions = TraceFilterOptions(), val traces: List<TraceListItem> = emptyList(), val selectedTraceId: String? = null)

TraceSpanDetail

@Serializable

data class TraceSpanDetail(val traceId: String, val spanId: String, val parentSpanId: String? = null, val service: String, val operation: String, val status: String, val startEpochMs: Long, val endEpochMs: Long? = null, val durationMs: Long? = null, val host: String? = null, val protocol: String? = null, val component: String? = null, val edgeFrom: String? = null, val edgeTo: String? = null, val attributes: Map<String, String> = emptyMap())

TraceSpanDetailSnapshot

@Serializable

data class TraceSpanDetailSnapshot(val selectedTraceId: String? = null, val selectedSpanId: String? = null, val spanDetail: TraceSpanDetail? = null)

TraceSpanEvent

@Serializable

data class TraceSpanEvent(val traceId: String, val spanId: String, val parentSpanId: String? = null, val service: String, val operation: String, val startEpochMs: Long, val endEpochMs: Long? = null, val durationMs: Long? = null, val status: String, val attributes: Map<String, String> = emptyMap(), val edgeFrom: String? = null, val edgeTo: String? = null)

TraceSummarySnapshot

@Serializable

data class TraceSummarySnapshot(val summary: TraceDashboardSummary = TraceDashboardSummary())

TraceTimeline

@Serializable

data class TraceTimeline(val traceId: String, val durationMs: Long = 0, val spanCount: Int = 0, val startedAtEpochMs: Long = 0, val marks: List<TraceTimelineMark> = emptyList(), val spans: List<TraceTimelineSpan> = emptyList())

TraceTimelineMark

@Serializable

data class TraceTimelineMark(val label: String, val offsetPercent: Double)

TraceTimelineSnapshot

@Serializable

data class TraceTimelineSnapshot(val selectedTraceId: String? = null, val timeline: TraceTimeline? = null)

TraceTimelineSpan

@Serializable

data class TraceTimelineSpan(val traceId: String, val spanId: String, val parentSpanId: String? = null, val service: String, val operation: String, val startEpochMs: Long, val endEpochMs: Long? = null, val durationMs: Long? = null, val status: String, val depth: Int = 0, val leftPercent: Double = 0.0, val widthPercent: Double = 0.0, val host: String? = null, val protocol: String? = null, val component: String? = null, val attributes: Map<String, String> = emptyMap())

TrafficMetrics

@Serializable

data class TrafficMetrics(val recentFlowCount: Int = 0, val recentTraceCount: Int = 0, val topEdges: List<TopEdgeMetric> = emptyList())

Functions

toNodeAssetMetadata

fun PluginNodeAssetMetadata.toNodeAssetMetadata(): NodeAssetMetadata