- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for factor (0.18 sec)
-
cmd/data-scanner.go
} } // Sleep sleeps the specified time multiplied by the sleep factor. // If the factor is updated the sleep will be done again with the new factor. func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock() minWait, maxWait := d.minSleep, d.maxSleep factor := d.factor cycle := d.cycle d.mu.RUnlock()
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/xl-storage.go
// xl.meta has "inlined data" we prefer writing O_DIRECT and then doing // fdatasync() at the end instead of opening the file with O_DSYNC. // // This is an optimization mainly to ensure faster I/O. if len(b) > xioutil.DirectioAlignSize { r := bytes.NewReader(b) return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent) } w, err = s.openFileSync(filePath, flags, skipParent)
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) -
istioctl/pkg/internaldebug/internal-debug_test.go
} } else { if fErr != nil { t.Fatalf("Unwanted exception for 'istioctl %s': %v", strings.Join(c.args, " "), fErr) } } } func init() { cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory { tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/erasure-sets.go
} return s, nil } // cleanup ".trash/" folder every 5m minutes with sufficient sleep cycles, between each // deletes a dynamic sleeper is used with a factor of 10 ratio with max delay between // deletes to be 2 seconds. func (s *erasureSets) cleanupDeletedObjects(ctx context.Context) { timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval()) defer timer.Stop()
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) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
} } else { if fErr != nil { t.Fatalf("Unwanted exception for 'istioctl %s': %v", strings.Join(c.args, " "), fErr) } } } func init() { cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory { tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0) -
src/archive/zip/writer.go
var buf []byte if w.isZip64() { buf = make([]byte, dataDescriptor64Len) } else { buf = make([]byte, dataDescriptorLen) } b := writeBuf(buf) b.uint32(dataDescriptorSignature) // de-facto standard, required by OS X b.uint32(w.CRC32) if w.isZip64() { b.uint64(w.CompressedSize64) b.uint64(w.UncompressedSize64) } else { b.uint32(w.CompressedSize) b.uint32(w.UncompressedSize) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
t.Fatalf("Unexpected output for 'istioctl proxy-config all'\n got: %q\nwant: %q", out.String(), expected) } } func init() { cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory { tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle_test.go
objectName: "fooobject", objectTags: "storeforever=false&factory=true",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
} } else { if fErr != nil { t.Fatalf("Unwanted exception for 'istioctl %s': %v", strings.Join(c.args, " "), fErr) } } } func init() { cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory { tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 5.5K bytes - Viewed (0) -
istioctl/pkg/describe/describe_test.go
Namespace: c.namespace, IstioNamespace: c.istioNamespace, Results: c.configDumps, }) client, err := ctx.CLIClient() assert.NoError(t, err) // Override the Istio config factory for i := range c.istioConfigs { switch t := c.istioConfigs[i].(type) { case *v1alpha3.DestinationRule:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0)