Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 429 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. docs/en/docs/reference/testclient.md

    You can use the `TestClient` class to test FastAPI applications without creating an actual HTTP and socket connection, just communicating directly with the FastAPI code.
    
    Read more about it in the [FastAPI docs for Testing](https://fastapi.tiangolo.com/tutorial/testing/).
    
    You can import it directly from `fastapi.testclient`:
    
    ```python
    from fastapi.testclient import TestClient
    ```
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 450 bytes
    - Click Count (0)
  6. 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)
  7. tests/test_tutorial/test_path_params_numeric_validations/test_tutorial005.py

    import pytest
    from fastapi.testclient import TestClient
    
    
    @pytest.fixture(
        name="client",
        params=[
            pytest.param("tutorial005_py39"),
            pytest.param("tutorial005_an_py39"),
        ],
    )
    def get_client(request: pytest.FixtureRequest) -> TestClient:
        mod = importlib.import_module(
            f"docs_src.path_params_numeric_validations.{request.param}"
        )
        return TestClient(mod.app)
    
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  8. tests/test_request_params/test_cookie/test_optional_str.py

    from typing import Annotated, Optional
    
    import pytest
    from fastapi import Cookie, FastAPI
    from fastapi.testclient import TestClient
    from pydantic import BaseModel, Field
    
    app = FastAPI()
    
    # =====================================================================================
    # Without aliases
    
    
    @app.get("/optional-str")
    async def read_optional_str(p: Annotated[Optional[str], Cookie()] = None):
        return {"p": p}
    
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  9. tests/test_tutorial/test_query_params_str_validations/test_tutorial003.py

        )
    
        client = TestClient(mod.app)
        return client
    
    
    def test_query_params_str_validations_no_query(client: TestClient):
        response = client.get("/items/")
        assert response.status_code == 200
        assert response.json() == {"items": [{"item_id": "Foo"}, {"item_id": "Bar"}]}
    
    
    def test_query_params_str_validations_q_query(client: TestClient):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Dec 26 10:43:02 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  10. tests/test_request_params/test_header/test_optional_list.py

    from typing import Annotated, Optional
    
    import pytest
    from fastapi import FastAPI, Header
    from fastapi.testclient import TestClient
    from pydantic import BaseModel, Field
    
    app = FastAPI()
    
    # =====================================================================================
    # Without aliases
    
    
    @app.get("/optional-list-str")
    async def read_optional_list_str(
        p: Annotated[Optional[list[str]], Header()] = None,
    ):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 9.3K bytes
    - Click Count (0)
Back to Top