- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for route (0.06 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)