Merge pull request #163 from jillesvangurp/add-msearch-to-indexrepo

add msearch to index repo
jillesvangurp · Jan 27, 2025 · 07929f6 · 07929f6
2 parents 7757cc0 + 9c581dd
commit 07929f6
Showing 1 changed file with 31 additions and 0 deletions.
diff --git a/search-client/src/commonMain/kotlin/com/jillesvangurp/ktsearch/repository/IndexRepository.kt b/search-client/src/commonMain/kotlin/com/jillesvangurp/ktsearch/repository/IndexRepository.kt
@@ -929,6 +929,37 @@ class IndexRepository<T : Any>(
         ).parseHits(serializer)
     }
 
+    suspend fun msearch(
+        allowNoIndices: Boolean? = null,
+        cssMinimizeRoundtrips: Boolean? = null,
+        expandWildcards: ExpandWildCards? = null,
+        ignoreThrottled: Boolean? = null,
+        ignoreUnavailable: Boolean? = null,
+        maxConcurrentSearches: Int? = null,
+        maxConcurrentShardRequests: Int? = null,
+        preFilterShardSize: Int? = null,
+        routing: String? = null,
+        searchType: SearchType? = null,
+        typedKeys: Boolean? = null,
+        block: MsearchRequest.() -> Unit,
+        ): MultiSearchResponse {
+        return client.msearch(
+            target = indexReadAlias,
+            allowNoIndices = allowNoIndices,
+            cssMinimizeRoundtrips = cssMinimizeRoundtrips,
+            expandWildcards = expandWildcards,
+            ignoreThrottled = ignoreThrottled,
+            ignoreUnavailable = ignoreUnavailable,
+            maxConcurrentSearches = maxConcurrentSearches,
+            maxConcurrentShardRequests = maxConcurrentShardRequests,
+            preFilterShardSize = preFilterShardSize,
+            routing = routing,
+            searchType = searchType,
+            typedKeys = typedKeys,
+            block = block
+        )
+    }
+
     suspend fun deleteByQuery(block: SearchDSL.() -> Unit): DeleteByQueryResponse {
         return client.deleteByQuery(target = indexWriteAlias, block = block)
     }