Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for subcounter (0.43 sec)

  1. cmd/peer-rest-server.go

    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    
    	server := &peerRESTServer{}
    	subrouter := router.PathPrefix(peerRESTPrefix).Subrouter()
    	subrouter.Methods(http.MethodPost).Path(peerRESTVersionPrefix + peerRESTMethodHealth).HandlerFunc(h(server.HealthHandler))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  2. cmd/api-router.go

    				// to match for `<bucket>`
    				return host != minioReservedBucket+"."+domainName
    			}).Host("{bucket:.+}."+domainName).Subrouter())
    		} else {
    			routers = append(routers, apiRouter.Host("{bucket:.+}."+domainName).Subrouter())
    		}
    	}
    	routers = append(routers, apiRouter.PathPrefix("/{bucket}").Subrouter())
    
    	for _, router := range routers {
    		// Register all rejected object APIs
    		for _, r := range rejectedObjAPIs {
    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)
  3. internal/dsync/dsync-server_test.go

    		router := mux.NewRouter().SkipClean(true)
    		subrouter := router.PathPrefix("/").Subrouter()
    		subrouter.Methods(http.MethodPost).Path("/v1/health").HandlerFunc(lockServer.HealthHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/refresh").HandlerFunc(lockServer.RefreshHandler)
    		subrouter.Methods(http.MethodPost).Path("/v1/lock").HandlerFunc(lockServer.LockHandler)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 23 16:46:37 GMT 2023
    - 8.3K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    				endpoint: endpoint,
    			}
    
    			subrouter := router.PathPrefix(path.Join(storageRESTPrefix, endpoint.Path)).Subrouter()
    
    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodHealth).HandlerFunc(h(server.HealthHandler))
    			subrouter.Methods(http.MethodPost).Path(storageRESTVersionPrefix + storageRESTMethodAppendFile).HandlerFunc(h(server.AppendFileHandler))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  5. cmd/admin-router.go

    func registerAdminRouter(router *mux.Router, enableConfigOps bool) {
    	adminAPI := adminAPIHandlers{}
    	// Admin router
    	adminRouter := router.PathPrefix(adminPathPrefix).Subrouter()
    
    	adminVersions := []string{
    		adminAPIVersionPrefix,
    	}
    
    	for _, adminVersion := range adminVersions {
    		// Restart and stop MinIO service type=2
    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)
  6. cmd/test-utils_test.go

    		// Register all api endpoints by default.
    		registerAPIRouter(muxRouter)
    		return
    	}
    	// API Router.
    	apiRouter := muxRouter.PathPrefix(SlashSeparator).Subrouter()
    	// Bucket router.
    	bucketRouter := apiRouter.PathPrefix("/{bucket}").Subrouter()
    
    	// All object storage operations are registered as HTTP handlers on `objectAPIHandlers`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  7. cmd/kms-router.go

    )
    
    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))
    	if err != nil {
    		// Static params, so this is very unlikely.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Aug 19 14:37:53 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  8. cmd/healthcheck-router.go

    )
    
    // 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
    	healthRouter.Methods(http.MethodGet).Path(healthCheckClusterPath).HandlerFunc(httpTraceAll(ClusterCheckHandler))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jan 23 11:12:47 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  9. cmd/metrics-router.go

    )
    
    // 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
    	if authType == prometheusPublic {
    		auth = NoAuthMiddleware
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  10. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
Back to top