Browse Source

Merge branch 'master' of https://github.com/seaweedfs/seaweedfs

pull/4097/head
chrislu 2 years ago
parent
commit
7111c08289
  1. 6
      k8s/charts/seaweedfs/templates/filer-statefulset.yaml
  2. 12
      k8s/charts/seaweedfs/values.yaml
  3. 12
      weed/stats/metrics.go

6
k8s/charts/seaweedfs/templates/filer-statefulset.yaml

@ -97,6 +97,12 @@ spec:
value: {{ $value | quote }}
{{- end }}
{{- end }}
{{- if .Values.filer.secretExtraEnvironmentVars }}
{{- range $key, $value := .Values.filer.secretExtraEnvironmentVars }}
- name: {{ $key }}
valueFrom: {{ toYaml $value | nindent 16 }}
{{- end }}
{{- end }}
command:
- "/bin/sh"
- "-ec"

12
k8s/charts/seaweedfs/values.yaml

@ -407,6 +407,18 @@ filer:
# directories under this folder will be automatically creating a separate bucket
WEED_FILER_BUCKETS_FOLDER: "/buckets"
# secret env variables
secretExtraEnvironmentVars: []
# WEED_POSTGRES_USERNAME:
# secretKeyRef:
# name: postgres-credentials
# key: username
# WEED_POSTGRES_PASSWORD:
# secretKeyRef:
# name: postgres-credentials
# key: password
s3:
enabled: true
port: 8333

12
weed/stats/metrics.go

@ -1,7 +1,6 @@
package stats
import (
"fmt"
"log"
"net"
"net/http"
@ -282,12 +281,21 @@ func LoopPushingMetric(name, instance, addr string, intervalSeconds int) {
}
}
func JoinHostPort(host string, port int) string {
portStr := strconv.Itoa(port)
if strings.HasPrefix(host, "[") && strings.HasSuffix(host, "]") {
return host + ":" + portStr
}
return net.JoinHostPort(host, portStr)
}
func StartMetricsServer(ip string, port int) {
if port == 0 {
return
}
http.Handle("/metrics", promhttp.HandlerFor(Gather, promhttp.HandlerOpts{}))
log.Fatal(http.ListenAndServe(fmt.Sprintf("%s:%d", ip, port), nil))
log.Fatal(http.ListenAndServe(JoinHostPort(ip, port), nil))
}
func SourceName(port uint32) string {

Loading…
Cancel
Save