Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 59 for RestClient (0.06 seconds)

  1. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  2. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 11.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 Dec 28 19:28:13 GMT 2025
    - 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  5. tests/test_tutorial/test_body/test_tutorial001.py

    import importlib
    from unittest.mock import patch
    
    import pytest
    from fastapi.testclient import TestClient
    
    from ...utils import needs_py310
    
    
    @pytest.fixture(
        name="client",
        params=[
            "tutorial001_py39",
            pytest.param("tutorial001_py310", marks=needs_py310),
        ],
    )
    def get_client(request: pytest.FixtureRequest):
        mod = importlib.import_module(f"docs_src.body.{request.param}")
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  6. tests/test_request_params/test_query/test_list.py

    from typing import Annotated
    
    import pytest
    from dirty_equals import IsOneOf
    from fastapi import FastAPI, Query
    from fastapi.testclient import TestClient
    from pydantic import BaseModel, Field
    
    app = FastAPI()
    
    # =====================================================================================
    # Without aliases
    
    
    @app.get("/required-list-str")
    async def read_required_list_str(p: Annotated[list[str], Query()]):
        return {"p": p}
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:31:34 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  7. 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 Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 20:40:26 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  8. docs/ru/docs/tutorial/testing.md

    Это позволяет вам использовать `pytest` без лишних усложнений.
    
    ///
    
    /// note | Технические детали
    
    Также можно написать `from starlette.testclient import TestClient`.
    
    **FastAPI** предоставляет тот же самый `starlette.testclient` как `fastapi.testclient`. Это всего лишь небольшое удобство для Вас, как разработчика. Но он берётся напрямую из Starlette.
    
    ///
    
    /// tip | Подсказка
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 10K bytes
    - Click Count (0)
  9. tests/test_tutorial/test_body_multiple_params/test_tutorial002.py

    import pytest
    from fastapi.testclient import TestClient
    
    from ...utils import needs_py310
    
    
    @pytest.fixture(
        name="client",
        params=[
            pytest.param("tutorial002_py39"),
            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)
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 11K bytes
    - Click Count (0)
  10. tests/test_request_params/test_form/test_optional_list.py

    from typing import Annotated, Optional
    
    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 Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 9.9K bytes
    - Click Count (0)
Back to Top