- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for index (0.19 sec)
-
cmd/erasure-object.go
fi := metadata[index] // Assign index when index is initialized if fi.Erasure.Index == 0 { fi.Erasure.Index = index + 1 } if !fi.IsValid() { return errFileCorrupt } resp, err := disks[index].RenameData(ctx, srcBucket, srcEntry, fi, dstBucket, dstEntry, RenameOptions{}) if err != nil { return err } diskVersions[index] = resp.Sign
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
src/cmd/go/internal/modload/init.go
if !addToolchainRoot { padding = 1 } roots = make([]module.Version, 0, padding+len(modFile.Require)) for _, r := range modFile.Require { if index := MainModules.Index(m); index != nil && index.exclude[r.Mod] { if cfg.BuildMod == "mod" { fmt.Fprintf(os.Stderr, "go: dropping requirement on excluded version %s %s\n", r.Mod.Path, r.Mod.Version) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
bucketsToBeUpdatedSlice := bucketsToBeUpdated.ToSlice() g := errgroup.WithNErrs(len(bucketsToBeUpdatedSlice)).WithConcurrency(50) for index := range bucketsToBeUpdatedSlice { index := index g.Go(func() error { return globalDNSConfig.Put(bucketsToBeUpdatedSlice[index]) }, index) } ctx := GlobalContext for _, err := range g.Wait() { if err != nil { dnsLogIf(ctx, err) return } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
} } pred := storage.Everything pred.AllowWatchBookmarks = true makePod := func(index int) *examplev1.Pod { return &examplev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("pod-%d", index), Namespace: "ns", ResourceVersion: fmt.Sprintf("%v", 100+index), }, } } // Create pod to initialize watch cache.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
} func expectAction(t *testing.T, actions []k8stesting.Action, index int, verb, resource string) { t.Helper() if len(actions) <= index { t.Fatalf("Expected at least %d actions, got %d", index+1, len(actions)) } action := actions[index] if action.GetVerb() != verb { t.Errorf("Expected action %d verb to be %s, got %s", index, verb, action.GetVerb()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
return false } if hasBackoffLimitPerIndex(jobCtx.job) { if index := getCompletionIndex(pod.Annotations); index != unknownCompletionIndex { if p, ok := jobCtx.podsWithDelayedDeletionPerIndex[index]; ok && p.UID == pod.UID { logger.V(3).Info("Delaying pod finalizer removal to await for pod recreation within the index", "pod", klog.KObj(pod)) return false } } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/cmd/go/internal/modget/get.go
// that resolved the module to that version (the “reason”). resolvedVersion map[string]versionReason buildList []module.Version buildListVersion map[string]string // index of buildList (module path → version) initialVersion map[string]string // index of the initial build list at the start of 'go get' missing []pathSet // candidates for missing transitive dependencies work *par.Queue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:26:32 UTC 2024 - 66.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/security_windows.go
return *getSidSubAuthorityCount(sid) } // SubAuthority returns the sub-authority of the SID as specified by // the index, which must be less than sid.SubAuthorityCount(). func (sid *SID) SubAuthority(idx uint32) uint32 { if idx >= uint32(sid.SubAuthorityCount()) { panic("sub-authority index out of range") } return *getSidSubAuthority(sid, idx) } // IsValid returns whether the SID has a valid revision and length.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 52.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
listVal.Set(reflect.MakeSlice(listVal.Type(), len(selectedObjects), len(selectedObjects))) span.AddEvent("Resized result") for i, o := range selectedObjects { listVal.Index(i).Set(reflect.ValueOf(o).Elem()) } } span.AddEvent("Filtered items", attribute.Int("count", listVal.Len())) if c.versioner != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/erasure-healing_test.go
) // Tests isObjectDangling function func TestIsObjectDangling(t *testing.T) { fi := newFileInfo("test-object", 2, 2) fi.Erasure.Index = 1 ifi := newFileInfo("test-object", 2, 2) ifi.SetInlineData() ifi.Erasure.Index = 1 testCases := []struct { name string metaArr []FileInfo errs []error dataErrs map[int][]int
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0)