- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for requestTimeout (0.46 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options_test.go
MaxMutatingRequestsInFlight: -200, RequestTimeout: time.Duration(2) * time.Minute, MinRequestTimeout: 1800, JSONPatchMaxCopyBytes: 10 * 1024 * 1024, MaxRequestBodyBytes: 10 * 1024 * 1024, }, expectErr: "--max-mutating-requests-inflight can not be negative value", }, { name: "Test when RequestTimeout is negative value", testOptions: &ServerRunOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 10.9K bytes - Viewed (0) -
pkg/wasm/cache_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/wasm/httpfetcher.go
requestMaxRetry int } // NewHTTPFetcher create a new HTTP remote wasm module fetcher. // requestTimeout is a timeout for each HTTP/HTTPS request. // requestMaxRetry is # of maximum retries of HTTP/HTTPS requests. func NewHTTPFetcher(requestTimeout time.Duration, requestMaxRetry int) *HTTPFetcher { if requestTimeout == 0 { requestTimeout = 5 * time.Second } transport := http.DefaultTransport.(*http.Transport).Clone() // nolint: gosec
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 5.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
private static final Logger logger = LogManager.getLogger(ScoreBooster.class); protected BulkRequestBuilder bulkRequestBuilder = null; protected int priority = 1; protected String requestTimeout = "1m"; protected int requestCacheSize = 1000; protected String scriptLang = "painless"; protected String scriptCode = null;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5K bytes - Viewed (0) -
pkg/http/get.go
"bytes" "fmt" "io" "net/http" "time" ) const requestTimeout = time.Second * 1 // Default timeout. func DoHTTPGetWithTimeout(requestURL string, t time.Duration) (*bytes.Buffer, error) { return request("GET", requestURL, t, nil) } func DoHTTPGet(requestURL string) (*bytes.Buffer, error) { return DoHTTPGetWithTimeout(requestURL, requestTimeout) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 03:52:10 UTC 2023 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options.go
return &ServerRunOptions{ MaxRequestsInFlight: defaults.MaxRequestsInFlight, MaxMutatingRequestsInFlight: defaults.MaxMutatingRequestsInFlight, RequestTimeout: defaults.RequestTimeout, LivezGracePeriod: defaults.LivezGracePeriod, MinRequestTimeout: defaults.MinRequestTimeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:53:51 UTC 2023 - 15.4K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactoryTest.java
Collections.emptyMap(), Collections.emptyMap()); int requestTimeout = (Integer) systemSessionFactory .newRepositorySession(request) .getConfigProperties() .get(ConfigurationProperties.REQUEST_TIMEOUT + "." + server.getId()); assertEquals(3000, requestTimeout); } @Test
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Mar 27 14:46:12 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/wasm/options.go
"Always": 2, } // GetOptions is a struct for providing options to Get method of Cache. type GetOptions struct { Checksum string ResourceName string ResourceVersion string RequestTimeout time.Duration PullSecret []byte PullPolicy PullPolicy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 1.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 14:13:36 UTC 2024 - 27.5K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/util.go
package endpoint import ( "crypto/tls" "net" "os" "strconv" "time" "istio.io/istio/pkg/log" ) var epLog = log.RegisterScope("endpoint", "echo serverside") const ( requestTimeout = 15 * time.Second idleTimeout = 5 * time.Second ) func listenOnAddress(ip string, port int) (net.Listener, int, error) { parsedIP := net.ParseIP(ip) ipBind := "tcp" if parsedIP != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K bytes - Viewed (0)