- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for indexName (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)