From 8f6b5e6724071635590d28d61cb3becc331c0d33 Mon Sep 17 00:00:00 2001 From: Hai Yan Date: Thu, 19 Sep 2024 16:33:18 -0500 Subject: [PATCH] Add upper bounds for new options Signed-off-by: Hai Yan --- .../plugins/sink/s3/configuration/ClientOptions.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/data-prepper-plugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/configuration/ClientOptions.java b/data-prepper-plugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/configuration/ClientOptions.java index 76947bdee6..a5e83948a5 100644 --- a/data-prepper-plugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/configuration/ClientOptions.java +++ b/data-prepper-plugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/configuration/ClientOptions.java @@ -6,7 +6,9 @@ package org.opensearch.dataprepper.plugins.sink.s3.configuration; import com.fasterxml.jackson.annotation.JsonProperty; +import jakarta.validation.constraints.Max; import jakarta.validation.constraints.Min; +import org.hibernate.validator.constraints.time.DurationMax; import org.hibernate.validator.constraints.time.DurationMin; import java.time.Duration; @@ -17,10 +19,12 @@ public class ClientOptions { @JsonProperty("max_connections") @Min(1) + @Max(5000) private int maxConnections = DEFAULT_MAX_CONNECTIONS; @JsonProperty("acquire_timeout") @DurationMin(seconds = 1) + @DurationMax(seconds = 3600) private Duration acquireTimeout = DEFAULT_ACQUIRE_TIMEOUT; public int getMaxConnections() {