Skip to content

Commit

Permalink
metrics:add heap release metrics
Browse files Browse the repository at this point in the history
  • Loading branch information
fengzi committed Apr 19, 2018
1 parent 410a73c commit 0983ed1
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions metrics/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,22 +95,28 @@ func collectSystemMetrics() {
}

allocs := metrics.GetOrRegisterMeter("system_allocs", nil)

// totalAllocs := metrics.GetOrRegisterMeter("system_total_allocs", nil)
sys := metrics.GetOrRegisterMeter("system_sys", nil)
frees := metrics.GetOrRegisterMeter("system_frees", nil)
heapInuse := metrics.GetOrRegisterMeter("system_heapInuse", nil)
stackInuse := metrics.GetOrRegisterMeter("system_stackInuse", nil)
releases := metrics.GetOrRegisterMeter("system_release", nil)

for i := 1; ; i++ {
select {
case <-quitCh:
return
default:
runtime.ReadMemStats(memstats[i%2])
allocs.Mark(int64(memstats[i%2].Alloc - memstats[(i-1)%2].Alloc))

sys.Mark(int64(memstats[i%2].Sys - memstats[(i-1)%2].Sys))
frees.Mark(int64(memstats[i%2].Frees - memstats[(i-1)%2].Frees))
heapInuse.Mark(int64(memstats[i%2].HeapInuse - memstats[(i-1)%2].HeapInuse))
stackInuse.Mark(int64(memstats[i%2].StackInuse - memstats[(i-1)%2].StackInuse))
releases.Mark(int64(memstats[i%2].HeapReleased - memstats[(i-1)%2].HeapReleased))

time.Sleep(2 * time.Second)
}
}
Expand Down

0 comments on commit 0983ed1

Please sign in to comment.