- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 148 for mantler (2.43 sec)
-
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/crossdomain-xml-handler.go
// policy file that grants access to the source domain, allowing the client to continue the transaction. func setCrossDomainPolicyMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { cxml := crossDomainXML if globalServerCtxt.CrossDomainXML != "" { cxml = globalServerCtxt.CrossDomainXML }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 06:42:40 GMT 2024 - 2.2K bytes - Viewed (0) -
internal/grid/debug.go
func (t *TestGrid) WaitAllConnect(ctx context.Context) { for _, manager := range t.Managers { for _, remote := range manager.Targets() { if manager.HostName() == remote { continue } if err := manager.Connection(remote).WaitForConnect(ctx); err != nil { panic(err) } } } } func getHosts(n int) (hosts []string, listeners []net.Listener, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/grid/handlers.go
HandlerRenameData2 // 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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/bucket-versioning-handler.go
Harshavardhana <******@****.***> 1713808170 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
cmd/handler-utils_test.go
Harshavardhana <******@****.***> 1708583166 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 6.1K bytes - Viewed (0) -
cmd/peer-rest-server.go
logger.FatalIf(getMetacacheListingRPC.Register(gm, server.GetMetacacheListingHandler), "unable to register handler") logger.FatalIf(getMetricsRPC.Register(gm, server.GetMetricsHandler), "unable to register handler") logger.FatalIf(getNetInfoRPC.Register(gm, server.GetNetInfoHandler), "unable to register handler") logger.FatalIf(getOSInfoRPC.Register(gm, server.GetOSInfoHandler), "unable to register handler")
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) -
internal/grid/connection.go
return newMuxStateless(ctx, m, c, *handler) }) } else { // Stream: var handler *StreamHandler if subID == nil { if !m.Handler.valid() { gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"})) return } handler = c.handlers.streams[m.Handler] } else { handler = c.handlers.subStreams[*subID] } if handler == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/api-router.go
// If none of the routes match add default error handler routes apiRouter.NotFoundHandler = collectAPIStats("notfound", httpTraceAll(errorResponseHandler)) apiRouter.MethodNotAllowedHandler = collectAPIStats("methodnotallowed", httpTraceAll(methodNotAllowedHandler("S3"))) } // corsHandler handler for CORS (Cross Origin Resource Sharing) func corsHandler(handler http.Handler) http.Handler { commonS3Headers := []string{ xhttp.Date,
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)