|
|
@ -1,6 +1,7 @@ |
|
|
|
package s3api |
|
|
|
|
|
|
|
import ( |
|
|
|
"github.com/chrislusf/seaweedfs/weed/s3api/s3_constants" |
|
|
|
stats_collect "github.com/chrislusf/seaweedfs/weed/stats" |
|
|
|
"net/http" |
|
|
|
"strconv" |
|
|
@ -27,11 +28,12 @@ func (r *StatusRecorder) Flush() { |
|
|
|
|
|
|
|
func track(f http.HandlerFunc, action string) http.HandlerFunc { |
|
|
|
return func(w http.ResponseWriter, r *http.Request) { |
|
|
|
bucket, _ := s3_constants.GetBucketAndObject(r) |
|
|
|
w.Header().Set("Server", "SeaweedFS S3") |
|
|
|
recorder := NewStatusResponseWriter(w) |
|
|
|
start := time.Now() |
|
|
|
f(recorder, r) |
|
|
|
stats_collect.S3RequestHistogram.WithLabelValues(action).Observe(time.Since(start).Seconds()) |
|
|
|
stats_collect.S3RequestCounter.WithLabelValues(action, strconv.Itoa(recorder.Status)).Inc() |
|
|
|
stats_collect.S3RequestHistogram.WithLabelValues(action, bucket).Observe(time.Since(start).Seconds()) |
|
|
|
stats_collect.S3RequestCounter.WithLabelValues(action, strconv.Itoa(recorder.Status), bucket).Inc() |
|
|
|
} |
|
|
|
} |