summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorLester Solbakken <lesters@oath.com>2022-11-24 12:18:11 +0100
committerLester Solbakken <lesters@oath.com>2022-11-24 12:18:11 +0100
commit7a4ac463a3a82350179d0a004ad3f79420b36a71 (patch)
tree0649a8d13a68dbdb73299ea62f7a3338d176cdf0 /container-search
parentb7c99d78afc5273572b2f03dc33a6572380a0261 (diff)
Add track as option to grid logger entry
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java16
1 files changed, 15 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java b/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
index e02bb8da8c0..8d8afce4f77 100644
--- a/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
+++ b/container-search/src/main/java/com/yahoo/search/logging/LoggerEntry.java
@@ -17,11 +17,13 @@ public class LoggerEntry {
private final Long timestamp;
private final Query query;
private final ByteBuffer blob;
+ private final String track;
private LoggerEntry(Builder builder) {
timestamp = builder.timestamp; // or set automatically if not set
query = builder.query;
blob = builder.blob;
+ track = builder.track;
}
public Long timestamp() {
@@ -49,6 +51,10 @@ public class LoggerEntry {
return blob;
}
+ public String track() {
+ return track;
+ }
+
public String toString() {
return serialize();
}
@@ -61,6 +67,7 @@ public class LoggerEntry {
root.setLong("timestamp", timestamp == null ? 0 : timestamp);
root.setString("query", queryString());
root.setString("blob", Base64.getEncoder().encodeToString(blob.array()));
+ root.setString("track", track());
return Utf8.toString(SlimeUtils.toJsonBytes(slime)); // TODO
} catch (IOException e) {
@@ -74,8 +81,9 @@ public class LoggerEntry {
var timestamp = slime.get().field("timestamp").asLong();
var query = new Query(slime.get().field("query").asString());
var blob = slime.get().field("blob").asString();
+ var track = slime.get().field("track").asString();
- return new LoggerEntry(new Builder().timestamp(timestamp).query(query).blob(blob));
+ return new LoggerEntry(new Builder().timestamp(timestamp).query(query).blob(blob).track(track));
}
public static class Builder {
@@ -85,6 +93,7 @@ public class LoggerEntry {
private Long timestamp;
private Query query;
private ByteBuffer blob;
+ private String track = "";
// For testing
public Builder() { this(entry -> false); }
@@ -116,6 +125,11 @@ public class LoggerEntry {
return this;
}
+ public Builder track(String track) {
+ this.track = track;
+ return this;
+ }
+
public boolean send() {
return logger.send(new LoggerEntry(this));
}