Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 421 for handler3 (0.05 seconds)

  1. internal/grid/handlers.go

    	HandlerCheckParts3
    
    	// Add more above here ^^^
    	// If all handlers are used, the type of Handler can be changed.
    	// Handlers have no versioning, so non-compatible handler changes must result in new IDs.
    	handlerTest
    	handlerTest2
    	handlerLast
    )
    
    // handlerPrefixes are prefixes for handler IDs used for tracing.
    // If a handler is not listed here, it will be traced with "grid" prefix.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. internal/grid/manager.go

    		if m.handlers.hasAny(id) && !id.isTestHandler() {
    			return ErrHandlerAlreadyExists
    		}
    		m.handlers.streams[id] = &h
    		return nil
    	}
    	subID := makeSubHandlerID(id, h.Subroute)
    	if m.handlers.hasSubhandler(subID) && !id.isTestHandler() {
    		return ErrHandlerAlreadyExists
    	}
    	m.handlers.subStreams[subID] = &h
    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subStreams[makeZeroSubHandlerID(id)] = &h
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  3. cmd/generic-handlers.go

    		}
    		h.ServeHTTP(w, r)
    	})
    }
    
    // criticalErrorHandler handles panics and fatal errors by
    // `panic(logger.ErrCritical)` as done by `logger.CriticalIf`.
    //
    // It should be always the first / highest HTTP handler.
    func setCriticalErrorHandler(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		defer func() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.7K bytes
    - Click Count (1)
  4. internal/grid/grid_test.go

    	handler2 := func(req *testRequest) (resp *testResponse, err *RemoteErr) {
    		r := RemoteErr(req.String)
    		return nil, &r
    	}
    	errFatal(h1.Register(local, handler1))
    	errFatal(h2.Register(local, handler2))
    
    	errFatal(h1.Register(remote, handler1))
    	errFatal(h2.Register(remote, handler2))
    
    	// local to remote connection
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/context/CIFSContextWrapperTest.java

            // First call should create a new Handler
            URLStreamHandler handler1 = cifsContextWrapper.getUrlHandler();
            assertNotNull(handler1);
            assertTrue(handler1 instanceof Handler);
    
            // Second call should return the same instance
            URLStreamHandler handler2 = cifsContextWrapper.getUrlHandler();
            assertEquals(handler1, handler2);
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.7K bytes
    - Click Count (0)
  6. internal/grid/connection.go

    			return
    		}
    
    		var handler *StatelessHandler
    		if subID == nil {
    			handler = c.handlers.stateless[m.Handler]
    		} else {
    			handler = c.handlers.subStateless[*subID]
    		}
    		if handler == nil {
    			msg := fmt.Sprintf("Invalid Handler for type: %v", m.Handler)
    			if subID != nil {
    				msg = fmt.Sprintf("Invalid Handler for type: %v", *subID)
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  7. cmd/handler-utils.go

    	success = true
    
    	// Make sure we remove any existing headers before
    	// proxying the request to another node.
    	for k := range w.Header() {
    		w.Header().Del(k)
    	}
    
    	f := handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  8. cmd/auth-handler.go

    	_, ok := supportedS3AuthTypes[aType]
    	return ok
    }
    
    // setAuthMiddleware to validate authorization header for the incoming request.
    func setAuthMiddleware(h http.Handler) http.Handler {
    	// handler for validating incoming authorization headers.
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. cmd/sts-handlers.go

    // stsAPIHandlers implements and provides http handlers for AWS STS API.
    type stsAPIHandlers struct{}
    
    // registerSTSRouter - registers AWS STS compatible APIs.
    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    	stsRouter := router.NewRoute().PathPrefix(SlashSeparator).Subrouter()
    
    	// Assume roles with no JWT, handles AssumeRole.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
  10. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    participant client as Client
    participant handler as Exception handler
    participant dep as Dep with yield
    participant operation as Path Operation
    participant tasks as Background tasks
    
        Note over client,operation: Can raise exceptions, including HTTPException
        client ->> dep: Start request
        Note over dep: Run code up to yield
        opt raise Exception
            dep -->> handler: Raise Exception
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 12.6K bytes
    - Click Count (0)
Back to Top