cliente - Code Search

internal/event/target/elasticsearch.go

func (target *ElasticsearchTarget) Close() error {
	close(target.quitCh)
	if target.client != nil {
		// Stops the background processes that the client is running.
		target.client.stop()
	}
	return nil
}

func (target *ElasticsearchTarget) checkAndInitClient(ctx context.Context) error {
	if target.client != nil {
		return nil
	}

	clientV7, err := newClientV7(target.args)
	if err != nil {
		return err
	}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 15K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

  private var client =
    clientTestRule
      .newClientBuilder()
      .eventListenerFactory(clientTestRule.wrap(eventRecorder))
      .build()

  fun executeAndCheckUpgrade(request: Request) {
    val socketHandler =
      MockSocketHandler()
        .apply {
          receiveRequest("client says hello\n")
          sendResponse("server says hello\n")

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Tue Nov 04 19:13:52 GMT 2025

- 9.6K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_behind_a_proxy/test_tutorial001.py

from docs_src.behind_a_proxy.tutorial001_py39 import app

client = TestClient(app, root_path="/api/v1")


def test_main():
    response = client.get("/app")
    assert response.status_code == 200
    assert response.json() == {"message": "Hello World", "root_path": "/api/v1"}


def test_openapi():
    response = client.get("/openapi.json")
    assert response.status_code == 200
    assert response.json() == {

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 1K bytes

- Click Count (0)

github.com/square/okhttp

samples/crawler/src/main/java/okhttp3/sample/Crawler.java

  private final OkHttpClient client;
  private final Set<HttpUrl> fetchedUrls = Collections.synchronizedSet(new LinkedHashSet<>());
  private final BlockingQueue<HttpUrl> queue;
  private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>();
  private final int hostLimit;

  public Crawler(OkHttpClient client, int queueLimit, int hostLimit) {
    this.client = client;

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Jul 23 00:58:06 GMT 2025

- 5K bytes

- Click Count (0)

github.com/golang/go

doc/godebug.md

Go 1.22 changed the default minimum TLS version supported by both servers
and clients to TLS 1.2. The default can be reverted to TLS 1.0 using the
[`tls10server` setting](/pkg/crypto/tls/#Config).
This setting will be removed in Go 1.27.

Go 1.22 changed the default TLS cipher suites used by clients and servers when
not explicitly configured, removing the cipher suites which used RSA based key

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Wed Dec 03 00:18:09 GMT 2025

- 24.7K bytes

- Click Count (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/PostMultipart.java

public final class PostMultipart {
  /**
   * The imgur client ID for OkHttp recipes. If you're using imgur for anything other than running
   * these examples, please request your own client ID! https://api.imgur.com/oauth2
   */
  private static final String IMGUR_CLIENT_ID = "9199fdef135c122";
  private static final MediaType MEDIA_TYPE_PNG = MediaType.get("image/png");

  private final OkHttpClient client = new OkHttpClient();

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Mon Jun 24 12:59:42 GMT 2019

- 2.2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_dependency_security_overrides.py


client = TestClient(app)


def test_normal():
    response = client.get("/user")
    assert response.json() == {
        "user": "john",
        "scopes": ["foo", "bar"],
        "data": [1, 2, 3],
    }


def test_override_data():
    app.dependency_overrides[get_data] = get_data_override
    response = client.get("/user")
    assert response.json() == {

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 21:25:59 GMT 2025

- 1.4K bytes

- Click Count (1)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial001.py

from docs_src.websockets.tutorial001_py39 import app

client = TestClient(app)


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


def test_websocket():
    with pytest.raises(WebSocketDisconnect):
        with client.websocket_connect("/ws") as websocket:
            message = "Message one"

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 827 bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_graphql/test_tutorial001.py


@pytest.fixture(name="client")
def get_client() -> TestClient:
    return TestClient(app)


def test_query(client: TestClient):
    response = client.post("/graphql", json={"query": "{ user { name, age } }"})
    assert response.status_code == 200
    assert response.json() == {"data": {"user": {"name": "Patrick", "age": 100}}}


def test_openapi(client: TestClient):
    response = client.get("/openapi.json")

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Fri Dec 26 10:43:02 GMT 2025

- 2.2K bytes

- Click Count (0)

github.com/square/okhttp

container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt

  val mockServer: MockServerContainer =
    MockServerContainer(MOCKSERVER_IMAGE)
      .withNetworkAliases("mockserver")

  @Test
  fun testOkHttpDirect() {
    testRequest {
      val client = OkHttpClient()

      val response =
        client
          .newCall(
            Request((mockServer.endpoint + "/person?name=peter").toHttpUrl()),
          ).execute()

      assertThat(response.body.string()).contains("Peter the person")

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 6.2K bytes

- Click Count (1)

Search Options