MCPcopy
hub / github.com/kubernetes/kubectl / podTableWatchBody

Function podTableWatchBody

pkg/cmd/get/get_test.go:3072–3092  ·  view source on GitHub ↗

build meta table watch events from pod watch events

(codec runtime.Codec, events []watch.Event)

Source from the content-addressed store, hash-verified

3070
3071// build meta table watch events from pod watch events
3072func podTableWatchBody(codec runtime.Codec, events []watch.Event) io.ReadCloser {
3073 tableEvents := []watch.Event{}
3074 for i, e := range events {
3075 b := bytes.NewBuffer(nil)
3076 codec.Encode(e.Object, b)
3077 var columns []metav1.TableColumnDefinition
3078 if i == 0 {
3079 columns = podColumns
3080 }
3081 tableEvents = append(tableEvents, watch.Event{
3082 Type: e.Type,
3083 Object: &metav1.Table{
3084 ColumnDefinitions: columns,
3085 Rows: []metav1.TableRow{{
3086 Object: runtime.RawExtension{Raw: b.Bytes()},
3087 Cells: []interface{}{e.Object.(*corev1.Pod).Name, "0/0", "", int64(0), "<unknown>", "<none>", "<none>", "<none>", "<none>"},
3088 }}},
3089 })
3090 }
3091 return watchBody(codec, tableEvents)
3092}
3093
3094// build a meta table response from a service list
3095func serviceTableObjBody(codec runtime.Codec, services ...corev1.Service) io.ReadCloser {

Callers 6

TestWatchTableResourceFunction · 0.85
TestWatchOnlyTableListFunction · 0.85

Calls 1

watchBodyFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…