Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for Subrouter (0.11 sec)

  1. cmd/test-utils_test.go

    	muxRouter := mux.NewRouter().SkipClean(true).UseEncodedPath()
    	if len(apiFunctions) > 0 {
    		// Iterate the list of API functions requested for and register them in mux HTTP handler.
    		registerAPIFunctions(muxRouter, objLayer, apiFunctions...)
    		muxRouter.Use(globalMiddlewares...)
    		return muxRouter
    	}
    	registerAPIRouter(muxRouter)
    	muxRouter.Use(globalMiddlewares...)
    	return muxRouter
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. cmd/sts-handlers.go

    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    	stsRouter := router.NewRoute().PathPrefix(SlashSeparator).Subrouter()
    
    	// Assume roles with no JWT, handles AssumeRole.
    	stsRouter.Methods(http.MethodPost).MatcherFunc(func(r *http.Request, rm *mux.RouteMatch) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  3. internal/grid/README.md

    ## Handlers & Routes
    
    Handlers have a predefined Handler ID. 
    In addition, there can be several *static* subroutes used to differentiate between different handlers of the same ID.
    A subroute on a client must match a subroute on the server. So routes cannot be used for dynamic routing, unlike HTTP.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. internal/grid/manager.go

    // []byte -> ([]byte, error) requests.
    // subroutes are joined with "/" to a single subroute.
    func (m *Manager) RegisterSingleHandler(id HandlerID, h SingleHandlerFn, subroute ...string) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	s := strings.Join(subroute, "/")
    	if debugPrint {
    		fmt.Println("RegisterSingleHandler: ", id.String(), "subroute:", s)
    	}
    
    	if len(subroute) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. tests/test_router_events.py

            state.router_shutdown = True
    
        sub_router = APIRouter()
    
        @sub_router.on_event("startup")
        def sub_router_startup() -> None:
            state.sub_router_startup = True
    
        @sub_router.on_event("shutdown")
        def sub_router_shutdown() -> None:
            state.sub_router_shutdown = True
    
        router.include_router(sub_router)
        app.include_router(router)
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 24 19:09:52 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. internal/grid/connection.go

    	}
    	return c
    }
    
    // Subroute returns a static subroute for the connection.
    func (c *Connection) Subroute(s string) *Subroute {
    	if c == nil {
    		return nil
    	}
    	return &Subroute{
    		Connection: c,
    		route:      s,
    		subID:      makeSubHandlerID(0, s),
    		trace:      c.trace.subroute(s),
    	}
    }
    
    // Subroute adds a subroute to the subroute.
    // The subroutes are combined with '/'.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. tests/test_additional_response_extra.py

    from fastapi import APIRouter, FastAPI
    from fastapi.testclient import TestClient
    
    router = APIRouter()
    
    sub_router = APIRouter()
    
    app = FastAPI()
    
    
    @sub_router.get("/")
    def read_item():
        return {"id": "foo"}
    
    
    router.include_router(sub_router, prefix="/items")
    
    app.include_router(router)
    
    client = TestClient(app)
    
    
    def test_path_operation():
        response = client.get("/items/")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jun 30 18:25:16 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  8. internal/grid/trace.go

    		TraceType: madmin.TraceInternal,
    		Prefix:    "grid",
    		Local:     c.Local,
    		Remote:    c.Remote,
    		Subroute:  "",
    	}
    }
    
    // subroute adds a specific subroute to the request.
    func (c *tracer) subroute(subroute string) *tracer {
    	if c == nil {
    		return nil
    	}
    	c2 := *c
    	c2.Subroute = subroute
    	return &c2
    }
    
    type tracer struct {
    	Publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  9. internal/grid/handlers.go

    		// Any non-nil error sent as response means no more responses are sent.
    		Handle StreamHandlerFn
    
    		// Subroute for handler.
    		// Subroute must be static and clients should specify a matching subroute.
    		// Should not be set unless there are different handlers for the same HandlerID.
    		Subroute string
    
    		// OutCapacity is the output capacity. If <= 0 capacity will be 1.
    		OutCapacity int
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  10. internal/grid/benchmark_test.go

    					toSend = append(toSend, payload...)
    					select {
    					case <-ctx.Done():
    						return nil
    					case out <- toSend:
    					}
    				}
    				return nil
    			},
    
    			Subroute:    "some-subroute",
    			OutCapacity: 1, // Only one message buffered.
    			InCapacity:  0,
    		}))
    		errFatal(err)
    	}
    	const payloadSize = 512
    	rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top