@ -119,7 +119,7 @@ func TestUpdate(t *testing.T) {
}
c := &Client{Factory: f}
if err := c.Update("test", objBody(codec, &listA), objBody(codec, &listB)); err != nil {
if err := c.Update("test", objBody(codec, &listA), objBody(codec, &listB), false); err != nil {
t.Fatal(err)
@ -167,7 +167,7 @@ func (p *PrintingKubeClient) WatchUntilReady(ns string, r io.Reader) error {
// Update implements KubeClient Update.
func (p *PrintingKubeClient) Update(ns string, currentReader, modifiedReader io.Reader) error {
func (p *PrintingKubeClient) Update(ns string, currentReader, modifiedReader io.Reader, restart bool) error {
_, err := io.Copy(p.Out, modifiedReader)
return err
@ -44,7 +44,7 @@ func (k *mockKubeClient) Get(ns string, r io.Reader) (string, error) {
func (k *mockKubeClient) Delete(ns string, r io.Reader) error {
return nil
func (k *mockKubeClient) Update(ns string, currentReader, modifiedReader io.Reader) error {
func (k *mockKubeClient) Update(ns string, currentReader, modifiedReader io.Reader, restart bool) error {
func (k *mockKubeClient) WatchUntilReady(ns string, r io.Reader) error {
@ -1361,7 +1361,7 @@ type updateFailingKubeClient struct {
environment.PrintingKubeClient
func (u *updateFailingKubeClient) Update(namespace string, originalReader, modifiedReader io.Reader) error {
func (u *updateFailingKubeClient) Update(namespace string, originalReader, modifiedReader io.Reader, restart bool) error {
return errors.New("Failed update in kube client")