diff --git a/registry/client/repository.go b/registry/client/repository.go index 9846c42c..f9499552 100644 --- a/registry/client/repository.go +++ b/registry/client/repository.go @@ -62,7 +62,7 @@ func checkHTTPRedirect(req *http.Request, via []*http.Request) error { } // NewRegistry creates a registry namespace which can be used to get a listing of repositories -func NewRegistry(ctx context.Context, baseURL string, transport http.RoundTripper) (Registry, error) { +func NewRegistry(baseURL string, transport http.RoundTripper) (Registry, error) { ub, err := v2.NewURLBuilderFromString(baseURL, false) if err != nil { return nil, err @@ -75,9 +75,8 @@ func NewRegistry(ctx context.Context, baseURL string, transport http.RoundTrippe } return ®istry{ - client: client, - ub: ub, - context: ctx, + client: client, + ub: ub, }, nil } @@ -133,7 +132,7 @@ func (r *registry) Repositories(ctx context.Context, entries []string, last stri } // NewRepository creates a new Repository for the given repository name and base URL. -func NewRepository(ctx context.Context, name reference.Named, baseURL string, transport http.RoundTripper) (distribution.Repository, error) { +func NewRepository(name reference.Named, baseURL string, transport http.RoundTripper) (distribution.Repository, error) { ub, err := v2.NewURLBuilderFromString(baseURL, false) if err != nil { return nil, err @@ -146,10 +145,9 @@ func NewRepository(ctx context.Context, name reference.Named, baseURL string, tr } return &repository{ - client: client, - ub: ub, - name: name, - context: ctx, + client: client, + ub: ub, + name: name, }, nil } @@ -190,19 +188,17 @@ func (r *repository) Manifests(ctx context.Context, options ...distribution.Mani func (r *repository) Tags(ctx context.Context) distribution.TagService { return &tags{ - client: r.client, - ub: r.ub, - context: r.context, - name: r.Named(), + client: r.client, + ub: r.ub, + name: r.Named(), } } // tags implements remote tagging operations. type tags struct { - client *http.Client - ub *v2.URLBuilder - context context.Context - name reference.Named + client *http.Client + ub *v2.URLBuilder + name reference.Named } // All returns all tags diff --git a/registry/client/repository_test.go b/registry/client/repository_test.go index 45ef24cd..e5a6dad0 100644 --- a/registry/client/repository_test.go +++ b/registry/client/repository_test.go @@ -118,7 +118,7 @@ func TestBlobDelete(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -140,7 +140,7 @@ func TestBlobFetch(t *testing.T) { ctx := context.Background() repo, _ := reference.WithName("test.example.com/repo1") - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -194,7 +194,7 @@ func TestBlobExistsNoContentLength(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -220,7 +220,7 @@ func TestBlobExists(t *testing.T) { ctx := context.Background() repo, _ := reference.WithName("test.example.com/repo1") - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -325,7 +325,7 @@ func TestBlobUploadChunked(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -435,7 +435,7 @@ func TestBlobUploadMonolithic(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -512,7 +512,7 @@ func TestBlobMount(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -723,7 +723,7 @@ func TestV1ManifestFetch(t *testing.T) { e, c := testServer(m) defer c() - r, err := NewRepository(context.Background(), repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -795,7 +795,7 @@ func TestManifestFetchWithEtag(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -836,7 +836,7 @@ func TestManifestDelete(t *testing.T) { e, c := testServer(m) defer c() - r, err := NewRepository(context.Background(), repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -899,7 +899,7 @@ func TestManifestPut(t *testing.T) { e, c := testServer(m) defer c() - r, err := NewRepository(context.Background(), repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -952,7 +952,7 @@ func TestManifestTags(t *testing.T) { e, c := testServer(m) defer c() - r, err := NewRepository(context.Background(), repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -1009,7 +1009,7 @@ func TestObtainsErrorForMissingTag(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -1040,7 +1040,7 @@ func TestObtainsManifestForTagWithoutHeaders(t *testing.T) { defer c() ctx := context.Background() - r, err := NewRepository(ctx, repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -1098,7 +1098,7 @@ func TestManifestTagsPaginated(t *testing.T) { s.Config.Handler = testutil.NewHandler(m) - r, err := NewRepository(context.Background(), repo, s.URL, nil) + r, err := NewRepository(repo, s.URL, nil) if err != nil { t.Fatal(err) } @@ -1146,7 +1146,7 @@ func TestManifestUnauthorized(t *testing.T) { e, c := testServer(m) defer c() - r, err := NewRepository(context.Background(), repo, e, nil) + r, err := NewRepository(repo, e, nil) if err != nil { t.Fatal(err) } @@ -1183,7 +1183,7 @@ func TestCatalog(t *testing.T) { entries := make([]string, 5) - r, err := NewRegistry(context.Background(), e, nil) + r, err := NewRegistry(e, nil) if err != nil { t.Fatal(err) } @@ -1215,7 +1215,7 @@ func TestCatalogInParts(t *testing.T) { entries := make([]string, 2) - r, err := NewRegistry(context.Background(), e, nil) + r, err := NewRegistry(e, nil) if err != nil { t.Fatal(err) } diff --git a/registry/proxy/proxyregistry.go b/registry/proxy/proxyregistry.go index a6413fda..e8a8f352 100644 --- a/registry/proxy/proxyregistry.go +++ b/registry/proxy/proxyregistry.go @@ -146,7 +146,7 @@ func (pr *proxyingRegistry) Repository(ctx context.Context, name reference.Named return nil, err } - remoteRepo, err := client.NewRepository(ctx, name, pr.remoteURL.String(), tr) + remoteRepo, err := client.NewRepository(name, pr.remoteURL.String(), tr) if err != nil { return nil, err }