|
|
|
@ -186,7 +186,7 @@ func (c *Client) Get(namespace string, reader io.Reader) (string, error) {
|
|
|
|
|
}
|
|
|
|
|
for _, o := range ot {
|
|
|
|
|
if err := p.PrintObj(o, buf); err != nil {
|
|
|
|
|
log.Printf("failed to print object type %d, object: %d :\n %v", t, o, err)
|
|
|
|
|
log.Printf("failed to print object type %s, object: %q :\n %v", t, o, err)
|
|
|
|
|
return "", err
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -233,17 +233,17 @@ func (c *Client) Update(namespace string, originalReader, targetReader io.Reader
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
kind := info.Mapping.GroupVersionKind.Kind
|
|
|
|
|
log.Printf("Created a new %s called %d\n", kind, info.Name)
|
|
|
|
|
log.Printf("Created a new %s called %q\n", kind, info.Name)
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
originalInfo := original.Get(info)
|
|
|
|
|
if originalInfo == nil {
|
|
|
|
|
return fmt.Errorf("no resource with the name %d found", info.Name)
|
|
|
|
|
return fmt.Errorf("no resource with the name %q found", info.Name)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if err := updateResource(c, info, originalInfo.Object, recreate); err != nil {
|
|
|
|
|
log.Printf("error updating the resource %d:\n\t %v", info.Name, err)
|
|
|
|
|
log.Printf("error updating the resource %q:\n\t %v", info.Name, err)
|
|
|
|
|
updateErrors = append(updateErrors, err.Error())
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -258,9 +258,9 @@ func (c *Client) Update(namespace string, originalReader, targetReader io.Reader
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
for _, info := range original.Difference(target) {
|
|
|
|
|
log.Printf("Deleting %d in %s...", info.Name, info.Namespace)
|
|
|
|
|
log.Printf("Deleting %q in %s...", info.Name, info.Namespace)
|
|
|
|
|
if err := deleteResource(c, info); err != nil {
|
|
|
|
|
log.Printf("Failed to delete %d, err: %s", info.Name, err)
|
|
|
|
|
log.Printf("Failed to delete %q, err: %s", info.Name, err)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if shouldWait {
|
|
|
|
@ -278,7 +278,7 @@ func (c *Client) Delete(namespace string, reader io.Reader) error {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
return perform(c, namespace, infos, func(info *resource.Info) error {
|
|
|
|
|
log.Printf("Starting delete for %d %s", info.Name, info.Mapping.GroupVersionKind.Kind)
|
|
|
|
|
log.Printf("Starting delete for %q %s", info.Name, info.Mapping.GroupVersionKind.Kind)
|
|
|
|
|
err := deleteResource(c, info)
|
|
|
|
|
return skipIfNotFound(err)
|
|
|
|
|
})
|
|
|
|
@ -350,7 +350,7 @@ func deleteResource(c *Client, info *resource.Info) error {
|
|
|
|
|
}
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
log.Printf("Using reaper for deleting %d", info.Name)
|
|
|
|
|
log.Printf("Using reaper for deleting %q", info.Name)
|
|
|
|
|
return reaper.Stop(info.Namespace, info.Name, 0, nil)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|