caClient - Code Search

src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequestBuilder.java

import org.codelibs.fess.suggest.request.RequestBuilder;
import org.opensearch.client.Client;

public class SuggestRequestBuilder extends RequestBuilder<SuggestRequest, SuggestResponse> {
    public SuggestRequestBuilder(final Client client, final ReadingConverter readingConverter, final Normalizer normalizer) {
        super(client, new SuggestRequest());
        request.setReadingConverter(readingConverter);

Registered: Fri Nov 08 09:08:12 UTC 2024

- Last Modified: Thu Feb 22 01:36:54 UTC 2024

- 2.8K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.13.md

  - [Downloads for v1.13.12](#downloads-for-v11312)
    - [Client Binaries](#client-binaries)
    - [Server Binaries](#server-binaries)
    - [Node Binaries](#node-binaries)
  - [Changelog since v1.13.11](#changelog-since-v11311)
    - [Other notable changes](#other-notable-changes)
- [v1.13.11](#v11311)
  - [Downloads for v1.13.11](#downloads-for-v11311)
    - [Client Binaries](#client-binaries-1)
    - [Server Binaries](#server-binaries-1)

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

- Last Modified: Thu May 05 13:44:43 UTC 2022

- 273.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial002_an.py


def test_main():
    client = TestClient(app)
    response = client.get("/")
    assert response.status_code == 200, response.text
    assert b"<!DOCTYPE html>" in response.content


def test_websocket_with_cookie():
    client = TestClient(app, cookies={"session": "fakesession"})
    with pytest.raises(WebSocketDisconnect):
        with client.websocket_connect("/items/foo/ws") as websocket:

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

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

- 3.6K bytes

- Viewed (0)

github.com/minio/minio

internal/grid/connection.go

		if _, loaded := c.outgoing.LoadOrStore(client.MuxID, client); client.MuxID != 0 && !loaded {
			if debugReqs {
				_, found := c.outgoing.Load(client.MuxID)
				fmt.Println(client.MuxID, c.String(), "Connection.newMuxClient: RELOADED MUX. loaded:", loaded, "found:", found)
			}
			return client, nil
		}
		client.MuxID = atomic.AddUint64(&c.NextID, 1)
	}
}

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/tiangolo/fastapi

tests/test_tutorial/test_additional_responses/test_tutorial004.py

client = TestClient(app)


def test_path_operation():
    response = client.get("/items/foo")
    assert response.status_code == 200, response.text
    assert response.json() == {"id": "foo", "value": "there goes my hero"}


def test_path_operation_img():
    shutil.copy("./docs/en/docs/img/favicon.png", "./image.png")
    response = client.get("/items/foo?img=1")

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

- Last Modified: Fri Jul 07 17:12:13 UTC 2023

- 4.8K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial003.py

from fastapi.testclient import TestClient

from docs_src.websockets.tutorial003 import app, html

client = TestClient(app)


def test_get():
    response = client.get("/")
    assert response.text == html


def test_websocket_handle_disconnection():
    with client.websocket_connect("/ws/1234") as connection, client.websocket_connect(
        "/ws/5678"
    ) as connection_two:
        connection.send_text("Hello from 1234")

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

- Last Modified: Thu Jul 29 09:26:07 UTC 2021

- 872 bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

    client.send(message2)
    serverListener.assertTextMessage(message2)

    // Empty server to client message.
    val message3 = ""
    server.send(message3)
    clientListener.assertTextMessage(message3)

    // Empty client to server message.
    val message4 = ""
    client.send(message4)
    serverListener.assertTextMessage(message4)

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

- Last Modified: Sun Mar 31 17:16:15 UTC 2024

- 35.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_validate_response_dataclass.py

        {"name": "bar", "price": "bar"},
        {"name": "baz", "price": "baz"},
    ]


client = TestClient(app)


def test_invalid():
    with pytest.raises(ResponseValidationError):
        client.get("/items/invalid")


def test_double_invalid():
    with pytest.raises(ResponseValidationError):
        client.get("/items/innerinvalid")


def test_invalid_list():

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

- Last Modified: Fri Jul 07 17:12:13 UTC 2023

- 1.2K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/nodeagent/informers_test.go

			PodIP:  "",
		},
	}
	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}}

	client := kube.NewFakeClient(ns, pod)

	fs := &fakeServer{}

	server := getFakeDP(fs, client.Kube())

	handlers := setupHandlers(ctx, client, server, "istio-system")
	client.RunAndWait(ctx.Done())
	go handlers.Start()

	// label the namespace

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

- Last Modified: Wed Oct 09 16:05:45 UTC 2024

- 22.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_router_redirect_slashes.py

    @router.get("/hello/")
    def hello_page() -> str:
        return "Hello, World!"

    app.include_router(router)

    client = TestClient(app)

    response = client.get("/hello/", follow_redirects=False)
    assert response.status_code == 200

    response = client.get("/hello", follow_redirects=False)
    assert response.status_code == 307


def test_redirect_slashes_disabled():

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

- Last Modified: Thu Jun 22 10:37:50 UTC 2023

- 974 bytes

- Viewed (0)

Search Options