Skip to content

Commit 40e3feb

Browse files
committed
removes empty columns and fixes request details
1 parent e6ee924 commit 40e3feb

File tree

1 file changed

+24
-11
lines changed

1 file changed

+24
-11
lines changed

staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller_debug.go

Lines changed: 24 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ func (cfgCtlr *configController) dumpPriorityLevels(w http.ResponseWriter, r *ht
5858
"ExecutingRequests", // 6
5959
}
6060
tabPrint(tabWriter, rowForHeaders(columnHeaders))
61-
endline(tabWriter)
61+
endLine(tabWriter)
6262
for _, plState := range cfgCtlr.priorityLevelStates {
6363
if plState.queues == nil {
6464
tabPrint(tabWriter, row(
@@ -69,7 +69,7 @@ func (cfgCtlr *configController) dumpPriorityLevels(w http.ResponseWriter, r *ht
6969
"<none>", // 5
7070
"<none>", // 6
7171
))
72-
endline(tabWriter)
72+
endLine(tabWriter)
7373
continue
7474
}
7575
queueSetDigest := plState.queues.Dump(false)
@@ -88,7 +88,7 @@ func (cfgCtlr *configController) dumpPriorityLevels(w http.ResponseWriter, r *ht
8888
queueSetDigest.Waiting, // 5
8989
queueSetDigest.Executing, // 6
9090
))
91-
endline(tabWriter)
91+
endLine(tabWriter)
9292
}
9393
runtime.HandleError(tabWriter.Flush())
9494
}
@@ -105,7 +105,7 @@ func (cfgCtlr *configController) dumpQueues(w http.ResponseWriter, r *http.Reque
105105
"VirtualStart", // 5
106106
}
107107
tabPrint(tabWriter, rowForHeaders(columnHeaders))
108-
endline(tabWriter)
108+
endLine(tabWriter)
109109
for _, plState := range cfgCtlr.priorityLevelStates {
110110
if plState.queues == nil {
111111
tabPrint(tabWriter, row(
@@ -115,7 +115,7 @@ func (cfgCtlr *configController) dumpQueues(w http.ResponseWriter, r *http.Reque
115115
"<none>", // 4
116116
"<none>", // 5
117117
))
118-
endline(tabWriter)
118+
endLine(tabWriter)
119119
continue
120120
}
121121
queueSetDigest := plState.queues.Dump(false)
@@ -127,7 +127,7 @@ func (cfgCtlr *configController) dumpQueues(w http.ResponseWriter, r *http.Reque
127127
q.ExecutingRequests, // 4
128128
q.VirtualStart, // 5
129129
))
130-
endline(tabWriter)
130+
endLine(tabWriter)
131131
}
132132
}
133133
runtime.HandleError(tabWriter.Flush())
@@ -149,6 +149,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
149149
"ArriveTime", // 6
150150
}))
151151
if includeRequestDetails {
152+
continueLine(tabWriter)
152153
tabPrint(tabWriter, rowForHeaders([]string{
153154
"UserName", // 7
154155
"Verb", // 8
@@ -160,7 +161,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
160161
"SubResource", // 14
161162
}))
162163
}
163-
endline(tabWriter)
164+
endLine(tabWriter)
164165
for _, plState := range cfgCtlr.priorityLevelStates {
165166
if plState.queues == nil {
166167
tabPrint(tabWriter, row(
@@ -172,6 +173,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
172173
"<none>", // 6
173174
))
174175
if includeRequestDetails {
176+
continueLine(tabWriter)
175177
tabPrint(tabWriter, row(
176178
"<none>", // 7
177179
"<none>", // 8
@@ -183,7 +185,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
183185
"<none>", // 14
184186
))
185187
}
186-
endline(tabWriter)
188+
endLine(tabWriter)
187189
continue
188190
}
189191
queueSetDigest := plState.queues.Dump(includeRequestDetails)
@@ -198,6 +200,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
198200
r.ArriveTime, // 6
199201
))
200202
if includeRequestDetails {
203+
continueLine(tabWriter)
201204
tabPrint(tabWriter, rowForRequestDetails(
202205
r.UserName, // 7
203206
r.RequestInfo.Verb, // 8
@@ -212,7 +215,7 @@ func (cfgCtlr *configController) dumpRequests(w http.ResponseWriter, r *http.Req
212215
r.RequestInfo.Subresource, // 14
213216
))
214217
}
215-
endline(tabWriter)
218+
endLine(tabWriter)
216219
}
217220
}
218221
}
@@ -223,7 +226,12 @@ func tabPrint(w io.Writer, row string) {
223226
_, err := fmt.Fprint(w, row)
224227
runtime.HandleError(err)
225228
}
226-
func endline(w io.Writer) {
229+
230+
func continueLine(w io.Writer) {
231+
_, err := fmt.Fprint(w, ",\t")
232+
runtime.HandleError(err)
233+
}
234+
func endLine(w io.Writer) {
227235
_, err := fmt.Fprint(w, "\n")
228236
runtime.HandleError(err)
229237
}
@@ -269,9 +277,14 @@ func rowForRequestDetails(username, verb, path, namespace, name, apiVersion, res
269277
username,
270278
verb,
271279
path,
280+
namespace,
281+
name,
282+
apiVersion,
283+
resource,
284+
subResource,
272285
)
273286
}
274287

275288
func row(columns ...string) string {
276-
return strings.Join(columns, ",\t") + ",\t"
289+
return strings.Join(columns, ",\t")
277290
}

0 commit comments

Comments
 (0)