build meta table watch events from pod watch events
(codec runtime.Codec, events []watch.Event)
| 3070 | |
| 3071 | // build meta table watch events from pod watch events |
| 3072 | func 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 |
| 3095 | func serviceTableObjBody(codec runtime.Codec, services ...corev1.Service) io.ReadCloser { |
no test coverage detected
searching dependent graphs…