aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-feed-client
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-01-09 11:19:35 +0100
committerjonmv <venstad@gmail.com>2023-01-09 11:19:35 +0100
commitaea29bd12106f85c9e77ba40b45c2162ab85bbd7 (patch)
treedfd237d6eae4f3a70c27c69b14a5d0ab2c29b0fd /vespa-feed-client
parent6bd735e4b444bbcffe54778881f17e194ac47d79 (diff)
Use gzip by default for payloads > 512b
Diffstat (limited to 'vespa-feed-client')
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/ApacheCluster.java6
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/FeedClientBuilderImpl.java2
2 files changed, 4 insertions, 4 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/ApacheCluster.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/ApacheCluster.java
index b2672b4ebf3..639aebf7c46 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/ApacheCluster.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/ApacheCluster.java
@@ -49,7 +49,7 @@ class ApacheCluster implements Cluster {
new BasicHeader("Vespa-Client-Version", Vespa.VERSION));
private final Header gzipEncodingHeader = new BasicHeader(HttpHeaders.CONTENT_ENCODING, "gzip");
private final RequestConfig requestConfig;
- private final boolean gzip;
+ private final Compression compression;
private int someNumber = 0;
private final ExecutorService dispatchExecutor = Executors.newFixedThreadPool(8, t -> new Thread(t, "request-dispatch-thread"));
@@ -60,7 +60,7 @@ class ApacheCluster implements Cluster {
for (URI endpoint : builder.endpoints)
endpoints.add(new Endpoint(createHttpClient(builder), endpoint));
this.requestConfig = createRequestConfig(builder);
- this.gzip = builder.compression == Compression.gzip;
+ this.compression = builder.compression;
}
@Override
@@ -89,7 +89,7 @@ class ApacheCluster implements Cluster {
wrapped.headers().forEach((name, value) -> request.setHeader(name, value.get()));
if (wrapped.body() != null) {
byte[] body = wrapped.body();
- if (gzip) {
+ if (compression == Compression.gzip || compression == null && body.length > 512) {
request.setHeader(gzipEncodingHeader);
body = gzipped(body);
}
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/FeedClientBuilderImpl.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/FeedClientBuilderImpl.java
index 6886dc3d2b9..b364ba953eb 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/FeedClientBuilderImpl.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/FeedClientBuilderImpl.java
@@ -51,7 +51,7 @@ public class FeedClientBuilderImpl implements FeedClientBuilder {
boolean benchmark = true;
boolean dryrun = false;
boolean speedTest = false;
- Compression compression = none;
+ Compression compression = null;
URI proxy;