Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for Indexer (0.72 sec)

  1. pkg/controller/statefulset/stateful_pod_control_test.go

    	fakeClient := &fake.Clientset{}
    	claims := getPersistentVolumeClaims(set, pod)
    	indexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc})
    	for k := range claims {
    		claim := claims[k]
    		indexer.Add(&claim)
    	}
    	claimLister := corelisters.NewPersistentVolumeClaimLister(indexer)
    	control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go

    	startIndex, endIndex, locker := 0, len(events), &sync.Mutex{}
    	indexer := func(i int) *watchCacheEvent {
    		if len(events) == 0 {
    			return nil
    		}
    		return events[i]
    	}
    	indexValidator := func(_ int) bool { return true }
    
    	return newCacheInterval(startIndex, endIndex, indexer, indexValidator, locker)
    }
    
    func bufferFromEvents(events []*watchCacheEvent) *watchCacheIntervalBuffer {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler_test.go

    				},
    			},
    			wantErr: "indexer conflict",
    		},
    		{
    			name: "register the same indexer body with different names, no conflicts",
    			// order of registration doesn't matter
    			entrypoints: map[string]frameworkruntime.PluginFactory{
    				"AddIndexer1": func(ctx context.Context, obj runtime.Object, handle framework.Handle) (framework.Plugin, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/dra/plugin/noderesources.go

    			break
    		}
    		logger.V(5).Info("Getting Node object failed, waiting", "err", err)
    		select {
    		case <-ctx.Done():
    			return
    		case <-time.After(time.Second):
    		}
    	}
    
    	// We could use an indexer on driver name, but that seems overkill.
    	informer := resourceinformers.NewFilteredResourceSliceInformer(c.kubeClient, resyncPeriod, nil, func(options *metav1.ListOptions) {
    		options.FieldSelector = "nodeName=" + node.Name
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 20:12:53 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    		if err != nil {
    			return nil, err
    		}
    		return objIndexFunc(seo)
    	}
    }
    
    func storeElementIndexers(indexers *cache.Indexers) cache.Indexers {
    	if indexers == nil {
    		return cache.Indexers{}
    	}
    	ret := cache.Indexers{}
    	for indexName, indexFunc := range *indexers {
    		ret[indexName] = storeElementIndexFunc(indexFunc)
    	}
    	return ret
    }
    
    // watchCache implements a Store interface.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  6. pkg/features/kube_features.go

    	// releases.
    	UserNamespacesPodSecurityStandards featuregate.Feature = "UserNamespacesPodSecurityStandards"
    
    	// owner: @ahutsunshine
    	// beta: v1.30
    	//
    	// Allows namespace indexer for namespace scope resources in apiserver cache to accelerate list operations.
    	StorageNamespaceIndex featuregate.Feature = "StorageNamespaceIndex"
    
    	// owner: @jsafrane
    	// kep: https://kep.k8s.io/1710
    	// alpha: v1.30
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/batch/v1/types.go

    type SuccessPolicyRule struct {
    	// succeededIndexes specifies the set of indexes
    	// which need to be contained in the actual set of the succeeded indexes for the Job.
    	// The list of indexes must be within 0 to ".spec.completions-1" and
    	// must not contain duplicates. At least one element is required.
    	// The indexes are represented as intervals separated by commas.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go

    	"completedIndexes":        "completedIndexes holds the completed indexes when .spec.completionMode = \"Indexed\" in a text format. The indexes are represented as decimal integers separated by commas. The numbers are listed in increasing order. Three or more consecutive numbers are compressed and represented by the first and last element of the series, separated by a hyphen. For example, if the completed indexes are 1, 3, 4, 5 and 7, they are represented as \"1,3-5,7\".",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/generated.proto

      // completedIndexes holds the completed indexes when .spec.completionMode =
      // "Indexed" in a text format. The indexes are represented as decimal integers
      // separated by commas. The numbers are listed in increasing order. Three or
      // more consecutive numbers are compressed and represented by the first and
      // last element of the series, separated by a hyphen.
      // For example, if the completed indexes are 1, 3, 4, 5 and 7, they are
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 29.1K bytes
    - Viewed (0)
  10. pkg/apis/batch/types.go

    type SuccessPolicyRule struct {
    	// succeededIndexes specifies the set of indexes
    	// which need to be contained in the actual set of the succeeded indexes for the Job.
    	// The list of indexes must be within 0 to ".spec.completions-1" and
    	// must not contain duplicates. At least one element is required.
    	// The indexes are represented as intervals separated by commas.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 12:01:28 UTC 2024
    - 33K bytes
    - Viewed (0)
Back to top