- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 68 for heddle (0.3 sec)
-
cmd/storage-rest-server.go
logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerWalkDir, grid.StreamHandler{ Subroute: endpoint.Path, Handle: server.WalkDirHandler, OutCapacity: 1, }), "unable to register handler") createStorage := func(server *storageRESTServer) bool { xl, err := newXLStorage(endpoint, false)
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) -
internal/grid/debug.go
return nil }, AddAuth: func(aud string) string { return aud }, BlockConnect: ready, }) if err != nil { return nil, err } m := mux.NewRouter() m.Handle(RoutePath, manager.Handler()) res.Managers = append(res.Managers, manager) res.Servers = append(res.Servers, startHTTPServer(listeners[i], m)) res.Listeners = append(res.Listeners, listeners[i])
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) -
cmd/xl-storage.go
return res, err } s.RLock() formatLegacy := s.formatLegacy s.RUnlock() dstBuf, err := xioutil.ReadFile(dstFilePath) if err != nil { // handle situations when dstFilePath is 'file' // for example such as someone is trying to // upload an object such as `prefix/object/xl.meta` // where `prefix/object` is already an object
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
internal/s3select/select_test.go
<RequestProgress> <Enabled>FALSE</Enabled> </RequestProgress> <ScanRange><End>35</End></ScanRange> </SelectObjectContentRequest>`), }, { name: "select-middle", input: testInput, // Since we are doing offset, no headers are used. wantResult: `{"_1":"a text, with comma"}`, requestXML: []byte(`<?xml version="1.0" encoding="UTF-8"?> <SelectObjectContentRequest>
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
return nil } gridConn.Store(gc) return gc }, } } // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints() // after verifying format.json
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) -
cmd/signature-v4_test.go
package cmd import ( "context" "fmt" "net/http" "net/url" "os" "testing" "time" ) func niceError(code APIErrorCode) string { // Special-handle ErrNone if code == ErrNone { return "ErrNone" } return fmt.Sprintf("%s (%s)", errorCodes[code].Code, errorCodes[code].Description) } func TestDoesPolicySignatureMatch(t *testing.T) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/api-router.go
HandlerFunc(s3APIMiddleware(api.ListBucketsHandler)) // S3 browser with signature v4 adds '//' for ListBuckets request, so rather // than failing with UnknownAPIRequest we simply handle it for now. apiRouter.Methods(http.MethodGet).Path(SlashSeparator + SlashSeparator). HandlerFunc(s3APIMiddleware(api.ListBucketsHandler)) // If none of the routes match add default error handler routes
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) -
cmd/metacache-entries.go
return FileInfo{ Volume: bucket, Name: e.name, Mode: uint32(os.ModeDir), }, nil } if e.cached != nil { if len(e.cached.versions) == 0 { // This special case is needed to handle xlMeta.versions == 0 return FileInfo{ Volume: bucket, Name: e.name, Deleted: true, IsLatest: true, ModTime: timeSentinel1970, }, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/test-utils_test.go
hm := hmac.New(sha1.New, []byte(secretAccessKey)) hm.Write([]byte(stringToSign)) // Calculate signature. signature := base64.StdEncoding.EncodeToString(hm.Sum(nil)) query := req.URL.Query() // Handle specially for Google Cloud Storage. query.Set("AWSAccessKeyId", accessKeyID) // Fill in Expires for presigned query. query.Set("Expires", strconv.FormatInt(epochExpires, 10)) // Encode query and save.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
logger.FatalIf(updateMetacacheListingRPC.Register(gm, server.UpdateMetacacheListingHandler), "unable to register handler") logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerTrace, grid.StreamHandler{ Handle: server.TraceHandler, Subroute: "", OutCapacity: 100000, InCapacity: 0, }), "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)