Function lintVectorDir

tools/vectorlint/main.go:199–237

(schemaCompiler *jsonschema.Compiler, results *schemaLintResults, vectorDir string)

}

func lintVectorDir(schemaCompiler *jsonschema.Compiler, results *schemaLintResults, vectorDir string) error {
	err := filepath.WalkDir(vectorDir, func(path string, d fs.DirEntry, err error) error {
		if err != nil {
			return err
		}

		if d.IsDir() || !strings.HasSuffix(d.Name(), ".json") {
			return nil
		}

		if vectorRegex != nil && !vectorRegex.MatchString(d.Name()) {
			return nil
		}

		results.total++

		vectorData, err := os.ReadFile(path)
		if err != nil {
			return fmt.Errorf("failed to read %s: %w", path, err)
		}

		if err := lintVectorTestGroups(vectorData, path); err != nil {
			log.Printf("❌ %q: %s\n", path, err)
			results.invalid++
			return nil
		}

		if err := lintVectorToSchema(schemaCompiler, vectorData, path, results); err != nil {
			return err
		}

		return nil
	})
	if err != nil {
		return fmt.Errorf("error walking directory: %w", err)
	}

	return nil
}

func lintVectorTestGroups(vectorData []byte, path string) error {
	var vector struct {