Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for Routes (0.15 sec)

  1. cmd/api-router.go

    func registerAPIRouter(router *mux.Router) {
    	// Initialize API.
    	api := objectAPIHandlers{
    		ObjectAPI: newObjectLayerFn,
    	}
    
    	// API Router
    	apiRouter := router.PathPrefix(SlashSeparator).Subrouter()
    
    	var routers []*mux.Router
    	for _, domainName := range globalDomainNames {
    		if IsKubernetes() {
    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)
  2. cmd/admin-router.go

    type adminAPIHandlers struct{}
    
    // registerAdminRouter - Add handler functions for each service REST API routes.
    func registerAdminRouter(router *mux.Router, enableConfigOps bool) {
    	adminAPI := adminAPIHandlers{}
    	// Admin router
    	adminRouter := router.PathPrefix(adminPathPrefix).Subrouter()
    
    	adminVersions := []string{
    		adminAPIVersionPrefix,
    	}
    
    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)
  3. cmd/handler-utils.go

    		return matches[1]
    	}
    	return "unknown"
    }
    
    func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) {
    	return errorResponseHandler
    }
    
    // If none of the http routes match respond with appropriate errors
    func errorResponseHandler(w http.ResponseWriter, r *http.Request) {
    	if r.Method == http.MethodOptions {
    		return
    	}
    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)
  4. cmd/update.go

    	scanner := bufio.NewScanner(helmInfoFile)
    	for scanner.Scan() {
    		if strings.Contains(scanner.Text(), "chart=") {
    			helmChartVersion := strings.TrimPrefix(scanner.Text(), "chart=")
    			// remove quotes from the chart version
    			return strings.Trim(helmChartVersion, `"`)
    		}
    	}
    
    	return ""
    }
    
    // IsSourceBuild - returns if this binary is a non-official build from
    // source code.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    //
    // Any updates to this must be serialized via globalLocalDrivesMu (locker)
    var globalLocalSetDrives [][][]StorageAPI
    
    // registerStorageRESTHandlers - register storage rpc router.
    func registerStorageRESTHandlers(router *mux.Router, endpointServerPools EndpointServerPools, gm *grid.Manager) {
    	h := func(f http.HandlerFunc) http.HandlerFunc {
    		return collectInternodeStats(httpTraceHdrs(f))
    	}
    
    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)
  6. internal/grid/muxclient.go

    	}
    	msg.setZeroPayloadFlag()
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    
    	// Send...
    	err := m.send(msg)
    	if err != nil {
    		out <- Response{Err: err}
    		return
    	}
    
    	// Route directly to output.
    	m.respWait = out
    }
    
    // RequestStream will send a single payload request and stream back results.
    // 'requests' can be nil, in which case only req is sent as input.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    		return restoreObjStatus{}, errRestoreHDRMalformed
    	}
    
    	switch progressTokens[1] {
    	case "true", `"true"`: // true without double quotes is deprecated in Feb 2022
    		if len(tokens) == 1 {
    			return ongoingRestoreObj(), nil
    		}
    	case "false", `"false"`: // false without double quotes is deprecated in Feb 2022
    		if len(tokens) != 2 {
    			return restoreObjStatus{}, errRestoreHDRMalformed
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. internal/event/target/postgresql.go

    			valid = false
    			return -1
    		}
    	}, name)
    
    	if valid {
    		// check for simple name or quoted name
    		// - letter/underscore followed by one or more letter/digit/underscore
    		// - any text between quotes (text cannot contain a quote itself)
    		if match, err := regexp.MatchString("^[a_][a0_$]*$", cleaned); err != nil {
    			return err
    		} else if match {
    			return nil
    		}
    	}
    
    	return errInvalidPsqlTablename
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  9. cmd/api-response.go

    	cs := oi.decryptChecksums(0)
    	c := CompleteMultipartUploadResponse{
    		Location: location,
    		Bucket:   bucket,
    		Key:      key,
    		// AWS S3 quotes the ETag in XML, make sure we are compatible here.
    		ETag:           "\"" + oi.ETag + "\"",
    		ChecksumSHA1:   cs[hash.ChecksumSHA1.String()],
    		ChecksumSHA256: cs[hash.ChecksumSHA256.String()],
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  10. cmd/common-main.go

    	if len(envTokens) != 2 {
    		return envKV{}, fmt.Errorf("envEntry malformed; %s, expected to be of form 'KEY=value'", envEntry)
    	}
    
    	key := envTokens[0]
    	val := envTokens[1]
    
    	// Remove quotes from the value if found
    	if len(val) >= 2 {
    		quote := val[0]
    		if (quote == '"' || quote == '\'') && val[len(val)-1] == quote {
    			val = val[1 : len(val)-1]
    		}
    	}
    
    	return envKV{
    		Key:   key,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
Back to top