org.llm4s.vectorstore.AsyncPgVectorStore
See theAsyncPgVectorStore companion object
final class AsyncPgVectorStore(syncStore: VectorStore) extends AsyncVectorStore
Asynchronous wrapper for PgVectorStore.
This implementation shifts all synchronous, thread-blocking JDBC network I/O (from PgVectorStore) onto the user-provided ExecutionContext. In a production environment, this ExecutionContext should be backed by a bounded blocking thread pool (e.g., ExecutionContext.fromExecutor(Executors.newFixedThreadPool(...))), preventing standard compute thread starvation during high-concurrency RAG operations.
Attributes
- Companion
- object
- Graph
-
- Supertypes
Members list
Value members
Concrete methods
Attributes
- Definition Classes
Attributes
- Definition Classes
override def count(filter: Option[MetadataFilter])(implicit ec: ExecutionContext): AsyncResult[Long]
Attributes
- Definition Classes
Attributes
- Definition Classes
Attributes
- Definition Classes
override def deleteByFilter(filter: MetadataFilter)(implicit ec: ExecutionContext): AsyncResult[Long]
Attributes
- Definition Classes
Attributes
- Definition Classes
Attributes
- Definition Classes
override def getBatch(ids: Seq[String])(implicit ec: ExecutionContext): AsyncResult[Seq[VectorRecord]]
Attributes
- Definition Classes
override def list(limit: Int, offset: Int, filter: Option[MetadataFilter])(implicit ec: ExecutionContext): AsyncResult[Seq[VectorRecord]]
Attributes
- Definition Classes
override def search(queryVector: Array[Float], topK: Int, filter: Option[MetadataFilter])(implicit ec: ExecutionContext): AsyncResult[Seq[ScoredRecord]]
Attributes
- Definition Classes
Attributes
- Definition Classes
Attributes
- Definition Classes
override def upsertBatch(records: Seq[VectorRecord])(implicit ec: ExecutionContext): AsyncResult[Unit]
Attributes
- Definition Classes
In this article