(reader io.Reader, validate bool)
| 119 | } |
| 120 | |
| 121 | func (c *labelInjectingClient) Build(reader io.Reader, validate bool) (kube.ResourceList, error) { |
| 122 | resourceList, err := c.Interface.Build(reader, validate) |
| 123 | if err != nil { |
| 124 | return resourceList, err |
| 125 | } |
| 126 | err = resourceList.Visit(func(r *resource.Info, err error) error { |
| 127 | if err != nil { |
| 128 | return err |
| 129 | } |
| 130 | objMap, err := runtime.DefaultUnstructuredConverter.ToUnstructured(r.Object) |
| 131 | if err != nil { |
| 132 | return err |
| 133 | } |
| 134 | u := &unstructured.Unstructured{Object: objMap} |
| 135 | labels := u.GetLabels() |
| 136 | if labels == nil { |
| 137 | labels = map[string]string{} |
| 138 | } |
| 139 | for k, v := range c.labels { |
| 140 | labels[k] = v |
| 141 | } |
| 142 | u.SetLabels(labels) |
| 143 | return nil |
| 144 | }) |
| 145 | if err != nil { |
| 146 | return nil, err |
| 147 | } |
| 148 | return resourceList, nil |
| 149 | } |
no outgoing calls