Function LoadAllDir

internal/plugin/loader.go:173–200

LoadAllDir load all plugins found beneath the base directory, using the provided error filter to determine whether to fail on individual plugin load errors. This scans only one directory level.

(basedir string, errorFilter ErrorFilterFunc)

//
// This scans only one directory level.
func LoadAllDir(basedir string, errorFilter ErrorFilterFunc) ([]Plugin, error) {
	// We want <basedir>/*/plugin.yaml
	scanpath := filepath.Join(basedir, "*", PluginFileName)
	matches, err := filepath.Glob(scanpath)
	if err != nil {
		return nil, fmt.Errorf("failed to search for plugins in %q: %w", scanpath, err)
	}

	plugins := make([]Plugin, 0, len(matches))

	// empty dir should load
	if len(matches) == 0 {
		return plugins, nil
	}

	for _, yamlFile := range matches {
		dir := filepath.Dir(yamlFile)
		p, err := LoadDir(dir)
		if err != nil {
			if errNew := errorFilter(yamlFile, err); errNew != nil {
				return plugins, errNew
			}
		} else {
			plugins = append(plugins, p)
		}
	}
	return plugins, detectDuplicates(plugins)
}

// findFunc is a function that finds plugins in a directory
type findFunc func(pluginsDir string) ([]Plugin, error)