MCPcopy Create free account
hub / github.com/couchbase/cbft / gatherTopLevelStats

Function gatherTopLevelStats

ns_server.go:491–552  ·  view source on GitHub ↗
(rd *recentInfo)

Source from the content-addressed store, hash-verified

489}
490
491func gatherTopLevelStats(rd *recentInfo) map[string]interface{} {
492 topLevelStats := map[string]interface{}{}
493 // (Sys - HeapReleased) is the estimate the cbft process can make that
494 // best represents the process RSS; this accounts for memory that has been
495 // acquired by the process and the amount that has been released back.
496 topLevelStats["num_bytes_used_ram"] = rd.memStats.Sys - rd.memStats.HeapReleased
497 topLevelStats["total_gc"] = rd.memStats.NumGC
498 topLevelStats["pct_cpu_gc"] = rd.memStats.GCCPUFraction
499 topLevelStats["tot_remote_http"] = atomic.LoadUint64(&totRemoteHttp)
500 topLevelStats["tot_remote_http2"] = atomic.LoadUint64(&totRemoteHttpSsl) // deprecated
501 topLevelStats["tot_remote_http_ssl"] = atomic.LoadUint64(&totRemoteHttpSsl)
502 topLevelStats["tot_queryreject_on_memquota"] =
503 atomic.LoadUint64(&totQueryRejectOnNotEnoughQuota)
504
505 topLevelStats["tot_http_limitlisteners_opened"] =
506 atomic.LoadUint64(&TotHTTPLimitListenersOpened)
507 topLevelStats["tot_http_limitlisteners_closed"] =
508 atomic.LoadUint64(&TotHTTPLimitListenersClosed)
509 topLevelStats["tot_https_limitlisteners_opened"] =
510 atomic.LoadUint64(&TotHTTPSLimitListenersOpened)
511 topLevelStats["tot_https_limitlisteners_closed"] =
512 atomic.LoadUint64(&TotHTTPSLimitListenersClosed)
513
514 topLevelStats["tot_remote_grpc"] = atomic.LoadUint64(&totRemoteGrpc)
515 topLevelStats["tot_remote_grpc_tls"] = atomic.LoadUint64(&totRemoteGrpcSsl) // deprecated
516 topLevelStats["tot_remote_grpc_ssl"] = atomic.LoadUint64(&totRemoteGrpcSsl)
517 topLevelStats["tot_grpc_queryreject_on_memquota"] =
518 atomic.LoadUint64(&totGrpcQueryRejectOnNotEnoughQuota)
519
520 topLevelStats["tot_grpc_listeners_opened"] =
521 atomic.LoadUint64(&TotGRPCListenersOpened)
522 topLevelStats["tot_grpc_listeners_closed"] =
523 atomic.LoadUint64(&TotGRPCListenersClosed)
524 topLevelStats["tot_grpcs_listeners_opened"] =
525 atomic.LoadUint64(&TotGRPCSListenersOpened)
526 topLevelStats["tot_grpcs_listeners_closed"] =
527 atomic.LoadUint64(&TotGRPCSListenersClosed)
528
529 topLevelStats["batch_bytes_added"] = atomic.LoadUint64(&BatchBytesAdded)
530 topLevelStats["batch_bytes_removed"] = atomic.LoadUint64(&BatchBytesRemoved)
531
532 topLevelStats["tot_batches_flushed_on_maxops"] = atomic.LoadUint64(&TotBatchesFlushedOnMaxOps)
533 topLevelStats["tot_batches_flushed_on_timer"] = atomic.LoadUint64(&TotBatchesFlushedOnTimer)
534 topLevelStats["tot_batches_new"] = atomic.LoadUint64(&TotBatchesNew)
535 topLevelStats["tot_batches_merged"] = atomic.LoadUint64(&TotBatchesMerged)
536
537 topLevelStats["tot_bleve_dest_opened"] = atomic.LoadUint64(&TotBleveDestOpened)
538 topLevelStats["tot_bleve_dest_closed"] = atomic.LoadUint64(&TotBleveDestClosed)
539
540 topLevelStats["tot_rollback_full"] = atomic.LoadUint64(&TotRollbackFull)
541 topLevelStats["tot_rollback_partial"] = atomic.LoadUint64(&TotRollbackPartial)
542
543 topLevelStats["curr_batches_blocked_by_herder"] =
544 atomic.LoadUint64(&TotHerderOnBatchExecuteStartEnd) -
545 atomic.LoadUint64(&TotHerderOnBatchExecuteStartBeg)
546 topLevelStats["total_queries_rejected_by_herder"] =
547 atomic.LoadUint64(&TotHerderQueriesRejected)
548

Callers 2

ServeHTTPMethod · 0.85
gatherIndexStatsFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected