Method CheckAndReindexChangedFiles

pkg/rag/manager.go:472–493

CheckAndReindexChangedFiles checks for file changes and re-indexes if needed

(ctx context.Context)

// CheckAndReindexChangedFiles checks for file changes and re-indexes if needed
func (m *Manager) CheckAndReindexChangedFiles(ctx context.Context) (err error) {
	tracer := otel.Tracer("github.com/docker/docker-agent/pkg/rag")
	ctx, span := tracer.Start(ctx, "rag.reindex",
		trace.WithSpanKind(trace.SpanKindInternal),
		trace.WithAttributes(attribute.String(genai.AttrDataSourceID, m.name)),
	)
	defer func() {
		if err != nil {
			span.RecordError(err)
			span.SetStatus(codes.Error, err.Error())
		}
		span.End()
	}()

	for strategyName, strategyImpl := range m.strategies {
		strategyCfg := m.strategyConfigs[strategyName]
		if err := strategyImpl.CheckAndReindexChangedFiles(ctx, strategyCfg.Docs, strategyCfg.Chunking); err != nil {
			return fmt.Errorf("strategy %s failed: %w", strategyName, err)
		}
	}
	return nil
}

// StartFileWatcher starts monitoring files and directories for changes
func (m *Manager) StartFileWatcher(ctx context.Context) (err error) {