- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for rack (0.14 sec)
-
internal/grid/grid_test.go
st, err := remoteConn.NewStream(ctx, handlerTest, []byte(testPayload)) errFatal(err) // Wait for the server to send the first response. <-serverSent // Read back from the stream and block. nowBlocking := make(chan struct{}) stopBlocking := make(chan struct{}) defer close(stopBlocking) go func() { st.Results(func(b []byte) error { close(nowBlocking)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/format-erasure.go
return nil, err } return getFormatErasureInQuorum(formats) } // ecDrivesNoConfig returns the erasure coded drives in a set if no config has been set. // It will attempt to read it from env variable and fall back to drives/2. func ecDrivesNoConfig(setDriveCount int) (int, error) { sc, err := storageclass.LookupConfig(config.KVS{}, setDriveCount) if err != nil { return 0, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/utils.go
// for i, c := range via { // fmt.Printf("Sofar %d: %s %s\n", i, c.Method, c.URL.String()) // } // Save the last request in a redirect chain. lastReq = req // We do not follow redirect back to client application. if req.URL.Path == "/oauth_callback" { return http.ErrUseLastResponse } return nil } dexClient := http.Client{ CheckRedirect: checkRedirect, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/data-scanner.go
} } // add this version back to remaining versions for // subsequent lifecycle policy applications objectInfos = append(objectInfos, obj) continue } // NoncurrentDays not passed yet. if time.Now().UTC().Before(lifecycle.ExpectedExpiryTime(obj.SuccessorModTime, event.NoncurrentDays)) { // add this version back to remaining versions for
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/server-main.go
if err != nil { logger.FatalIf(err, "Unable to validate passed arguments in %s:%s", config.EnvVolumes, os.Getenv(config.EnvVolumes)) } } if v == "" { // Fall back to older environment value MINIO_ENDPOINTS v, _, _, err = env.LookupEnv(config.EnvEndpoints) if err != nil { logger.FatalIf(err, "Unable to validate passed arguments in %s:%s",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 34.9K bytes - Viewed (1) -
cmd/erasure-sets.go
continue } // An online-disk means its a valid disk but it may be a re-connected disk // we verify that here based on LastConn(), however we make sure to avoid // putting it back into the s.erasureDisks by re-placing the disk again. _, setIndex, _ := cdisk.GetDiskLoc() if setIndex != -1 { continue } } if cdisk != nil { // Close previous offline disk.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5)