mirror of
https://github.com/hanzoai/deploy.git
synced 2026-10-07 08:44:50 +00:00
zeekayandHanzo Dev
b726a55cab
github.com/argoproj/pkg/v2 was one of two live argoproj dependencies. It is 11 files and 176K total, and we used five packages from it: grpc/http, kubeclientmetrics, stats, sync, time. Vendored into util/vendored/ and the dependency dropped from go.mod, so the gRPC surface (2 references, in grpc-http/forwarders.go) is now ours to remove on our own schedule rather than upstream's. Kubernetes client-go pulls gRPC transitively regardless, so this is isolation — a realistic first step — not a claim that gRPC is gone. Internalized rather than forked to a shared repo because the only other consumer, hanzo/gitops, has zero live deployments and zero dependents. A second repo would be a second thing to version for one caller. NOTICE carries the Apache-2.0 attribution. go build ./... exit 0. Co-authored-by: Hanzo Dev <[email protected]>
83 lines
1.8 KiB
Go
83 lines
1.8 KiB
Go
package stats
|
|
|
|
import (
|
|
"os"
|
|
"os/signal"
|
|
"runtime"
|
|
"runtime/pprof"
|
|
"syscall"
|
|
"time"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
// StartStatsTicker starts a goroutine which dumps stats at a specified interval
|
|
func StartStatsTicker(d time.Duration) {
|
|
ticker := time.NewTicker(d)
|
|
go func() {
|
|
for {
|
|
<-ticker.C
|
|
LogStats()
|
|
}
|
|
}()
|
|
}
|
|
|
|
// RegisterStackDumper spawns a goroutine which dumps stack trace upon a SIGUSR1
|
|
func RegisterStackDumper() {
|
|
go func() {
|
|
sigs := make(chan os.Signal, 1)
|
|
signal.Notify(sigs, syscall.SIGUSR1)
|
|
for {
|
|
<-sigs
|
|
LogStats()
|
|
LogStack()
|
|
}
|
|
}()
|
|
}
|
|
|
|
// RegisterHeapDumper spawns a goroutine which dumps heap profile upon a SIGUSR2
|
|
func RegisterHeapDumper(filePath string) {
|
|
go func() {
|
|
sigs := make(chan os.Signal, 1)
|
|
signal.Notify(sigs, syscall.SIGUSR2)
|
|
for {
|
|
<-sigs
|
|
runtime.GC()
|
|
if _, err := os.Stat(filePath); err == nil {
|
|
err = os.Remove(filePath)
|
|
if err != nil {
|
|
log.Warnf("could not delete heap profile file: %v", err)
|
|
return
|
|
}
|
|
}
|
|
f, err := os.Create(filePath)
|
|
if err != nil {
|
|
log.Warnf("could not create heap profile file: %v", err)
|
|
return
|
|
}
|
|
|
|
if err := pprof.WriteHeapProfile(f); err != nil {
|
|
log.Warnf("could not write heap profile: %v", err)
|
|
return
|
|
} else {
|
|
log.Infof("dumped heap profile to %s", filePath)
|
|
}
|
|
}
|
|
}()
|
|
}
|
|
|
|
// LogStats logs runtime statistics
|
|
func LogStats() {
|
|
var m runtime.MemStats
|
|
runtime.ReadMemStats(&m)
|
|
log.Infof("Alloc=%v TotalAlloc=%v Sys=%v NumGC=%v Goroutines=%d", m.Alloc/1024, m.TotalAlloc/1024, m.Sys/1024, m.NumGC, runtime.NumGoroutine())
|
|
|
|
}
|
|
|
|
// LogStack will log the current stack
|
|
func LogStack() {
|
|
buf := make([]byte, 1<<20)
|
|
stacklen := runtime.Stack(buf, true)
|
|
log.Infof("*** goroutine dump...\n%s\n*** end\n", buf[:stacklen])
|
|
}
|