Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 181 for mantler (0.2 sec)

  1. internal/grid/manager.go

    	}
    
    	return m, nil
    }
    
    // AddToMux will add the grid manager to the given mux.
    func (m *Manager) AddToMux(router *mux.Router) {
    	router.Handle(RoutePath, m.Handler())
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    func (m *Manager) Handler() http.HandlerFunc {
    	return func(w http.ResponseWriter, req *http.Request) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  2. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  3. cmd/metrics-v3-handler.go

    	for _, val := range v {
    		s = append(s, fmt.Sprintf("%v", val))
    	}
    	err := fmt.Errorf("metrics handler error: %v", strings.Join(s, " "))
    	metricsLogIf(GlobalContext, err)
    }
    
    type metricsV3Server struct {
    	registry *prometheus.Registry
    	opts     promhttp.HandlerOpts
    	authFn   func(http.Handler) http.Handler
    
    	metricsData *metricsV3Collection
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/handler-api.go

    				errorCodes.ToAPIErr(ErrTooManyRequests),
    				r.URL)
    			globalHTTPStats.addRequestsInQueue(-1)
    			return
    		case <-r.Context().Done():
    			// When the client disconnects before getting the S3 handler
    			// status code response, set the status code to 499 so this request
    			// will be properly audited and traced.
    			w.WriteHeader(499)
    			globalHTTPStats.addRequestsInQueue(-1)
    			return
    		}
    	}
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
  5. maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java

                    ArtifactHandler handler = manager.getArtifactHandler(id);
                    type = new DefaultType(
                            id,
                            languageRegistry.require(handler.getLanguage()),
                            handler.getExtension(),
                            handler.getClassifier(),
                            handler.isIncludesDependencies(),
                            JavaPathType.CLASSES,
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Thu Apr 25 14:13:36 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  6. docs/en/docs/advanced/events.md

    ```Python
    with open("file.txt") as file:
        file.read()
    ```
    
    In recent versions of Python, there's also an **async context manager**. You would use it with `async with`:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  7. internal/grid/handlers.go

    	// 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.
    var handlerPrefixes = [handlerLast]string{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26.9K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    Anis Eleuch <******@****.***> 1712232280 +0100
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  9. cmd/bootstrap-peer-server.go

    // registerBootstrapRESTHandlers - register bootstrap rest router.
    func registerBootstrapRESTHandlers(gm *grid.Manager) {
    	server := &bootstrapRESTServer{}
    	logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler")
    }
    
    // client to talk to bootstrap NEndpoints.
    type bootstrapRESTClient struct {
    	gridConn *grid.Connection
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  10. .github/workflows/iam-integrations.yaml

            run: |
              sudo sysctl net.ipv6.conf.all.disable_ipv6=0
              sudo sysctl net.ipv6.conf.default.disable_ipv6=0
              go run docs/iam/access-manager-plugin.go &
              make test-iam
          - name: Test MinIO Old Version data to IAM import current version
            if: matrix.ldap == 'ldaphost:389'
            env:
              _MINIO_LDAP_TEST_SERVER: ${{ matrix.ldap }}
    Others
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top