indexing

type FileWatcher struct {
	// contains filtered or unexported fields
}

type Indexer interface {
	// IndexFile processes a single file into the Vector/Graph stores.
	IndexFile(ctx context.Context, filePath string) (*core.IndexingContext, error)

	// IndexDirectory concurrently processes an entire directory.
	IndexDirectory(ctx context.Context, dirPath string, recursive bool) error

	// IndexText indexes plain text content directly (no file parsing required).
	// This is useful for programmatic document management from APIs, databases, etc.
	IndexText(ctx context.Context, text string, metadata ...map[string]any) error

	// IndexTexts indexes multiple plain text contents in batch.
	IndexTexts(ctx context.Context, texts []string, metadata ...map[string]any) error

	// IndexDocuments indexes documents directly into Vector/Doc/Graph stores.
	IndexDocuments(ctx context.Context, docs ...*core.Document) error

	// DeleteDocument removes a document and all its associated chunks and vectors.
	DeleteDocument(ctx context.Context, docID string) error

	// GetDocument retrieves a document by its ID.
	GetDocument(ctx context.Context, docID string) (*core.Document, error)
}

type WatchConfig struct {
	Path             string        // 监控目录
	Recursive        bool          // 是否递归监控子目录
	Patterns         []string      // 文件匹配模式（例如：[]string{"*.pdf", "*.md"}）
	Exclude          []string      // 排除的文件模式
	DebounceInterval time.Duration // 防抖间隔，默认 500ms
}