- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 267 for index (0.05 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} if chanSize > maxChanSize { chanSize = maxChanSize } return chanSize } // isIndexValidLocked checks if a given index is still valid. // This assumes that the lock is held. func (w *watchCache) isIndexValidLocked(index int) bool { return index >= w.startIndex } // getAllEventsSinceLocked returns a watchCacheInterval that can be used to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
src/slices/slices_test.go
v []int }{ // There are no values. {"with negative index", a[:1:1], -1, nil}, {"with out-of-bounds index and > cap", a[:1:1], 2, nil}, {"with out-of-bounds index and = cap", a[:1:2], 2, nil}, {"with out-of-bounds index and < cap", a[:1:3], 2, nil}, // There are values. {"with negative index", a[:1:1], -1, b[:]}, {"with out-of-bounds index and > cap", a[:1:1], 2, b[:]},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:06 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_image_test.go
} func TestPullWithSecrets(t *testing.T) { ctx := context.Background() // auth value is equivalent to: "username":"passed-user","password":"passed-password" dockerCfg := map[string]map[string]string{"index.docker.io/v1/": {"email": "passed-email", "auth": "cGFzc2VkLXVzZXI6cGFzc2VkLXBhc3N3b3Jk"}} dockercfgContent, err := json.Marshal(dockerCfg) if err != nil { t.Errorf("unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
"k8s.io/kubernetes/pkg/controller/resourceclaim/metrics" "k8s.io/utils/ptr" ) const ( // podResourceClaimIndex is the lookup name for the index function which indexes by pod ResourceClaim templates. podResourceClaimIndex = "pod-resource-claim-index" // podResourceClaimAnnotation is the special annotation that generated // ResourceClaims get. Its value is the pod.spec.resourceClaims[].name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/object-api-utils_test.go
if !tt.wantIdx && len(idx) > 0 { t.Errorf("index returned above threshold") } if tt.wantIdx { if idx == nil { t.Errorf("no index returned") } var index s2.Index _, err = index.Load(s2.RestoreIndexHeaders(idx)) if err != nil { t.Errorf("error loading index: %v", err) } t.Log("size:", len(idx)) t.Log(string(index.JSON()))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.4K bytes - Viewed (0) -
src/cmd/compile/internal/types2/infer.go
var maxUntyped map[*TypeParam]Type // lazily allocated (we may not need it) for _, index := range untyped { tpar := params.At(index).typ.(*TypeParam) // is type parameter (no alias) by construction of untyped if u.at(tpar) == nil { arg := args[index] // arg corresponding to tpar if maxUntyped == nil { maxUntyped = make(map[*TypeParam]Type) } max := maxUntyped[tpar]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 13:54:20 UTC 2024 - 26.4K bytes - Viewed (0) -
cmd/object-api-utils.go
} } partSkip = offset - skipLength // Load index and skip more if feasible. if partSkip > 0 && len(oi.Parts) > firstPartIdx && len(oi.Parts[firstPartIdx].Index) > 0 { _, isEncrypted := crypto.IsEncrypted(oi.UserDefined) if isEncrypted { dec, err := decrypt(oi.Parts[firstPartIdx].Index) if err == nil { // Load Index var idx s2.Index _, err := idx.Load(s2.RestoreIndexHeaders(dec))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K bytes - Viewed (0) -
src/net/http/fs.go
return } // use contents of index.html for directory, if present index := strings.TrimSuffix(name, "/") + indexPage ff, err := fs.Open(index) if err == nil { defer ff.Close() dd, err := ff.Stat() if err == nil { d = dd f = ff } } } // Still a directory? (we didn't find an index.html file) if d.IsDir() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 09 17:06:47 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
return subToken, false } func proxyRequestByNodeIndex(ctx context.Context, w http.ResponseWriter, r *http.Request, index int) (success bool) { if len(globalProxyEndpoints) == 0 { return false } if index < 0 || index >= len(globalProxyEndpoints) { return false } ep := globalProxyEndpoints[index] if ep.IsLocal { return false } return proxyRequest(ctx, w, r, ep) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
} return rPods, nil } } func createNoExecuteTaint(index int) corev1.Taint { now := metav1.Now() return corev1.Taint{ Key: "testTaint" + fmt.Sprintf("%v", index), Value: "test" + fmt.Sprintf("%v", index), Effect: corev1.TaintEffectNoExecute, TimeAdded: &now, } } func addToleration(pod *corev1.Pod, index int, duration int64) *corev1.Pod { if pod.Annotations == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0)