htlee
a0f24d5757
- QueryMetricsBufferService: ConcurrentLinkedQueue + 10초 batch flush - GisServiceV2: REST API 메트릭 수집 추가 - ChunkedTrackStreamingService: saveAsync → buffer.enqueue 전환 - QueryMetricsController: /history (페이지네이션+필터), /summary (P95 포함) - ApiMetrics.tsx: 요약카드 + 버튼그룹 필터 + 서버사이드 DataTable + 30s 폴링 - DataTable: server-side pagination props 확장 (하위 호환)
70 lines
2.0 KiB
TypeScript
70 lines
2.0 KiB
TypeScript
import { fetchJson } from './httpClient.ts'
|
|
import type {
|
|
CacheDetails,
|
|
CacheStats,
|
|
DataQuality,
|
|
HaeguStat,
|
|
MetricsSummary,
|
|
ProcessingDelay,
|
|
QueryMetricsPage,
|
|
QueryMetricsParams,
|
|
QueryMetricsSummary,
|
|
ThroughputMetrics,
|
|
} from './types.ts'
|
|
|
|
export const monitorApi = {
|
|
getDelay(): Promise<ProcessingDelay> {
|
|
return fetchJson('/monitor/delay')
|
|
},
|
|
|
|
getMetricsSummary(): Promise<MetricsSummary> {
|
|
return fetchJson('/admin/metrics/summary')
|
|
},
|
|
|
|
getCacheStats(): Promise<CacheStats> {
|
|
return fetchJson('/api/monitoring/cache/stats')
|
|
},
|
|
|
|
getCacheDetails(): Promise<CacheDetails> {
|
|
return fetchJson('/api/monitoring/cache/details')
|
|
},
|
|
|
|
getDailyCacheStatus(): Promise<Record<string, unknown>> {
|
|
return fetchJson('/api/websocket/daily-cache')
|
|
},
|
|
|
|
getThroughput(): Promise<ThroughputMetrics> {
|
|
return fetchJson('/monitor/throughput')
|
|
},
|
|
|
|
getQuality(): Promise<DataQuality> {
|
|
return fetchJson('/monitor/quality')
|
|
},
|
|
|
|
getHaeguRealtimeStats(): Promise<HaeguStat[]> {
|
|
return fetchJson('/monitor/haegu/realtime')
|
|
},
|
|
|
|
getHaeguStats(): Promise<Record<string, unknown>[]> {
|
|
return fetchJson('/admin/haegu/stats')
|
|
},
|
|
|
|
getQueryMetricsHistory(params: QueryMetricsParams): Promise<QueryMetricsPage> {
|
|
const qs = new URLSearchParams()
|
|
if (params.queryType) qs.set('queryType', params.queryType)
|
|
if (params.dataPath) qs.set('dataPath', params.dataPath)
|
|
if (params.status) qs.set('status', params.status)
|
|
if (params.elapsedMsMin != null) qs.set('elapsedMsMin', String(params.elapsedMsMin))
|
|
if (params.elapsedMsMax != null) qs.set('elapsedMsMax', String(params.elapsedMsMax))
|
|
qs.set('page', String(params.page ?? 0))
|
|
qs.set('size', String(params.size ?? 20))
|
|
qs.set('sortBy', params.sortBy ?? 'created_at')
|
|
qs.set('sortDir', params.sortDir ?? 'desc')
|
|
return fetchJson(`/api/monitoring/query-metrics/history?${qs}`)
|
|
},
|
|
|
|
getQueryMetricsSummary(hours = 24): Promise<QueryMetricsSummary> {
|
|
return fetchJson(`/api/monitoring/query-metrics/summary?hours=${hours}`)
|
|
},
|
|
}
|