stats - Code Search

docs_src/websockets/tutorial002_py310.py

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.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/url_test.go

	if err != nil {
		b.Fatal(err)
	}

	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
	b.ReportAllocs()
	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
	b.ResetTimer()

	if err := req.ParseForm(); err != nil {
		b.Fatal(err)
	}

	b.RunParallel(func(pb *testing.PB) {
		for pb.Next() {
			req.Form.Get("uploadId")
		}
	})

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

- Last Modified: Tue Nov 16 17:28:29 UTC 2021

- 2K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/authentication/v1alpha1/generated.proto

  // +optional
  optional k8s.io.apimachinery.pkg.apis.meta.v1.ObjectMeta metadata = 1;

  // Status is filled in by the server with the user attributes.
  optional SelfSubjectReviewStatus status = 2;
}

// SelfSubjectReviewStatus is filled by the kube-apiserver and sent back to a user.
message SelfSubjectReviewStatus {

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

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

- 2K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/kubeinject/testdata/mesh-config.yaml

  # https://lyft.github.io/envoy/docs/operations/admin.html
  # for more details
  proxyAdminPort: 15000
  #
  # Zipkin trace collector
  zipkinAddress: ""
  #
  # Statsd metrics collector converts statsd metrics into Prometheus metrics.
  statsdUdpAddress: ""
  #
  # Mutual TLS authentication between sidecars and istio control plane.
  controlPlaneAuthPolicy: NONE
  #

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

- Last Modified: Thu Jun 15 15:02:17 UTC 2023

- 2.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-object-lock.go

func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
	if objInfo.DeleteMarker {
		return false
	}

	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
		return true
	}

	ret := objectlock.GetObjectRetentionMeta(objInfo.UserDefined)
	if ret.Mode.Valid() && (ret.Mode == objectlock.RetCompliance || ret.Mode == objectlock.RetGovernance) {

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

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 13.2K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.4.md

* fix kubectl taint e2e flake: add retries for removing taint ([#33872](https://github.com/kubernetes/kubernetes/pull/33872), [@kevin-wangzefeng](https://github.com/kevin-wangzefeng))
* portfordwardtester: avoid data loss during send+close+exit ([#37103](https://github.com/kubernetes/kubernetes/pull/37103), [@sttts](https://github.com/sttts))

Registered: Fri Nov 01 09:05:11 UTC 2024

- Last Modified: Thu Dec 24 02:28:26 UTC 2020

- 133.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java

        logger.info("logList: {}", logList);
        for (Map<String, Object> elem : logList) {
            deleteMethod("/api/admin/joblog/log/" + elem.get("id")).then().body("response.status", equalTo(0));
        }

        final List<Map<String, Object>> afterList = readJobLog(NAME_PREFIX);
        assertEquals(0, afterList.size()); // check if logs are successfully deleted
    }

    /**

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 9.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/TransPeekNamedPipeResponse.java

    private int head;

    static final int STATUS_DISCONNECTED = 1;
    static final int STATUS_LISTENING = 2;
    static final int STATUS_CONNECTION_OK = 3;
    static final int STATUS_SERVER_END_CLOSED = 4;

    int status, available;

    TransPeekNamedPipeResponse( SmbNamedPipe pipe ) {
        this.pipe = pipe;
    }

    int writeSetupWireFormat( byte[] dst, int dstIndex ) {
        return 0;
    }

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

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 2.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/api/admin/log/ApiAdminLogAction.java

    @Execute
    public JsonResponse<ApiResult> files() {
        final List<Map<String, Object>> list = getLogFileItems();
        return asJson(new ApiResult.ApiLogFilesResponse().files(list).total(list.size()).status(ApiResult.Status.OK).result());
    }

    // GET /api/admin/log/file/{id}
    @Execute
    public StreamResponse get$file(final String id) {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 2.7K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial002_an.py

from typing import Union

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

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>

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

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

- 2.8K bytes

- Viewed (0)

Search Options