Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for indexName (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top