Package sk.iway.iwcm.rag.service

Class SemanticIndexService

java.lang.Object

sk.iway.iwcm.rag.service.SemanticIndexService

@Service
public class SemanticIndexService
extends Object

Core service for semantic indexing of documents. Orchestrates: content extraction -> chunking -> embedding -> vector storage.

Constructor Summary

Constructors

Constructor	Description
SemanticIndexService(DocDetailsContentExtractor contentExtractor, SlidingWindowChunker chunker, EmbeddingService embeddingService, PgVectorStore vectorStore, IndexQueueRepository queueRepository, RagEmbeddingStatService ragEmbeddingStatService, EmbeddingChunkRepository embeddingChunkRepository)

Method Summary

Modifier and Type	Method	Description
void	processQueue()	Process all pending items in the RAG indexing queue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SemanticIndexService

@Autowired
public SemanticIndexService(DocDetailsContentExtractor contentExtractor,
 SlidingWindowChunker chunker,
 EmbeddingService embeddingService,
 PgVectorStore vectorStore,
 IndexQueueRepository queueRepository,
 RagEmbeddingStatService ragEmbeddingStatService,
 EmbeddingChunkRepository embeddingChunkRepository)

Method Details

processQueue

public void processQueue()

Process all pending items in the RAG indexing queue. Items are fetched in batches of 500 and processed sequentially. Uses a cache-based flag to prevent concurrent execution. Failed items remain in the queue and are retried on the next run.