Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 341 - 350 of 859 for durable (0.13 seconds)

  1. guava/src/com/google/common/collect/ArrayListMultimap.java

      /**
       * Reduces the memory used by this {@code ArrayListMultimap}, if feasible.
       *
       * @deprecated For a {@link ListMultimap} that automatically trims to size, use {@link
       *     ImmutableListMultimap}. If you need a mutable collection, remove the {@code trimToSize}
       *     call, or switch to a {@code HashMap<K, ArrayList<V>>}.
       */
      @Deprecated
      public void trimToSize() {
        for (Collection<V> collection : backingMap().values()) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 05 23:15:58 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  2. internal/handlers/forwarder.go

    		outReq.Host = target.Host
    	}
    
    	// TODO: only supports HTTP 1.1 for now.
    	outReq.Proto = "HTTP/1.1"
    	outReq.ProtoMajor = 1
    	outReq.ProtoMinor = 1
    
    	f.rewriter.Rewrite(outReq)
    
    	// Disable closeNotify when method GET for http pipelining
    	if outReq.Method == http.MethodGet {
    		quietReq := outReq.WithContext(context.Background())
    		*outReq = *quietReq
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  3. internal/http/server.go

    	wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// If server is in shutdown.
    		if atomic.LoadUint32(&srv.inShutdown) != 0 {
    			// To indicate disable keep-alive, server is shutting down.
    			w.Header().Set("Connection", "close")
    
    			// Add 1 minute retry header, incase-client wants to honor it
    			w.Header().Set(RetryAfter, "60")
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  4. cmd/callhome.go

    				auditOptions := AuditLogOptions{Event: "callhome:diagnostics"}
    				// Received all data. Send to SUBNET and return
    				err := sendHealthInfo(ctx, healthInfo)
    				if err != nil {
    					internalLogIf(ctx, fmt.Errorf("Unable to perform callhome: %w", err))
    					auditOptions.Error = err.Error()
    				}
    				auditLogInternal(ctx, auditOptions)
    				return
    			}
    			healthInfo = hi
    		case <-healthCtx.Done():
    			return
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. tests/test_tutorial/test_body_multiple_params/test_tutorial002.py

        assert response.json() == {
            "detail": [
                {
                    "type": "int_parsing",
                    "loc": ["path", "item_id"],
                    "msg": "Input should be a valid integer, unable to parse string as an integer",
                    "input": "foo",
                }
            ]
        }
    
    
    def test_openapi_schema(client: TestClient):
        response = client.get("/openapi.json")
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 11.7K bytes
    - Click Count (0)
  6. docs/metrics/prometheus/alerts.md

            "severity": "critical"
          },
          "annotations": {
            "description": "MinIO instance 127.0.0.1:9000 of job minio-job has tolerance <=0 for more than 5 minutes.",
            "summary": "Instance 127.0.0.1:9000 unable to tolerate node failures"
          },
          "startsAt": "2023-11-18T06:20:09.456Z",
          "endsAt": "0001-01-01T00:00:00Z",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 23 15:13:23 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  7. docs/en/docs/how-to/separate-openapi-schemas.md

    In that case, you can disable this feature in **FastAPI**, with the parameter `separate_input_output_schemas=False`.
    
    /// info
    
    Support for `separate_input_output_schemas` was added in FastAPI `0.102.0`. 🤓
    
    ///
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Dec 20 15:55:38 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  8. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchJavaBasePlugin.java

                    return;
                }
                configuration.resolutionStrategy(ResolutionStrategy::failOnVersionConflict);
            });
    
            // disable transitive dependency management
            SourceSetContainer sourceSets = project.getExtensions().getByType(SourceSetContainer.class);
            sourceSets.all(sourceSet -> disableTransitiveDependenciesForSourceSet(project, sourceSet));
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Sep 27 16:04:42 GMT 2021
    - 8K bytes
    - Click Count (0)
  9. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/AndroidPlatform.kt

                trustManager,
                cert,
              ) as TrustAnchor
            trustAnchor.trustedCert
          } catch (e: IllegalAccessException) {
            throw AssertionError("unable to get issues and signature", e)
          } catch (_: InvocationTargetException) {
            null
          }
      }
    
      companion object {
        val Tag = "OkHttp"
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Oct 10 05:19:46 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

       * certificate pin checks.
       */
      fun sameHostAndPort(url: HttpUrl): Boolean
    
      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
       * These steps are split so callers can call [connectTcp] on a background thread if attempting
       * multiple plans concurrently.
       */
      interface Plan {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:58:02 GMT 2025
    - 4.2K bytes
    - Click Count (0)
Back to Top