Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for indexName (0.19 sec)

  1. pkg/scheduler/util/assumecache/assume_cache.go

    func NewAssumeCache(logger klog.Logger, informer Informer, description, indexName string, indexFunc cache.IndexFunc) *AssumeCache {
    	c := &AssumeCache{
    		logger:      logger,
    		description: description,
    		indexFunc:   indexFunc,
    		indexName:   indexName,
    	}
    	indexers := cache.Indexers{}
    	if indexName != "" && indexFunc != nil {
    		indexers[indexName] = c.objInfoIndexFunc
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. schema/naming.go

    }
    
    // CheckerName generate checker name
    func (ns NamingStrategy) CheckerName(table, column string) string {
    	return ns.formatName("chk", table, column)
    }
    
    // IndexName generate index name
    func (ns NamingStrategy) IndexName(table, column string) string {
    	return ns.formatName("idx", table, ns.toDBName(column))
    }
    
    // UniqueName generate unique constraint name
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/metrics/metrics.go

    	})
    }
    
    // RecordListCacheMetrics notes various metrics of the cost to serve a LIST request
    func RecordListCacheMetrics(resourcePrefix, indexName string, numFetched, numReturned int) {
    	listCacheCount.WithLabelValues(resourcePrefix, indexName).Inc()
    	listCacheNumFetched.WithLabelValues(resourcePrefix, indexName).Add(float64(numFetched))
    	listCacheNumReturned.WithLabelValues(resourcePrefix).Add(float64(numReturned))
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 07:39:23 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/selection_predicate.go

    			result = append(result, MatchValue{IndexName: FieldIndex(field), Value: value})
    		} else if field == "metadata.namespace" {
    			// list pods in the namespace. i.e. /api/v1/namespaces/default/pods
    			if namespace, isNamespaceScope := isNamespaceScopedRequest(ctx); isNamespaceScope {
    				result = append(result, MatchValue{IndexName: FieldIndex(field), Value: namespace})
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. pkg/scheduler/util/assumecache/assume_cache_test.go

    	return newTestWithIndexer(t, "", nil)
    }
    
    func newTestWithIndexer(t *testing.T, indexName string, indexFunc cache.IndexFunc) (ktesting.TContext, *AssumeCache, *testInformer) {
    	tCtx := ktesting.Init(t)
    	informer := new(testInformer)
    	cache := NewAssumeCache(tCtx.Logger(), informer, "TestObject", indexName, indexFunc)
    	return tCtx, cache, informer
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    	}
    	if indexUsed != "" {
    		t.Errorf("Used index %q but expected none to be used", indexUsed)
    	}
    
    	// list by label index.
    	matchValues := []storage.MatchValue{
    		{IndexName: "l:label", Value: "value1"},
    		{IndexName: "f:spec.nodeName", Value: "node2"},
    	}
    	list, resourceVersion, indexUsed, err = store.WaitUntilFreshAndList(ctx, 5, matchValues)
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    	}
    }
    
    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.
    // However, it depends on the elements implementing runtime.Object 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)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    			expiredWatchers = append(expiredWatchers, watchers)
    		}
    	}
    	return expiredWatchers
    }
    
    type filterWithAttrsFunc func(key string, l labels.Set, f fields.Set) bool
    
    type indexedTriggerFunc struct {
    	indexName   string
    	indexerFunc storage.IndexerFunc
    }
    
    // Cacher is responsible for serving WATCH and LIST requests for a given
    // resource from its internal cache and updating its cache in the background
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    var Everything = SelectionPredicate{
    	Label: labels.Everything(),
    	Field: fields.Everything(),
    }
    
    // MatchValue defines a pair (`<index name>`, `<value for that index>`).
    type MatchValue struct {
    	IndexName string
    	Value     string
    }
    
    // Pass an UpdateFunc to Interface.GuaranteedUpdate to make an update
    // that is guaranteed to succeed.
    // See the comment for GuaranteedUpdate for more details.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  10. tests/migrate_test.go

    		}
    		assert.ElementsMatch(t, expected, indexes)
    	}
    
    	uniqueIndex := &migrator.Index{TableName: table, NameValue: DB.Config.NamingStrategy.IndexName(table, "name"), ColumnList: []string{"name"}, PrimaryKeyValue: sql.NullBool{Bool: false, Valid: true}, UniqueValue: sql.NullBool{Bool: true, Valid: true}}
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
Back to top