Function NewLabeledStore

plugins/content/local/store.go:88–109

NewLabeledStore returns a new content store using the provided label store Note: content stores which are used underneath a metadata store may not require labels and should use `NewStore`. `NewLabeledStore` is primarily useful for tests or standalone implementations.

(root string, ls LabelStore)

// require labels and should use `NewStore`. `NewLabeledStore` is primarily
// useful for tests or standalone implementations.
func NewLabeledStore(root string, ls LabelStore) (content.Store, error) {
	if _, err := os.Stat(root); err != nil {
		if !errors.Is(err, fs.ErrNotExist) {
			return nil, fmt.Errorf("failed to stat %q: %w", root, err)
		}
		if err := os.MkdirAll(root, 0755); err != nil {
			return nil, fmt.Errorf("failed to mkdir %q: %w", root, err)
		}
	}
	supported, err := fsverity.IsSupported(root)
	if err != nil {
		log.L.WithError(err).WithField("path", root).Warnf("failed check for fsverity support")
	}
	s := &store{
		root:               root,
		ls:                 ls,
		integritySupported: supported,
		locks:              map[string]*lock{},
	}
	s.ensureIngestRootOnce = sync.OnceValue(s.ensureIngestRoot)
	return s, nil
}

func (s *store) Info(ctx context.Context, dgst digest.Digest) (content.Info, error) {
	p, err := s.blobPath(dgst)