Mirror/MarginaliaSearch
1
0
Fork 0
mirror of https://github.com/MarginaliaSearch/MarginaliaSearch.git synced 2025-02-23 21:18:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(qs) Better metrics for QS

Browse Source
This commit is contained in:
Viktor Lofgren 2024-01-04 13:27:14 +01:00
parent 343ea9c6d8
commit 4078708aea
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
code/services-core/query-service/src/main/java/nu/marginalia/query/QueryGRPCService.java
View File

@ -23,6 +23,7 @@ public class QueryGRPCService extends QueryApiGrpc.QueryApiImplBase {
private static final Histogram wmsa_qs_query_time_grpc = Histogram.build() private static final Histogram wmsa_qs_query_time_grpc = Histogram.build()
.name("wmsa_qs_query_time_grpc") .name("wmsa_qs_query_time_grpc")
.labelNames("timeout", "count")
.linearBuckets(0.05, 0.05, 15) .linearBuckets(0.05, 0.05, 15)
.help("QS-side query time (GRPC endpoint)") .help("QS-side query time (GRPC endpoint)")
.register(); .register();
@ -69,7 +70,10 @@ public class QueryGRPCService extends QueryApiGrpc.QueryApiImplBase {
io.grpc.stub.StreamObserver<nu.marginalia.index.api.RpcQsResponse> responseObserver) io.grpc.stub.StreamObserver<nu.marginalia.index.api.RpcQsResponse> responseObserver)
{ {
try { try {
wmsa_qs_query_time_grpc.time(() -> { wmsa_qs_query_time_grpc
.labels(Integer.toString(request.getQueryLimits().getTimeoutMs()),
Integer.toString(request.getQueryLimits().getResultsTotal()))
.time(() -> {
var params = QueryProtobufCodec.convertRequest(request); var params = QueryProtobufCodec.convertRequest(request);
var query = queryFactory.createQuery(params); var query = queryFactory.createQuery(params);