/
server.go
117 lines (98 loc) · 3.19 KB
/
server.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
/*
Copyright 2019 The Knative Authors
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package profiling
import (
"fmt"
"net/http"
"net/http/pprof"
"os"
"strconv"
"go.uber.org/atomic"
"go.uber.org/zap"
corev1 "k8s.io/api/core/v1"
)
const (
// ProfilingPortKey specified the name of an environment variable that
// may be used to override the default profiling port.
ProfilingPortKey = "PROFILING_PORT"
// ProfilingPort specifies the default port where profiling data is available when profiling is enabled
ProfilingPort = 8008
// profilingKey is the name of the key in config-observability config map
// that indicates whether profiling is enabled
profilingKey = "profiling.enable"
)
// Handler holds the main HTTP handler and a flag indicating
// whether the handler is active
type Handler struct {
enabled *atomic.Bool
handler http.Handler
log *zap.SugaredLogger
}
// NewHandler create a new ProfilingHandler which serves runtime profiling data
// according to the given context path
func NewHandler(logger *zap.SugaredLogger, enableProfiling bool) *Handler {
const pprofPrefix = "/debug/pprof/"
mux := http.NewServeMux()
mux.HandleFunc(pprofPrefix, pprof.Index)
mux.HandleFunc(pprofPrefix+"cmdline", pprof.Cmdline)
mux.HandleFunc(pprofPrefix+"profile", pprof.Profile)
mux.HandleFunc(pprofPrefix+"symbol", pprof.Symbol)
mux.HandleFunc(pprofPrefix+"trace", pprof.Trace)
logger.Info("Profiling enabled: ", enableProfiling)
return &Handler{
enabled: atomic.NewBool(enableProfiling),
handler: mux,
log: logger,
}
}
func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
if h.enabled.Load() {
h.handler.ServeHTTP(w, r)
} else {
http.NotFoundHandler().ServeHTTP(w, r)
}
}
func ReadProfilingFlag(config map[string]string) (bool, error) {
profiling, ok := config[profilingKey]
if !ok {
return false, nil
}
enabled, err := strconv.ParseBool(profiling)
if err != nil {
return false, fmt.Errorf("failed to parse the profiling flag: %w", err)
}
return enabled, nil
}
// UpdateFromConfigMap modifies the Enabled flag in the Handler
// according to the value in the given ConfigMap
func (h *Handler) UpdateFromConfigMap(configMap *corev1.ConfigMap) {
enabled, err := ReadProfilingFlag(configMap.Data)
if err != nil {
h.log.Errorw("Failed to update the profiling flag", zap.Error(err))
return
}
if h.enabled.Swap(enabled) != enabled {
h.log.Info("Profiling enabled: ", enabled)
}
}
// NewServer creates a new http server that exposes profiling data on the default profiling port
func NewServer(handler http.Handler) *http.Server {
port := os.Getenv(ProfilingPortKey)
if port == "" {
port = strconv.Itoa(ProfilingPort)
}
return &http.Server{
Addr: ":" + port,
Handler: handler,
}
}