keel-core/com.keel.kernel.observability/ObservabilityHub

ObservabilityHub

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

Constructors

ObservabilityHub

constructor(config: ObservabilityConfig = ObservabilityConfig.fromSystem())

Functions

emitCustomEvent

open override fun emitCustomEvent(type: String, payload: JsonElement)

events

open override fun events(): SharedFlow<ObservabilityStreamEvent>

flowSnapshot

open override fun flowSnapshot(limit: Int): List<FlowEvent>

jvmSnapshot

open override fun jvmSnapshot(): List<JvmNode>

logExplorerSnapshot

open override fun logExplorerSnapshot(query: String?, level: String?, source: String?, sinceEpochMs: Long?, page: Int, pageSize: Int, windowKey: String): LogExplorerSnapshot

logSnapshot

open override fun logSnapshot(limit: Int, query: String?, level: String?, source: String?, sinceEpochMs: Long?, page: Int, pageSize: Int, windowKey: String): LogSnapshotPage

metricsSnapshot

open override fun metricsSnapshot(windowMs: Long): ObservabilityMetricsSnapshot

nodeDashboardSnapshot

open override fun nodeDashboardSnapshot(windowMs: Long): NodeDashboardSnapshot

nodeSummarySnapshot

open override fun nodeSummarySnapshot(windowMs: Long): List<NodeSummary>

panelInfo

fun panelInfo(): List<PanelInfo>

panels

open override fun panels(): List<PanelInfo>

recordFlow

fun recordFlow(event: FlowEvent)

recordSpan

fun recordSpan(event: TraceSpanEvent)

registerPanel

open override fun registerPanel(id: String, title: String, dataEndpoint: String)

setPluginSnapshotProvider

fun setPluginSnapshotProvider(provider: () -> List<PluginRuntimeSnapshot>)

shutdown

fun shutdown()

start

fun start(scope: CoroutineScope)

tagCurrentSpan

open override fun tagCurrentSpan(key: String, value: String)

traceDashboardSnapshot

open override fun traceDashboardSnapshot(windowKey: String, query: String?, status: String?, service: String?, limit: Int, selectedTraceId: String?, selectedSpanId: String?): TraceDashboardSnapshot

traceListSnapshot

open override fun traceListSnapshot(windowKey: String, query: String?, status: String?, service: String?, limit: Int, selectedTraceId: String?): TraceListSnapshot

traceSnapshot

open override fun traceSnapshot(limit: Int, sinceEpochMs: Long?): List<TraceSpanEvent>

traceSpanDetailSnapshot

open override fun traceSpanDetailSnapshot(windowKey: String, query: String?, status: String?, service: String?, limit: Int, selectedTraceId: String?, selectedSpanId: String?): TraceSpanDetailSnapshot

traceSummarySnapshot

open override fun traceSummarySnapshot(windowKey: String, query: String?, status: String?, service: String?): TraceSummarySnapshot

traceTimelineSnapshot

open override fun traceTimelineSnapshot(windowKey: String, query: String?, status: String?, service: String?, limit: Int, selectedTraceId: String?): TraceTimelineSnapshot