Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for MatchNode (0.12 sec)

  1. pkg/registry/core/node/strategy.go

    	if !ok {
    		return nil, nil, fmt.Errorf("not a node")
    	}
    	return labels.Set(nodeObj.ObjectMeta.Labels), NodeToSelectableFields(nodeObj), nil
    }
    
    // MatchNode returns a generic matcher for a given label and field selector.
    func MatchNode(label labels.Selector, field fields.Selector) pkgstorage.SelectionPredicate {
    	return pkgstorage.SelectionPredicate{
    		Label:    label,
    		Field:    field,
    		GetAttrs: GetAttrs,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. pkg/registry/core/node/storage/storage.go

    	store := &genericregistry.Store{
    		NewFunc:                   func() runtime.Object { return &api.Node{} },
    		NewListFunc:               func() runtime.Object { return &api.NodeList{} },
    		PredicateFunc:             node.MatchNode,
    		DefaultQualifiedResource:  api.Resource("nodes"),
    		SingularQualifiedResource: api.Resource("node"),
    
    		CreateStrategy:      node.Strategy,
    		UpdateStrategy:      node.Strategy,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 20:38:11 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. pkg/registry/core/node/strategy_test.go

    		true: {
    			{"metadata.name": "foo"},
    		},
    		false: {
    			{"foo": "bar"},
    		},
    	}
    
    	for expectedResult, fieldSet := range testFieldMap {
    		for _, field := range fieldSet {
    			m := MatchNode(labels.Everything(), field.AsSelector())
    			_, matchesSingle := m.MatchesSingle()
    			if e, a := expectedResult, matchesSingle; e != a {
    				t.Errorf("%+v: expected %v, got %v", fieldSet, e, a)
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/patchnode/patchnode.go

    func AnnotateCRISocket(client clientset.Interface, nodeName string, criSocket string) error {
    
    	klog.V(1).Infof("[patchnode] Uploading the CRI Socket information %q to the Node API object %q as an annotation\n", criSocket, nodeName)
    
    	return apiclient.PatchNode(client, nodeName, func(n *v1.Node) {
    		annotateNodeWithCRISocket(n, criSocket)
    	})
    }
    
    func annotateNodeWithCRISocket(n *v1.Node, criSocket string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 17 14:40:46 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  5. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/WatchMode.java

     * limitations under the License.
     */
    
    package org.gradle.internal.watch.registry;
    
    import org.slf4j.Logger;
    import org.slf4j.helpers.NOPLogger;
    
    public enum WatchMode {
        ENABLED(true, "enabled") {
            @Override
            public Logger loggerForWarnings(Logger currentLogger) {
                return currentLogger;
            }
        },
        DEFAULT(true, "enabled if available") {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:38:01 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/test/groovy/org/gradle/tooling/internal/provider/FileSystemWatchingBuildActionRunnerTest.groovy

            WatchMode.DEFAULT  | VfsLogging.NORMAL  | WatchLogging.DEBUG  | true
            WatchMode.ENABLED  | VfsLogging.VERBOSE | WatchLogging.NORMAL | true
            WatchMode.ENABLED  | VfsLogging.NORMAL  | WatchLogging.NORMAL | true
            WatchMode.ENABLED  | VfsLogging.VERBOSE | WatchLogging.DEBUG  | true
            WatchMode.ENABLED  | VfsLogging.NORMAL  | WatchLogging.DEBUG  | true
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  7. platforms/core-execution/file-watching/src/integTest/groovy/org/gradle/internal/watch/EnableFileSystemWatchingIntegrationTest.groovy

                gradle.startParameter.setWatchFileSystemMode(${WatchMode.name}.${watchMode.name()})
            """
    
            when:
            run("assemble", "--info")
            then:
            outputContains(ENABLED_IF_AVAILABLE_MESSAGE)
            outputContains(ACTIVE_MESSAGE)
    
            where:
            watchMode << WatchMode.values()
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 03 13:50:33 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingNotSupportedVirtualFileSystem.java

        }
    
        @Override
        public boolean afterBuildStarted(
            WatchMode watchMode,
            VfsLogging vfsLogging,
            WatchLogging watchLogging,
            BuildOperationRunner buildOperationRunner
        ) {
            if (watchMode == WatchMode.ENABLED) {
                LOGGER.warn("Watching the file system is not supported.");
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 17:41:07 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/vfs/impl/WatchingNotSupportedVirtualFileSystemTest.groovy

            watchingNotSupportedVfs.beforeBuildFinished(watchMode, VfsLogging.NORMAL, WatchLogging.NORMAL, buildOperationRunner, Integer.MAX_VALUE)
            watchingNotSupportedVfs.afterBuildFinished()
            then:
            watchingNotSupportedVfs.root == emptySnapshotHierarchy
    
            where:
            watchMode << WatchMode.values().toList()
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 22:18:26 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  10. subprojects/core/src/main/java/org/gradle/api/internal/StartParameterInternal.java

    import org.gradle.internal.buildtree.BuildModelParameters;
    import org.gradle.internal.watch.registry.WatchMode;
    
    import javax.annotation.Nullable;
    import java.io.File;
    import java.time.Duration;
    
    public class StartParameterInternal extends StartParameter {
        private WatchMode watchFileSystemMode = WatchMode.DEFAULT;
        private boolean watchFileSystemDebugLogging;
        private boolean vfsVerboseLogging;
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 29 08:08:36 UTC 2023
    - 8.1K bytes
    - Viewed (0)
Back to top