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