scaler - Code Search

cmd/perf-tests.go

	rand.Read(r.buf)

	clusterInfos, err := globalSiteReplicationSys.GetClusterInfo(ctx)
	if err != nil {
		return madmin.SiteNetPerfNodeResult{Error: err.Error()}
	}

	// Scale the number of connections from 32 -> 4 from small to large clusters.
	connectionsPerPeer := 3 + (29+len(clusterInfos.Sites)-1)/len(clusterInfos.Sites)

	errStr := ""
	var wg sync.WaitGroup

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 11.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/cache/CacheBuilder.java

   */
  @J2ObjCIncompatible
  @GwtIncompatible // Duration
  @SuppressWarnings("GoodTime") // Duration decomposition
  @IgnoreJRERequirement // No more dangerous than wherever the caller got the Duration from
  @CanIgnoreReturnValue
  public CacheBuilder<K, V> expireAfterWrite(Duration duration) {
    return expireAfterWrite(toNanosSaturated(duration), NANOSECONDS);
  }

  /**

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Aug 07 16:05:33 UTC 2025

- 51.7K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/data/external_links.yml

s-request title: How to profile a FastAPI asynchronous request - author: Stephen Siegert - Neon link: https://neon.tech/blog/deploy-a-serverless-fastapi-app-with-neon-postgres-and-aws-app-runner-at-any-scale title: Deploy a Serverless FastAPI App with Neon Postgres and AWS App Runner at any scale - author: Kurtis Pykes - NVIDIA link: https://developer.nvidia.com/blog/building-a-machine-learning-microservice-with-fastapi/ title: Building a Machine Learning Microservice with FastAPI - author: Ravgeet...

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Sun Aug 31 10:49:48 UTC 2025

- 23K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/collect/testing/AbstractMapTester.java

    }

    throw new IllegalArgumentException(
        Platform.format("key %s not found in entries %s", newEntry.getKey(), expected));
  }

  /**
   * Wrapper for {@link Map#get(Object)} that forces the caller to pass in a key of the same type as
   * the map. Besides being slightly shorter than code that uses {@link #getMap()}, it also ensures
   * that callers don't pass an {@link Entry} by mistake.
   */

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Sat Jan 18 02:54:30 UTC 2025

- 7.8K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

 * highest valued code point that requires escaping. For example a replacement map containing the
 * single character '{@code \}{@code u1000}' will require approximately 16K of memory. If you need
 * to create multiple escaper instances that have the same character replacement mapping consider
 * using {@link ArrayBasedEscaperMap}.
 *
 * @author David Beaumont
 * @since 15.0
 */
@GwtCompatible

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Feb 13 15:45:16 UTC 2025

- 8.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/eventbus/SubscriberRegistry.java

         * (thanks to the checkArgument calls in getAnnotatedMethodsNotCached). If it happens, we'd
         * prefer to propagate an IllegalArgumentException to the caller. However, we don't want to
         * simply rethrow an exception (e.getCause()) that may in rare cases have come from another
         * thread. To accomplish both goals, we wrap that IllegalArgumentException in a new

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Tue Jul 08 18:32:10 UTC 2025

- 10.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

  val b0 = this[index].code
  val b1 = this[index + 1].code
  return (b0 shl 7) + b1
}

/**
 * An extremely generic binary search that doesn't know what data it's searching over. The caller
 * provides indexes and a comparison function, and this calls that function iteratively.
 *
 * @return the index of the match. If no match is found this is `(-1 - insertionPoint)`, where the

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Fri Dec 27 13:39:56 UTC 2024

- 9K bytes

- Viewed (0)

github.com/minio/minio

cmd/signature-v4-utils.go

// client did not calculate sha256 of the payload and there is a trailer.
const unsignedPayloadTrailer = "STREAMING-UNSIGNED-PAYLOAD-TRAILER"

// skipContentSha256Cksum returns true if caller needs to skip
// payload checksum, false if not.
func skipContentSha256Cksum(r *http.Request) bool {
	var (
		v  []string
		ok bool
	)

	if isRequestPresignedSignatureV4(r) {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Mon Nov 25 17:10:22 UTC 2024

- 9.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/advance.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml" href="${fe:url('/osdd')}"

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jan 18 12:09:07 UTC 2025

- 14.1K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

    FutureAsCancellable(Future<?> delegate) {
      this.delegate = delegate;
    }

    @Override
    @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
    public void cancel(boolean mayInterruptIfRunning) {
      delegate.cancel(mayInterruptIfRunning);
    }

    @Override
    public boolean isCancelled() {
      return delegate.isCancelled();
    }

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Sat Aug 09 01:14:59 UTC 2025

- 27.8K bytes

- Viewed (0)

Search Options