Merge pull request #201 from spq/query_elapsed_time

Display seconds a query took to run
spq · Nov 22, 2024 · 681d81f · 681d81f
2 parents affdad0 + d48bded
commit 681d81f
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 0 deletions.
diff --git a/cmd/pkappa2/main.go b/cmd/pkappa2/main.go
@@ -534,6 +534,7 @@ func main() {
 				Stream *index.Stream
 				Tags   []string
 			}
+			Elapsed     int64
 			Offset      uint
 			MoreResults bool
 		}{
@@ -543,6 +544,7 @@ func main() {
 				Tags   []string
 			}{},
 		}
+		start := time.Now()
 		v := mgr.GetView()
 		defer v.Release()
 		hasMore, offset, err := v.SearchStreams(r.Context(), qq, func(c manager.StreamContext) error {
@@ -563,6 +565,7 @@ func main() {
 			http.Error(w, fmt.Sprintf("SearchStreams failed: %v", err), http.StatusInternalServerError)
 			return
 		}
+		response.Elapsed = time.Since(start).Microseconds()
 		response.MoreResults = hasMore
 		response.Offset = offset
 		w.Header().Set("Content-Type", "application/json")

diff --git a/web/src/apiClient.guard.ts b/web/src/apiClient.guard.ts
@@ -54,6 +54,7 @@ export function isSearchResult(obj: unknown): obj is SearchResult {
                 typeof e === "string"
             )
         ) &&
+        typeof typedObj["Elapsed"] === "number" &&
         typeof typedObj["Offset"] === "number" &&
         typeof typedObj["MoreResults"] === "boolean"
     )

diff --git a/web/src/apiClient.ts b/web/src/apiClient.ts
@@ -46,6 +46,7 @@ export type Error = {
 export type SearchResult = {
   Debug: string[];
   Results: Result[];
+  Elapsed: number;
   Offset: number;
   MoreResults: boolean;
 };

diff --git a/web/src/components/Results.vue b/web/src/components/Results.vue
@@ -93,6 +93,12 @@
         >Results might be outdated.</v-alert
       >
       <v-spacer />
+      <div v-if="streams.result">
+        <span class="text-caption">
+          Query took {{ (streams.result.Elapsed / 1_000_000).toFixed(6) }}s
+        </span>
+      </div>
+      <v-spacer />
       <div
         v-if="
           !streams.running &&