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
|
// Copyright (C) 2015 The Android Open Source Project
//
// 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 com.google.gerrit.server.git;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import com.google.gerrit.metrics.Counter1;
import com.google.gerrit.metrics.Description;
import com.google.gerrit.metrics.Description.Units;
import com.google.gerrit.metrics.Field;
import com.google.gerrit.metrics.Histogram1;
import com.google.gerrit.metrics.MetricMaker;
import com.google.gerrit.metrics.Timer1;
import com.google.gerrit.server.logging.Metadata;
import com.google.inject.Inject;
import com.google.inject.Singleton;
import org.eclipse.jgit.storage.pack.PackStatistics;
import org.eclipse.jgit.transport.PostUploadHook;
@Singleton
public class UploadPackMetricsHook implements PostUploadHook {
enum Operation {
CLONE,
FETCH;
}
private final Counter1<Operation> requestCount;
private final Timer1<Operation> counting;
private final Timer1<Operation> compressing;
private final Timer1<Operation> writing;
private final Histogram1<Operation> packBytes;
@Inject
UploadPackMetricsHook(MetricMaker metricMaker) {
Field<Operation> operationField =
Field.ofEnum(Operation.class, "operation", Metadata.Builder::gitOperation)
.description("The name of the operation (CLONE, FETCH).")
.build();
requestCount =
metricMaker.newCounter(
"git/upload-pack/request_count",
new Description("Total number of git-upload-pack requests")
.setRate()
.setUnit("requests"),
operationField);
counting =
metricMaker.newTimer(
"git/upload-pack/phase_counting",
new Description("Time spent in the 'Counting...' phase")
.setCumulative()
.setUnit(Units.MILLISECONDS),
operationField);
compressing =
metricMaker.newTimer(
"git/upload-pack/phase_compressing",
new Description("Time spent in the 'Compressing...' phase")
.setCumulative()
.setUnit(Units.MILLISECONDS),
operationField);
writing =
metricMaker.newTimer(
"git/upload-pack/phase_writing",
new Description("Time spent transferring bytes to client")
.setCumulative()
.setUnit(Units.MILLISECONDS),
operationField);
packBytes =
metricMaker.newHistogram(
"git/upload-pack/pack_bytes",
new Description("Distribution of sizes of packs sent to clients")
.setCumulative()
.setUnit(Units.BYTES),
operationField);
}
@Override
public void onPostUpload(PackStatistics stats) {
Operation op = Operation.FETCH;
if (stats.getUninterestingObjects() == null || stats.getUninterestingObjects().isEmpty()) {
op = Operation.CLONE;
}
requestCount.increment(op);
counting.record(op, stats.getTimeCounting(), MILLISECONDS);
compressing.record(op, stats.getTimeCompressing(), MILLISECONDS);
writing.record(op, stats.getTimeWriting(), MILLISECONDS);
packBytes.record(op, stats.getTotalBytes());
}
}
|
