Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 96 for Chandler (0.17 sec)

  1. internal/grid/handlers.go

    	HandlerRenameData2
    
    	// 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  2. 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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    			return newMuxStateless(ctx, m, c, *handler)
    		})
    	} else {
    		// Stream:
    		var handler *StreamHandler
    		if subID == nil {
    			if !m.Handler.valid() {
    				gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"}))
    				return
    			}
    			handler = c.handlers.streams[m.Handler]
    		} else {
    			handler = c.handlers.subStreams[*subID]
    		}
    		if handler == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle-handlers_test.go

    			t.Fatalf("Test %d: %s: Failed to create HTTP request for GetBucketLocationHandler: <ERROR> %v", i+1, instanceType, err)
    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler.
    		apiRouter.ServeHTTP(rec, req)
    		if rec.Code != testCase.expectedRespStatus {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 13 20:52:33 GMT 2023
    - 11.2K bytes
    - Viewed (0)
  5. cmd/api-router.go

    }
    
    // corsHandler handler for CORS (Cross Origin Resource Sharing)
    func corsHandler(handler http.Handler) http.Handler {
    	commonS3Headers := []string{
    		xhttp.Date,
    		xhttp.ETag,
    		xhttp.ServerInfo,
    		xhttp.Connection,
    		xhttp.AcceptRanges,
    		xhttp.ContentRange,
    		xhttp.ContentEncoding,
    		xhttp.ContentLength,
    		xhttp.ContentType,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  6. cmd/admin-router.go

    		}
    
    		// call the final handler
    		f2(w, r)
    	}
    
    	// Enable compression of responses based on presence of flag.
    	if !handlerFlags.Has(noGZFlag) {
    		handler = gzipHandler(handler)
    	}
    
    	return handler
    }
    
    // adminAPIHandlers provides HTTP handlers for MinIO admin API.
    type adminAPIHandlers struct{}
    
    // registerAdminRouter - Add handler functions for each service REST API routes.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  8. cmd/signature-v4_test.go

    				"X-Amz-Content-Sha256": payloadSHA256,
    			},
    			region:   "",
    			expected: ErrSignatureDoesNotMatch,
    		},
    		// (8) Should error with signature does not match. But handles
    		// query params which do not precede with "x-amz-" header.
    		{
    			queryParams: map[string]string{
    				"X-Amz-Algorithm":       signV4Algorithm,
    				"X-Amz-Date":            now.Format(iso8601Format),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 10.4K bytes
    - Viewed (1)
  9. 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)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  10. cmd/metrics-resource.go

    				}
    			}
    		}
    
    		return metrics
    	})
    	return mg
    }
    
    // metricsResourceHandler is the prometheus handler for resource metrics
    func metricsResourceHandler() http.Handler {
    	return metricsHTTPHandler(resourceCollector, "handler.MetricsResource")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
Back to top