MCPcopy
hub / github.com/containerd/containerd / Active

Method Active

core/transfer/local/progress.go:345–357  ·  view source on GitHub ↗
(ctx context.Context, _ ...string)

Source from the content-addressed store, hash-verified

343}
344
345func (c *contentStatusTracker) Active(ctx context.Context, _ ...string) (ActiveJobs, error) {
346 active, err := c.cs.ListStatuses(ctx)
347 if err != nil {
348 log.G(ctx).WithError(err).Error("failed to list statuses for progress")
349 }
350 sort.Slice(active, func(i, j int) bool {
351 return active[i].Ref < active[j].Ref
352 })
353
354 return &contentActive{
355 active: active,
356 }, nil
357}
358
359func (c *contentStatusTracker) Check(ctx context.Context, dgst digest.Digest) (bool, error) {
360 _, err := c.cs.Info(ctx, dgst)

Callers

nothing calls this directly

Calls 2

ListStatusesMethod · 0.65
ErrorMethod · 0.45

Tested by

no test coverage detected