Method MkdirMetadata

backend/union/union.go:192–234

MkdirMetadata makes the root directory of the Fs object

(ctx context.Context, dir string, metadata fs.Metadata)

// MkdirMetadata makes the root directory of the Fs object
func (f *Fs) MkdirMetadata(ctx context.Context, dir string, metadata fs.Metadata) (fs.Directory, error) {
	upstreams, err := f.create(ctx, dir)
	if err != nil {
		return nil, err
	}
	errs := Errors(make([]error, len(upstreams)))
	entries := make([]upstream.Entry, len(upstreams))
	multithread(len(upstreams), func(i int) {
		u := upstreams[i]
		if do := u.Features().MkdirMetadata; do != nil {
			newDir, err := do(ctx, dir, metadata)
			if err != nil {
				errs[i] = fmt.Errorf("%s: %w", upstreams[i].Name(), err)
			} else {
				entries[i], err = u.WrapEntry(newDir)
				if err != nil {
					errs[i] = fmt.Errorf("%s: %w", upstreams[i].Name(), err)
				}
			}

		} else {
			// Just do Mkdir on upstreams which don't support MkdirMetadata
			err := u.Mkdir(ctx, dir)
			if err != nil {
				errs[i] = fmt.Errorf("%s: %w", upstreams[i].Name(), err)
			}
		}
	})
	err = errs.Err()
	if err != nil {
		return nil, err
	}

	entry, err := f.wrapEntries(entries...)
	if err != nil {
		return nil, err
	}
	newDir, ok := entry.(fs.Directory)
	if !ok {
		return nil, fmt.Errorf("internal error: expecting %T to be an fs.Directory", entry)
	}
	return newDir, nil
}

// Purge all files in the directory
//