Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 61 for RestClient (0.46 seconds)

  1. cmd/storage-rest_test.go

    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIListDir(t, restClient)
    }
    
    func TestStorageRESTClientReadAll(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIReadAll(t, restClient)
    }
    
    func TestStorageRESTClientReadFile(t *testing.T) {
    	restClient := newStorageRESTHTTPServerClient(t)
    
    	testStorageAPIReadFile(t, restClient)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  2. cmd/storage-rest-client.go

    		values = make(url.Values)
    	}
    	values.Set(storageRESTDiskID, *client.diskID.Load())
    	respBody, err := client.restClient.CallWithHTTPMethod(ctx, http.MethodGet, rpcMethod, values, body, length)
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    	return respBody, nil
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is disconnected
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  3. cmd/peer-rest-client.go

    		defer cancel()
    		respBody, err := healthClient.Call(ctx, peerRESTMethodHealth, nil, nil, -1)
    		xhttp.DrainBody(respBody)
    		return !isNetworkError(err)
    	}
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &peerRESTClient{
    		host: peer, restClient: restClient, gridHost: gridHost,
    		gridConn: func() *grid.Connection {
    			// Lazy initialization of grid connection.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  4. cmd/notification.go

    	for idx, client := range sys.peerClients {
    		if client == nil {
    			continue
    		}
    		wg.Add(1)
    		go func(idx int, client *peerRESTClient) {
    			defer wg.Done()
    			nodesOnlineIndex[idx] = client.restClient.HealthCheckFn()
    		}(idx, client)
    	}
    	wg.Wait()
    
    	for _, online := range nodesOnlineIndex {
    		if online {
    			nodesOnline++
    		} else {
    			nodesOffline++
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  5. tests/benchmarks/test_general_performance.py

    ):
        return ItemOut(name="foo", value=123, dep=dep)
    
    
    @pytest.fixture(scope="module")
    def client() -> Iterator[TestClient]:
        with TestClient(app) as client:
            yield client
    
    
    def _bench_get(benchmark, client: TestClient, path: str) -> tuple[int, bytes]:
        warmup = client.get(path)
        assert warmup.status_code == 200
    
        def do_request() -> tuple[int, bytes]:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Dec 26 20:40:26 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. tests/test_tutorial/test_body_multiple_params/test_tutorial002.py

    import pytest
    from fastapi.testclient import TestClient
    from inline_snapshot import snapshot
    
    from ...utils import needs_py310
    
    
    @pytest.fixture(
        name="client",
        params=[
            pytest.param("tutorial002_py310", marks=needs_py310),
        ],
    )
    def get_client(request: pytest.FixtureRequest):
        mod = importlib.import_module(f"docs_src.body_multiple_params.{request.param}")
    
        client = TestClient(mod.app)
        return client
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 11.7K bytes
    - Click Count (0)
  7. tests/test_request_params/test_form/test_optional_list.py

    from typing import Annotated
    
    import pytest
    from fastapi import FastAPI, Form
    from fastapi.testclient import TestClient
    from pydantic import BaseModel, Field
    
    from .utils import get_body_model_name
    
    app = FastAPI()
    
    # =====================================================================================
    # Without aliases
    
    
    @app.post("/optional-list-str", operation_id="optional_list_str")
    async def read_optional_list_str(
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 09:59:14 GMT 2026
    - 9.9K bytes
    - Click Count (0)
  8. tests/test_tutorial/test_body_nested_models/test_tutorial005.py

    import importlib
    
    import pytest
    from dirty_equals import IsList
    from fastapi.testclient import TestClient
    from inline_snapshot import snapshot
    
    from ...utils import needs_py310
    
    
    @pytest.fixture(
        name="client",
        params=[
            pytest.param("tutorial005_py310", marks=needs_py310),
        ],
    )
    def get_client(request: pytest.FixtureRequest):
        mod = importlib.import_module(f"docs_src.body_nested_models.{request.param}")
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/opensearch/client/SearchEngineClientRebuildTest.java

            assertFalse(result);
        }
    
        @Test
        public void test_reindexConfigIndices_returnsTrueWhenAllSucceed() {
            testClient.existsIndexResult = true;
            testClient.createIndexResult = true;
            testClient.deleteIndexResult = true;
            testClient.reindexResult = true;
            testClient.documentCount = 10;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 28.6K bytes
    - Click Count (0)
  10. tests/test_tutorial/test_body/test_tutorial001.py

        return client
    
    
    def test_body_float(client: TestClient):
        response = client.post("/items/", json={"name": "Foo", "price": 50.5})
        assert response.status_code == 200
        assert response.json() == {
            "name": "Foo",
            "price": 50.5,
            "description": None,
            "tax": None,
        }
    
    
    def test_post_with_str_float(client: TestClient):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Feb 23 17:45:20 GMT 2026
    - 11.1K bytes
    - Click Count (0)
Back to Top