- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for gm (0.18 sec)
-
cmd/storage-rest-server.go
logger.FatalIf(storageListDirRPC.RegisterNoInput(gm, server.ListDirHandler, endpoint.Path), "unable to register handler") logger.FatalIf(storageReadAllRPC.Register(gm, server.ReadAllHandler, endpoint.Path), "unable to register handler") logger.FatalIf(storageWriteAllRPC.Register(gm, server.WriteAllHandler, endpoint.Path), "unable to register handler")
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) -
cmd/bootstrap-peer-server.go
// registerBootstrapRESTHandlers - register bootstrap rest router. func registerBootstrapRESTHandlers(gm *grid.Manager) { server := &bootstrapRESTServer{} logger.FatalIf(serverVerifyHandler.Register(gm, server.VerifyHandler), "unable to register handler") } // client to talk to bootstrap NEndpoints. type bootstrapRESTClient struct { gridConn *grid.Connection }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
return nil } gc := gridConn.Load() if gc != nil { return gc } gm := globalGrid.Load() if gm == nil { return nil } gc = gm.Connection(node.GridHost) if gc == nil { bugLogIf(context.Background(), fmt.Errorf("gridHost %s not found for peer %s", node.GridHost, node.Host), node.Host+":gridHost")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/peer-rest-server.go
logger.FatalIf(getBucketStatsRPC.Register(gm, server.GetBucketStatsHandler), "unable to register handler") logger.FatalIf(getCPUsHandler.Register(gm, server.GetCPUsHandler), "unable to register handler") logger.FatalIf(getLastDayTierStatsRPC.Register(gm, server.GetLastDayTierStatsHandler), "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) -
cmd/storage-rest-client.go
xhttp.DrainBody(respBody) return toStorageErr(err) != errDiskNotFound } } conn := gm.Connection(endpoint.GridHost()).Subroute(endpoint.Path) if conn == nil { return nil, fmt.Errorf("unable to find connection for %s in targets: %v", endpoint.GridHost(), gm.Targets()) } client := &storageRESTClient{ endpoint: endpoint, restClient: restClient, gridConn: conn,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/peer-rest-client.go
return nil } gc := gridConn.Load() if gc != nil { return gc } gm := globalGrid.Load() if gm == nil { return nil } gc = gm.Connection(gridHost) if gc == nil { bugLogIf(context.Background(), fmt.Errorf("gridHost %q not found for peer %s", gridHost, peer.String()), peer.String()+":gridHost") return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0)