diff options
author | Michael Crosby <crosbymichael@gmail.com> | 2016-09-06 11:46:37 -0700 |
---|---|---|
committer | Michael Crosby <crosbymichael@gmail.com> | 2016-09-07 11:05:58 -0700 |
commit | 7c36a1af031b510cd990cf488ee5998a3efb450f (patch) | |
tree | 477f7c37b71fbc6dc641d7b294b68e17d6c869ec /client/image_search.go | |
parent | 91e197d614547f0202e6ae9b8a24d88ee131d950 (diff) | |
download | docker-7c36a1af031b510cd990cf488ee5998a3efb450f.tar.gz |
Move engine-api client package
This moves the engine-api client package to `/docker/docker/client`.
Signed-off-by: Michael Crosby <crosbymichael@gmail.com>
Diffstat (limited to 'client/image_search.go')
-rw-r--r-- | client/image_search.go | 51 |
1 files changed, 51 insertions, 0 deletions
diff --git a/client/image_search.go b/client/image_search.go new file mode 100644 index 0000000000..b0fcd5c23d --- /dev/null +++ b/client/image_search.go @@ -0,0 +1,51 @@ +package client + +import ( + "encoding/json" + "fmt" + "net/http" + "net/url" + + "github.com/docker/docker/api/types" + "github.com/docker/docker/api/types/filters" + "github.com/docker/docker/api/types/registry" + "golang.org/x/net/context" +) + +// ImageSearch makes the docker host to search by a term in a remote registry. +// The list of results is not sorted in any fashion. +func (cli *Client) ImageSearch(ctx context.Context, term string, options types.ImageSearchOptions) ([]registry.SearchResult, error) { + var results []registry.SearchResult + query := url.Values{} + query.Set("term", term) + query.Set("limit", fmt.Sprintf("%d", options.Limit)) + + if options.Filters.Len() > 0 { + filterJSON, err := filters.ToParam(options.Filters) + if err != nil { + return results, err + } + query.Set("filters", filterJSON) + } + + resp, err := cli.tryImageSearch(ctx, query, options.RegistryAuth) + if resp.statusCode == http.StatusUnauthorized && options.PrivilegeFunc != nil { + newAuthHeader, privilegeErr := options.PrivilegeFunc() + if privilegeErr != nil { + return results, privilegeErr + } + resp, err = cli.tryImageSearch(ctx, query, newAuthHeader) + } + if err != nil { + return results, err + } + + err = json.NewDecoder(resp.body).Decode(&results) + ensureReaderClosed(resp) + return results, err +} + +func (cli *Client) tryImageSearch(ctx context.Context, query url.Values, registryAuth string) (serverResponse, error) { + headers := map[string][]string{"X-Registry-Auth": {registryAuth}} + return cli.get(ctx, "/images/search", query, headers) +} |