- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 184 for load64 (0.23 sec)
-
cmd/erasure-server-pool-decom.go
func (z *erasureServerPools) Init(ctx context.Context) error { // Load rebalance metadata if present err := z.loadRebalanceMeta(ctx) if err != nil { return fmt.Errorf("failed to load rebalance data: %w", err) } // Start rebalance routine z.StartRebalance() meta := poolMeta{} if err := meta.load(ctx, z.serverPools[0], z.serverPools); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/iam-store.go
break } } mappedPolicy, ok := cache.iamUserPolicyMap.Load(name) if !ok { mappedPolicy, ok = cache.iamSTSPolicyMap.Load(name) } if !ok { // Attempt to load parent user mapping for STS accounts store.loadMappedPolicy(context.TODO(), name, stsUser, false, cache.iamSTSPolicyMap) mappedPolicy, ok = cache.iamSTSPolicyMap.Load(name) if !ok { return u, errNoSuchUser } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/config-current.go
return readServerConfig(GlobalContext, objAPI, nil) } // loadConfig - loads a new config from disk, overrides params // from env if found and valid // data is optional. If nil it will be loaded from backend. func loadConfig(objAPI ObjectLayer, data []byte) error { bootstrapTraceMsg("load the configuration") srvCfg, err := readServerConfig(GlobalContext, objAPI, data) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/tier.go
metrics = append(metrics, MetricV2{ Description: tierRequestsSuccessMD, Value: float64(stat.success), VariableLabels: map[string]string{"tier": tier}, }) metrics = append(metrics, MetricV2{ Description: tierRequestsFailureMD, Value: float64(stat.failure), VariableLabels: map[string]string{"tier": tier}, }) } return metrics }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
callbacks/helper_test.go
var vm visitMap var loaded bool type testM struct { Name string } t1 := testM{Name: "t1"} t2 := testM{Name: "t2"} t3 := testM{Name: "t3"} vm = make(visitMap) if loaded = loadOrStoreVisitMap(&vm, reflect.ValueOf(&t1)); loaded { t.Fatalf("loaded should be false") } if loaded = loadOrStoreVisitMap(&vm, reflect.ValueOf(&t1)); !loaded { t.Fatalf("loaded should be true") }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Mar 05 02:22:57 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-health.go
storageInfo := clusterDriveMetrics.storageInfo m.Set(healthCapacityRawTotalBytes, float64(GetTotalCapacity(storageInfo.Disks))) m.Set(healthCapacityRawFreeBytes, float64(GetTotalCapacityFree(storageInfo.Disks))) m.Set(healthCapacityUsableTotalBytes, float64(GetTotalUsableCapacity(storageInfo.Disks, storageInfo))) m.Set(healthCapacityUsableFreeBytes, float64(GetTotalUsableCapacityFree(storageInfo.Disks, storageInfo))) return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/grid/benchmark_test.go
// Since we are benchmarking n parallel servers we need to multiply by n. // This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond) b.ReportMetric(float64(n)*float64(ops)/spent.Seconds(), "vops/s") b.ReportMetric(latency/float64(ops), "ms/op") } }) } }) b.Run("rpc", func(b *testing.B) { for par := 1; par <= 32; par *= 2 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/common-main.go
// Manually load the certificate and private key into memory. // We need to check whether the private key is encrypted, and // if so, decrypt it using the user-provided password. certBytes, err := os.ReadFile(certFile) if err != nil { return tls.Certificate{}, fmt.Errorf("Unable to load KES client certificate as specified by the shell environment: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
internal/jwt/parser_test.go
defaultKeyFunc, &MapClaims{ MapClaims: jwt.MapClaims{ "foo": "bar", "exp": float64(time.Now().Unix() - 100), }, }, false, -1, }, { "basic nbf", "", // autogen defaultKeyFunc, &MapClaims{ MapClaims: jwt.MapClaims{ "foo": "bar", "nbf": float64(time.Now().Unix() + 100), }, }, false, -1, }, { "expired and nbf",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 05 19:20:08 GMT 2021 - 6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
hourTotals := rt.LastHour.getTotal() return madmin.TimedErrStats{ LastMinute: madmin.RStat{ Count: float64(minuteTotals.N), Bytes: minuteTotals.Size, }, LastHour: madmin.RStat{ Count: float64(hourTotals.N), Bytes: hourTotals.Size, }, Totals: madmin.RStat{ Count: float64(rt.SinceUptime.Count), Bytes: rt.SinceUptime.Bytes, }, ErrCounts: errCounts, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0)