- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 138 for AsSelector (0.27 sec)
-
pkg/kubelet/util/manager/watch_based_manager.go
return &cacheStore{store, sync.Mutex{}, false} } func (c *objectCache) newReflectorLocked(namespace, name string) *objectCacheItem { fieldSelector := fields.Set{"metadata.name": name}.AsSelector().String() listFunc := func(options metav1.ListOptions) (runtime.Object, error) { options.FieldSelector = fieldSelector return c.listObject(namespace, options) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-core/src/main/kotlin/org/gradle/internal/declarativedsl/parsing/GrammarToTree.kt
DOT -> isSelector = true SAFE_ACCESS -> { collectingFailure(tree.unsupported(node, it, UnsupportedLanguageFeature.SafeNavigation)) } ERROR_ELEMENT -> collectingFailure(tree.parsingError(node, it)) else -> { val isEffectiveSelector = isSelector && tokenType != ERROR_ELEMENT
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 22:06:18 UTC 2024 - 31.2K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
// AffinityTerm is a processed version of v1.PodAffinityTerm. type AffinityTerm struct { Namespaces sets.Set[string] Selector labels.Selector TopologyKey string NamespaceSelector labels.Selector } // Matches returns true if the pod matches the label selector and namespaces or namespace selector. func (at *AffinityTerm) Matches(pod *v1.Pod, nsLabels labels.Set) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/StreamingResolutionResultBuilderTest.groovy
} private DependencyGraphEdge dep(DependencyGraphSelector selector, Long fromVariant, Throwable failure) { def edge = Stub(DependencyGraphEdge) _ * edge.selector >> selector _ * edge.requested >> selector.requested _ * edge.reason >> requested() _ * edge.failure >> new ModuleVersionResolveException(selector.requested, failure) _ * edge.fromVariant >> fromVariant
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:29:40 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/inet/SocketConnection.java
private final Selector selector; private final ByteBuffer buffer; private final SocketChannel socket; private final byte[] readBuffer = new byte[1]; public SocketInputStream(SocketChannel socket) throws IOException { this.socket = socket; selector = Selector.open(); socket.register(selector, SelectionKey.OP_READ);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 11.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/EdgeState.java
*/ @Nullable ComponentState getTargetComponent() { if (!selector.isResolved() || selector.getFailure() != null) { return null; } return getSelectedComponent(); } @Override public SelectorState getSelector() { return selector; } @Override public boolean isTransitive() { return isTransitive;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 18.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
Resolution: networking.ServiceEntry_DNS, }, } // ServiceEntry with a selector var selector = &config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.ServiceEntry, Name: "selector", Namespace: "selector", CreationTimestamp: GlobalTime, }, Spec: &networking.ServiceEntry{ Hosts: []string{"selector.com"}, Ports: []*networking.ServicePort{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pkg/apis/core/v1/helper/helpers.go
return nil, err } selector = selector.Add(*r) } return selector, nil } // MatchTopologySelectorTerms checks whether given labels match topology selector terms in ORed; // nil or empty term matches no objects; while empty term list matches all objects. func MatchTopologySelectorTerms(topologySelectorTerms []v1.TopologySelectorTerm, lbls labels.Set) bool { if len(topologySelectorTerms) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 23:03:54 UTC 2024 - 11.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/DependencyGraphBuilder.java
dependency.computeSelector(); } SelectorState selector = dependency.getSelector(); ModuleResolveState module = selector.getTargetModule(); if (selector.canResolve() && module.getSelectors().size() > 0) { // Have an unprocessed/new selector for this module. Need to re-select the target version (if there are any selectors that can be used).
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 34.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ModuleResolveState.java
); } void addSelector(SelectorState selector, boolean deferSelection) { selectors.add(selector, deferSelection); mergedConstraintAttributes = appendAttributes(mergedConstraintAttributes, selector); if (overriddenSelection) { assert selected != null : "An overridden module cannot have selected == null"; selector.overrideSelection(selected); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 18.7K bytes - Viewed (0)