Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for Indexer (0.22 sec)

  1. 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)
  2. 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)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// IndexerFuncs is used for optimizing amount of watchers that
    	// needs to process an incoming event.
    	IndexerFuncs storage.IndexerFuncs
    
    	// Indexers is used to accelerate the list operation, falls back to regular list
    	// operation if no indexer found.
    	Indexers *cache.Indexers
    
    	// NewFunc is a function that creates new empty object storing a object of type Type.
    	NewFunc func() runtime.Object
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller_test.go

    		},
    		"indexed job start": {
    			parallelism:            2,
    			completions:            5,
    			backoffLimit:           6,
    			completionMode:         batch.IndexedCompletion,
    			expectedCreations:      2,
    			expectedActive:         2,
    			expectedCreatedIndexes: sets.New(0, 1),
    			expectedReady:          ptr.To[int32](0),
    		},
    		"indexed job with some pods deleted, podReplacementPolicy Failed": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller.go

    }
    
    // activePodsForRemoval returns Pods that should be removed because there
    // are too many pods running or, if this is an indexed job, there are repeated
    // indexes or invalid indexes or some pods don't have indexes.
    // Sorts candidate pods in the order such that not-ready < ready, unscheduled
    // < scheduled, and pending < running. This ensures that we delete pods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/ssa/_gen/PPC64.rules

    // Rules for MOV* or FMOV* ops determine when indexed (MOV*loadidx or MOV*storeidx)
    // or non-indexed (MOV*load or MOV*store) should be used. Indexed instructions
    // require an extra instruction and register to load the index so non-indexed is preferred.
    // Indexed ops generate indexed load or store instructions for all GOPPC64 values.
    // Non-indexed ops generate DS-form loads and stores when the offset fits in 16 bits,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    func TestValidateIndexers(t *testing.T) {
    	testcases := []struct {
    		name          string
    		indexers      *cache.Indexers
    		expectedError bool
    	}{
    		{
    			name:          "nil indexers",
    			indexers:      nil,
    			expectedError: false,
    		},
    		{
    			name: "normal indexers",
    			indexers: &cache.Indexers{
    				"f:spec.nodeName":            emptyIndexFunc,
    				"l:controller-revision-hash": emptyIndexFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/ssa/debug.go

    type FuncDebug struct {
    	// Slots is all the slots used in the debug info, indexed by their SlotID.
    	Slots []LocalSlot
    	// The user variables, indexed by VarID.
    	Vars []*ir.Name
    	// The slots that make up each variable, indexed by VarID.
    	VarSlots [][]SlotID
    	// The location list data, indexed by VarID. Must be processed by PutLocationList.
    	LocationLists [][]byte
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 58.4K bytes
    - Viewed (0)
  9. cmd/storage-interface.go

    	// Read all.
    	ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error)
    	GetDiskLoc() (poolIdx, setIdx, diskIdx int) // Retrieve location indexes.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc

    // function.
    llvm::SmallSet<int, 4> GetResizedTensorListIndexes(
        func::FuncOp func, const llvm::SmallSet<int, 4> &tensor_list_args) {
      // `indexes` stores the argument index of tensorlists which size may get
      // updated in the function.
      llvm::SmallSet<int, 4> indexes;
      for (BlockArgument &arg : func.getArguments()) {
        if (tensor_list_args.contains(arg.getArgNumber())) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 20:00:43 UTC 2024
    - 70.7K bytes
    - Viewed (0)
Back to top