stats - Code Search

docs_src/websockets/tutorial002_an_py39.py

from typing import Annotated, Union

from fastapi import (
    Cookie,
    Depends,
    FastAPI,
    Query,
    WebSocket,
    WebSocketException,
    status,
)
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">

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

- Last Modified: Sat Mar 18 12:29:59 UTC 2023

- 2.8K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/admissionregistration/v1/generated.proto

  // The webhook cares about an operation if it matches _any_ Rule.
  // However, in order to prevent ValidatingAdmissionWebhooks and MutatingAdmissionWebhooks
  // from putting the cluster in a state which cannot be recovered from without completely
  // disabling the plugin, ValidatingAdmissionWebhooks and MutatingAdmissionWebhooks are never called

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

- Last Modified: Mon Mar 11 18:43:24 UTC 2024

- 24.4K bytes

- Viewed (0)

github.com/google/guava

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

     * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
     * block, and reference field assignment is atomic, this may save reacquiring the lock when
     * another thread or the worker task has cleared the count and set the state.
     *
     * <p>When {@link #executor} is a directExecutor(), the value written to

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/google/guava

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

     * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
     * block, and reference field assignment is atomic, this may save reacquiring the lock when
     * another thread or the worker task has cleared the count and set the state.
     *
     * <p>When {@link #executor} is a directExecutor(), the value written to

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/kms-handlers.go

	if GlobalKMS == nil {
		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrKMSNotConfigured), r.URL)
		return
	}

	stat, err := GlobalKMS.Status(ctx)
	if err != nil {
		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
		return
	}
	resp, err := json.Marshal(stat)
	if err != nil {
		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
		return

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

- Last Modified: Sun Aug 18 06:43:03 UTC 2024

- 10.1K bytes

- Viewed (0)

github.com/google/guava

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

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.collect.ImmutableMultimap;
import com.google.common.util.concurrent.Service.State;

/**
 * Superinterface of {@link ServiceManager} to introduce a bridge method for {@code
 * servicesByState()}, to ensure binary compatibility with older Guava versions that specified

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

- Last Modified: Tue Apr 04 09:45:04 UTC 2023

- 1.2K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/util/configdump/listener.go

	}

	dal := make([]*admin.ListenersConfigDump_DynamicListener, 0)
	for _, l := range listenerDump.DynamicListeners {
		// If a listener was reloaded, it would contain both the active and draining state
		// delete the draining state for proper comparison
		l.DrainingState = nil
		if l.ActiveState != nil {
			dal = append(dal, l)
		}
	}

	// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.

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

- Last Modified: Thu Nov 03 08:41:32 UTC 2022

- 2.5K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_security/test_tutorial005_py310.py

    response = client.get(
        "/status/", headers={"Authorization": f"Bearer {access_token}"}
    )
    assert response.status_code == 200, response.text
    assert response.json() == {"status": "ok"}


@needs_py310
def test_read_system_status_no_token(client: TestClient):
    response = client.get("/status/")
    assert response.status_code == 401, response.text

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

- Last Modified: Wed Mar 13 19:07:10 UTC 2024

- 16.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_security/test_tutorial005_py39.py

    response = client.get(
        "/status/", headers={"Authorization": f"Bearer {access_token}"}
    )
    assert response.status_code == 200, response.text
    assert response.json() == {"status": "ok"}


@needs_py39
def test_read_system_status_no_token(client: TestClient):
    response = client.get("/status/")
    assert response.status_code == 401, response.text

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

- Last Modified: Wed Mar 13 19:07:10 UTC 2024

- 16.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/CacheTest.kt

        .body("A")
        .status("HTTP/1.1 200 A-OK")
        .build(),
    )
    server.enqueue(
      MockResponse.Builder()
        .code(HttpURLConnection.HTTP_NOT_MODIFIED)
        .build(),
    )

    // scenario 2: condition fails
    server.enqueue(
      response.newBuilder()
        .body("B")
        .status("HTTP/1.1 200 B-OK")
        .build(),
    )

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

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 108.6K bytes

- Viewed (0)

Search Options