initials - Code Search

internal/grid/connection.go

}

// State is a connection state.
type State uint32

// MANUAL go:generate stringer -type=State -output=state_string.go -trimprefix=State $GOFILE

const (
	// StateUnconnected is the initial state of a connection.
	// When the first message is sent it will attempt to connect.
	StateUnconnected = iota

	// StateConnecting is the state from StateUnconnected while the connection is attempted to be established.

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jul 29 18:10:04 UTC 2024

- 46.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/collect/CompactHashSet.java

    CompactHashSet<E> set = createWithExpectedSize(elements.length);
    Collections.addAll(set, elements);
    return set;
  }

  /**
   * Creates a {@code CompactHashSet} instance, with a high enough "initial capacity" that it
   * <i>should</i> hold {@code expectedSize} elements without growth.
   *
   * @param expectedSize the number of elements you expect to add to the returned set

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 18 20:24:49 UTC 2024

- 24K bytes

- Viewed (0)

github.com/tiangolo/fastapi

fastapi/openapi/docs.py

    html = f"""
    <!DOCTYPE html>
    <html>
    <head>
    <title>{title}</title>
    <!-- needed for adaptive design -->
    <meta charset="utf-8"/>
    <meta name="viewport" content="width=device-width, initial-scale=1">
    """
    if with_google_fonts:
        html += """
    <link href="https://fonts.googleapis.com/css?family=Montserrat:300,400,700|Roboto:300,400,700" rel="stylesheet">
    """
    html += f"""

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Thu May 23 22:59:02 UTC 2024

- 10.1K bytes

- Viewed (0)

github.com/square/okhttp

docs/features/interceptors.md

    .header("User-Agent", "OkHttp Example")
    .build();

Response response = client.newCall(request).execute();
response.body().close();
```

When we run this code, the interceptor runs twice. Once for the initial request to `http://www.publicobject.com/helloworld.txt`, and another for the redirect to `https://publicobject.com/helloworld.txt`.

```

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sun Feb 06 02:19:09 UTC 2022

- 8.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/util/MD4.java

    /**
     * Resets this object disregarding any temporary data present at the
     * time of the invocation of this call.
     */
    public void engineReset () {
        // initial values of MD4 i.e. A, B, C, D
        // as per rfc-1320; they are low-order byte first
        context[0] = 0x67452301;
        context[1] = 0xEFCDAB89;
        context[2] = 0x98BADCFE;
        context[3] = 0x10325476;

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 20:39:42 UTC 2019

- 9.3K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/net.go

	var consErr []error

	podsByUID := slices.GroupUnique(ambientPods, (*corev1.Pod).GetUID)
	if err := s.buildZtunnelSnapshot(podsByUID); err != nil {
		log.Warnf("failed to construct initial ztunnel snapshot: %v", err)
		consErr = append(consErr, err)
	}

	return errors.Join(consErr...)
}

func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error {

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Oct 21 16:48:55 UTC 2024

- 9.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractService.java

  private volatile StateSnapshot snapshot = new StateSnapshot(NEW);

  /** Constructor for use by subclasses. */
  protected AbstractService() {}

  /**
   * This method is called by {@link #startAsync} to initiate service startup. The invocation of
   * this method should cause a call to {@link #notifyStarted()}, either during this method's run,
   * or after it has returned. If startup fails, the invocation should cause a call to {@link

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri May 12 18:32:03 UTC 2023

- 20.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

    assertThat(ping.ack).isTrue()
  }

  @Test fun peerHttp2ServerLowersInitialWindowSize() {
    val initial = Settings()
    initial[Settings.INITIAL_WINDOW_SIZE] = 1684
    val shouldntImpactConnection = Settings()
    shouldntImpactConnection[Settings.INITIAL_WINDOW_SIZE] = 3368
    peer.sendFrame().settings(initial)
    peer.acceptFrame() // ACK
    peer.sendFrame().settings(shouldntImpactConnection)
    peer.acceptFrame() // ACK 2

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Apr 20 17:03:43 UTC 2024

- 75.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/pt/docs/project-generation.md

# Geração de Projetos - Modelo

Você pode usar um gerador de projetos para começar, por já incluir configurações iniciais, segurança, banco de dados e os primeiros _endpoints_ API já feitos para você.

Um gerador de projetos sempre terá uma pré-configuração que você pode atualizar e adaptar para suas próprias necessidades, mas pode ser um bom ponto de partida para seu projeto.

## Full Stack FastAPI PostgreSQL

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Mon Jul 29 23:35:07 UTC 2024

- 6.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/object-api-multipart_test.go

	err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
	if err != nil {
		// Failed to create newbucket, abort.
		t.Fatalf("%s : %s", instanceType, err.Error())
	}
	// Initiate Multipart Upload on the above created bucket.
	res, err := obj.NewMultipartUpload(context.Background(), bucket, object, opts)
	if err != nil {
		// Failed to create NewMultipartUpload, abort.

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Sep 06 09:42:21 UTC 2024

- 88.8K bytes

- Viewed (0)

Search Options