Merge pull request #44560 from vvoland/client-sharedsize-2206
[22.06 backport] client/list: Handle SharedSize
This commit is contained in:
commit
bb2eab21c6
2 changed files with 44 additions and 0 deletions
|
@ -34,6 +34,9 @@ func (cli *Client) ImageList(ctx context.Context, options types.ImageListOptions
|
||||||
if options.All {
|
if options.All {
|
||||||
query.Set("all", "1")
|
query.Set("all", "1")
|
||||||
}
|
}
|
||||||
|
if options.SharedSize && versions.GreaterThanOrEqualTo(cli.version, "1.42") {
|
||||||
|
query.Set("shared-size", "1")
|
||||||
|
}
|
||||||
|
|
||||||
serverResp, err := cli.get(ctx, "/images/json", query, nil)
|
serverResp, err := cli.get(ctx, "/images/json", query, nil)
|
||||||
defer ensureReaderClosed(serverResp)
|
defer ensureReaderClosed(serverResp)
|
||||||
|
|
|
@ -7,12 +7,15 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"net/url"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/docker/docker/api/types"
|
"github.com/docker/docker/api/types"
|
||||||
"github.com/docker/docker/api/types/filters"
|
"github.com/docker/docker/api/types/filters"
|
||||||
"github.com/docker/docker/errdefs"
|
"github.com/docker/docker/errdefs"
|
||||||
|
"gotest.tools/v3/assert"
|
||||||
|
is "gotest.tools/v3/assert/cmp"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestImageListError(t *testing.T) {
|
func TestImageListError(t *testing.T) {
|
||||||
|
@ -158,3 +161,41 @@ func TestImageListApiBefore125(t *testing.T) {
|
||||||
t.Fatalf("expected 2 images, got %v", images)
|
t.Fatalf("expected 2 images, got %v", images)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Checks if shared-size query parameter is set/not being set correctly
|
||||||
|
// for /images/json.
|
||||||
|
func TestImageListWithSharedSize(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
const sharedSize = "shared-size"
|
||||||
|
for _, tc := range []struct {
|
||||||
|
name string
|
||||||
|
version string
|
||||||
|
options types.ImageListOptions
|
||||||
|
sharedSize string // expected value for the shared-size query param, or empty if it should not be set.
|
||||||
|
}{
|
||||||
|
{name: "unset after 1.42, no options set", version: "1.42"},
|
||||||
|
{name: "set after 1.42, if requested", version: "1.42", options: types.ImageListOptions{SharedSize: true}, sharedSize: "1"},
|
||||||
|
{name: "unset before 1.42, even if requested", version: "1.41", options: types.ImageListOptions{SharedSize: true}},
|
||||||
|
} {
|
||||||
|
tc := tc
|
||||||
|
t.Run(tc.name, func(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
var query url.Values
|
||||||
|
client := &Client{
|
||||||
|
client: newMockClient(func(req *http.Request) (*http.Response, error) {
|
||||||
|
query = req.URL.Query()
|
||||||
|
return &http.Response{
|
||||||
|
StatusCode: http.StatusOK,
|
||||||
|
Body: io.NopCloser(strings.NewReader("[]")),
|
||||||
|
}, nil
|
||||||
|
}),
|
||||||
|
version: tc.version,
|
||||||
|
}
|
||||||
|
_, err := client.ImageList(context.Background(), tc.options)
|
||||||
|
assert.Check(t, err)
|
||||||
|
expectedSet := tc.sharedSize != ""
|
||||||
|
assert.Check(t, is.Equal(query.Has(sharedSize), expectedSet))
|
||||||
|
assert.Check(t, is.Equal(query.Get(sharedSize), tc.sharedSize))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in a new issue