Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 173 for Router (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/kms-router.go

    	kmsAPIVersion       = "v1"
    	kmsAPIVersionPrefix = SlashSeparator + kmsAPIVersion
    )
    
    type kmsAPIHandlers struct{}
    
    // registerKMSRouter - Registers KMS APIs
    func registerKMSRouter(router *mux.Router) {
    	kmsAPI := kmsAPIHandlers{}
    	kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter()
    
    	KMSVersions := []string{
    		kmsAPIVersionPrefix,
    	}
    
    	gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 07 23:55:37 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  2. cmd/healthcheck-router.go

    	healthCheckPathPrefix      = minioReservedBucketPath + healthCheckPath
    )
    
    // registerHealthCheckRouter - add handler functions for liveness and readiness routes.
    func registerHealthCheckRouter(router *mux.Router) {
    	// Healthcheck router
    	healthRouter := router.PathPrefix(healthCheckPathPrefix).Subrouter()
    
    	// Cluster check handler to verify cluster is active
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 23 11:12:47 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  3. cmd/metrics-router.go

    const (
    	prometheusJWT    prometheusAuthType = "jwt"
    	prometheusPublic prometheusAuthType = "public"
    )
    
    // registerMetricsRouter - add handler functions for metrics.
    func registerMetricsRouter(router *mux.Router) {
    	// metrics router
    	metricsRouter := router.NewRoute().PathPrefix(minioReservedBucketPath).Subrouter()
    	authType := prometheusAuthType(strings.ToLower(env.Get(EnvPrometheusAuthType, string(prometheusJWT))))
    
    	auth := AuthMiddleware
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 15 16:28:02 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  4. tests/test_router_circular_import.py

    import pytest
    from fastapi import APIRouter
    
    
    def test_router_circular_import():
        router = APIRouter()
    
        with pytest.raises(
            AssertionError,
            match="Cannot include the same APIRouter instance into itself. Did you mean to include a different router?",
        ):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 10 10:58:40 GMT 2026
    - 317 bytes
    - Click Count (0)
  5. tests/test_dependency_yield_scope.py

            )
    
        return StreamingResponse(iter_data())
    
    
    app.include_router(
        prefix="/router-scope-function",
        router=router,
        dependencies=[Depends(raise_after_yield, scope="function")],
    )
    
    app.include_router(
        prefix="/router-scope-request",
        router=router,
        dependencies=[Depends(raise_after_yield, scope="request")],
    )
    
    client = TestClient(app)
    
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  6. docs_src/custom_request_and_route/tutorial003_py310.py

                response.headers["X-Response-Time"] = str(duration)
                print(f"route duration: {duration}")
                print(f"route response: {response}")
                print(f"route response headers: {response.headers}")
                return response
    
            return custom_route_handler
    
    
    app = FastAPI()
    router = APIRouter(route_class=TimedRoute)
    
    
    @app.get("/")
    async def not_timed():
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 10 08:55:32 GMT 2025
    - 1K bytes
    - Click Count (0)
  7. tests/test_strict_content_type_nested.py

        response = client_nested.post("/outer/strict/items/", json={"key": "value"})
        assert response.status_code == 200
    
    
    def test_default_inner_accepts_json_content_type():
        response = client_nested.post("/outer/default/items/", json={"key": "value"})
        assert response.status_code == 200
    
    
    # Strict app -> lax outer router -> strict inner router
    
    app_mixed = FastAPI(strict_content_type=True)
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Feb 23 17:45:20 GMT 2026
    - 2.7K bytes
    - Click Count (0)
  8. tests/test_custom_middleware_exception.py

                return
    
            wrapper = self.receive_wrapper(receive)
            await self.app(scope, wrapper, send)
    
    
    @router.post("/middleware")
    def run_middleware(file: UploadFile = File(..., description="Big File")):
        return {"message": "OK"}
    
    
    app.include_router(router)
    app.add_middleware(ContentSizeLimitMiddleware, max_content_size=2**8)
    
    
    client = TestClient(app)
    
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 09:59:14 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  9. tests/test_security_oauth2_authorization_code_bearer_scopes_openapi.py

    )
    async def read_with_get_token():
        return {"message": "Admin Access"}
    
    
    router = APIRouter(dependencies=[Security(oauth2_scheme, scopes=["read"])])
    
    
    @router.get("/items/")
    async def read_items(token: str | None = Depends(oauth2_scheme)):
        return {"token": token}
    
    
    @router.post("/items/")
    async def create_item(
        token: str | None = Security(oauth2_scheme, scopes=["read", "write"]),
    ):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 09:59:14 GMT 2026
    - 6.6K bytes
    - Click Count (0)
  10. cmd/crossdomain-xml-handler_test.go

    	"testing"
    
    	"github.com/minio/mux"
    )
    
    // Test cross domain xml handler.
    func TestCrossXMLHandler(t *testing.T) {
    	// Server initialization.
    	router := mux.NewRouter().SkipClean(true).UseEncodedPath()
    	handler := setCrossDomainPolicyMiddleware(router)
    	srv := httptest.NewServer(handler)
    
    	resp, err := http.Get(srv.URL + crossDomainXMLEntity)
    	if err != nil {
    		t.Fatal(err)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jul 08 14:31:42 GMT 2023
    - 1.3K bytes
    - Click Count (0)
Back to Top