client/plugin_upgrade.go

   1 package client
   2
   3 import (
   4         "io"
   5         "net/url"
   6
   7         "github.com/docker/distribution/reference"
   8         "github.com/docker/docker/api/types"
   9         "github.com/pkg/errors"
  10         "golang.org/x/net/context"
  11 )
  12
  13 // PluginUpgrade upgrades a plugin
  14 func (cli *Client) PluginUpgrade(ctx context.Context, name string, options types.PluginInstallOptions) (rc io.ReadCloser, err error) {
  15         if err := cli.NewVersionError("1.26", "plugin upgrade"); err != nil {
  16                 return nil, err
  17         }
  18         query := url.Values{}
  19         if _, err := reference.ParseNormalizedNamed(options.RemoteRef); err != nil {
  20                 return nil, errors.Wrap(err, "invalid remote reference")
  21         }
  22         query.Set("remote", options.RemoteRef)
  23
  24         privileges, err := cli.checkPluginPermissions(ctx, query, options)
  25         if err != nil {
  26                 return nil, err
  27         }
  28
  29         resp, err := cli.tryPluginUpgrade(ctx, query, privileges, name, options.RegistryAuth)
  30         if err != nil {
  31                 return nil, err
  32         }
  33         return resp.body, nil
  34 }
  35
  36 func (cli *Client) tryPluginUpgrade(ctx context.Context, query url.Values, privileges types.PluginPrivileges, name, registryAuth string) (serverResponse, error) {
  37         headers := map[string][]string{"X-Registry-Auth": {registryAuth}}
  38         return cli.post(ctx, "/plugins/"+name+"/upgrade", query, privileges, headers)
  39 }