- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 56 for indexName (0.23 sec)
-
schema/naming_test.go
} } } func TestNamingStrategy(t *testing.T) { ns := NamingStrategy{ TablePrefix: "public.", SingularTable: true, NameReplacer: strings.NewReplacer("CID", "Cid"), } idxName := ns.IndexName("public.table", "name") if idxName != "idx_public_table_name" { t.Errorf("invalid index name generated, got %v", idxName) } chkName := ns.CheckerName("public.table", "name")
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue May 30 02:00:48 UTC 2023 - 7K 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) -
schema/index.go
"The composite tag of %s.%s cannot be empty", field.Schema.Name, field.Name) return } subName = composite } name = field.Schema.namer.IndexName( field.Schema.Table, subName) } if (k == "UNIQUEINDEX") || settings["UNIQUE"] != "" { settings["CLASS"] = "UNIQUE" } priority, err := strconv.Atoi(settings["PRIORITY"])
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Sun Feb 04 07:49:19 UTC 2024 - 3.7K 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) -
src/test/java/org/codelibs/fess/suggest/SuggesterTest.java
} @Test public void test_indexFromDocumentReader() throws Exception { Client client = runner.client(); int num = 10000; String indexName = "test"; BulkRequestBuilder bulkRequestBuilder = client.prepareBulk(); for (int i = 0; i < num; i++) { Map<String, Object> source = Collections.singletonMap("content", "test");
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 37K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
} // validateIndexers will check the prefix of indexers. func validateIndexers(indexers *cache.Indexers) error { if indexers == nil { return nil } for indexName := range *indexers { if len(indexName) <= 2 || (indexName[:2] != "l:" && indexName[:2] != "f:") { return fmt.Errorf("index must prefix with \"l:\" or \"f:\"") } } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K 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)