@@ -30,7 +30,6 @@ import (
30
30
"github.com/containerd/errdefs"
31
31
"github.com/containerd/log"
32
32
ocispec "github.com/opencontainers/image-spec/specs-go/v1"
33
- "github.com/sirupsen/logrus"
34
33
)
35
34
36
35
func (ts * localTransferService ) pull (ctx context.Context , ir transfer.ImageFetcher , is transfer.ImageStorer , tops * transfer.Config ) error {
@@ -57,28 +56,28 @@ func (ts *localTransferService) pull(ctx context.Context, ir transfer.ImageFetch
57
56
58
57
// Verify image before pulling.
59
58
for vfName , vf := range ts .config .Verifiers {
60
- log := log .G (ctx ).WithFields (logrus .Fields {
59
+ logger := log .G (ctx ).WithFields (log .Fields {
61
60
"name" : name ,
62
61
"digest" : desc .Digest .String (),
63
62
"verifier" : vfName ,
64
63
})
65
- log .Debug ("Verifying image pull" )
64
+ logger .Debug ("Verifying image pull" )
66
65
67
66
jdg , err := vf .VerifyImage (ctx , name , desc )
68
67
if err != nil {
69
- log .WithError (err ).Error ("No judgement received from verifier" )
68
+ logger .WithError (err ).Error ("No judgement received from verifier" )
70
69
return fmt .Errorf ("blocking pull of %v with digest %v: image verifier %v returned error: %w" , name , desc .Digest .String (), vfName , err )
71
70
}
72
- log = log .WithFields (logrus .Fields {
71
+ logger = logger .WithFields (log .Fields {
73
72
"ok" : jdg .OK ,
74
73
"reason" : jdg .Reason ,
75
74
})
76
75
77
76
if ! jdg .OK {
78
- log .Warn ("Image verifier blocked pull" )
77
+ logger .Warn ("Image verifier blocked pull" )
79
78
return fmt .Errorf ("image verifier %s blocked pull of %v with digest %v for reason: %v" , vfName , name , desc .Digest .String (), jdg .Reason )
80
79
}
81
- log .Debug ("Image verifier allowed pull" )
80
+ logger .Debug ("Image verifier allowed pull" )
82
81
}
83
82
84
83
// TODO: Handle already exists
@@ -89,7 +88,7 @@ func (ts *localTransferService) pull(ctx context.Context, ir transfer.ImageFetch
89
88
tops .Progress (transfer.Progress {
90
89
Event : "fetching image content" ,
91
90
Name : name ,
92
- //Digest: img.Target.Digest.String(),
91
+ // Digest: img.Target.Digest.String(),
93
92
})
94
93
}
95
94
@@ -114,7 +113,7 @@ func (ts *localTransferService) pull(ctx context.Context, ir transfer.ImageFetch
114
113
115
114
ctx , cancel := context .WithCancel (ctx )
116
115
if tops .Progress != nil {
117
- progressTracker = NewProgressTracker (name , "downloading" ) //Pass in first name as root
116
+ progressTracker = NewProgressTracker (name , "downloading" ) // Pass in first name as root
118
117
go progressTracker .HandleProgress (ctx , tops .Progress , NewContentStatusTracker (store ))
119
118
defer progressTracker .Wait ()
120
119
}
0 commit comments