@@ -17,6 +17,7 @@ import (
17
17
"github.com/docker/distribution/reference"
18
18
distclient "github.com/docker/distribution/registry/client"
19
19
"github.com/docker/distribution/registry/client/auth"
20
+ "github.com/docker/distribution/registry/client/auth/challenge"
20
21
"github.com/docker/distribution/registry/client/transport"
21
22
22
23
imageapi "github.com/openshift/origin/pkg/image/apis/image"
@@ -40,7 +41,7 @@ func UploadBlob(
40
41
41
42
var rt http.RoundTripper
42
43
if creds != nil {
43
- challengeManager := auth . NewSimpleChallengeManager ()
44
+ challengeManager := challenge . NewSimpleManager ()
44
45
_ , err := ping (challengeManager , serverURL .String ()+ "/v2/" , "" )
45
46
if err != nil {
46
47
return distribution.Descriptor {}, err
@@ -233,7 +234,7 @@ func (tcs *testCredentialStore) SetRefreshToken(u *url.URL, service string, toke
233
234
234
235
// ping pings the provided endpoint to determine its required authorization challenges.
235
236
// If a version header is provided, the versions will be returned.
236
- func ping (manager auth. ChallengeManager , endpoint , versionHeader string ) ([]auth.APIVersion , error ) {
237
+ func ping (manager challenge. Manager , endpoint , versionHeader string ) ([]auth.APIVersion , error ) {
237
238
resp , err := http .Get (endpoint )
238
239
if err != nil {
239
240
return nil , err
0 commit comments