Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for route (0.06 seconds)

  1. internal/grid/connection.go

    	return &Subroute{
    		Connection: c,
    		route:      s,
    		subID:      makeSubHandlerID(0, s),
    		trace:      c.trace.subroute(s),
    	}
    }
    
    // Subroute adds a subroute to the subroute.
    // The subroutes are combined with '/'.
    func (c *Subroute) Subroute(s string) *Subroute {
    	route := strings.Join([]string{c.route, s}, "/")
    	return &Subroute{
    		Connection: c.Connection,
    		route:      route,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  2. src/cmd/api/main_test.go

    // For example, on return:
    //
    //	w.importMap["math"] = "math"
    //	w.importDir["math"] = "<goroot>/src/math"
    //
    //	w.importMap["golang.org/x/net/route"] = "vendor/golang.org/x/net/route"
    //	w.importDir["vendor/golang.org/x/net/route"] = "<goroot>/src/vendor/golang.org/x/net/route"
    //
    // Since the set of packages that exist depends on context, the result of
    // loadImports also depends on context. However, to improve test running time
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Feb 20 03:25:33 GMT 2025
    - 31.4K bytes
    - Click Count (0)
  3. internal/grid/manager.go

    	}
    
    	return m, nil
    }
    
    // AddToMux will add the grid manager to the given mux.
    func (m *Manager) AddToMux(router *mux.Router, authReq func(r *http.Request) error) {
    	router.Handle(m.routePath, m.Handler(authReq))
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  4. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  5. docs/config/README.md

    ```
    KEY:
    etcd  federate multiple clusters for IAM and Bucket DNS
    
    ARGS:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.1K bytes
    - Click Count (1)
  6. cmd/api-router.go

    	return handler
    }
    
    // registerAPIRouter - registers S3 compatible APIs.
    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() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  7. 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,
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  8. cmd/admin-handlers_test.go

    )
    
    // adminErasureTestBed - encapsulates subsystems that need to be setup for
    // admin-handler unit tests.
    type adminErasureTestBed struct {
    	erasureDirs []string
    	objLayer    ObjectLayer
    	router      *mux.Router
    	done        context.CancelFunc
    }
    
    // prepareAdminErasureTestBed - helper function that setups a single-node
    // Erasure backend for admin-handler tests.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  9. cmd/kms-handlers_test.go

    		accessKey = userAccessKey
    		secretKey = userSecretKey
    	}
    
    	req := buildKMSRequest(t, test.method, test.path, accessKey, secretKey, test.query)
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    
    	t.Logf("HTTP req: %s, resp code: %d, resp body: %s", req.URL.String(), rec.Code, rec.Body.String())
    
    	// Check status code
    	if rec.Code != test.wantStatusCode {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  10. cmd/sts-handlers.go

    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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
Back to Top