Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for registered_ (1.14 sec)

  1. pkg/scheduler/framework/runtime/framework.go

    				continue
    			}
    
    			// if this plugin is already registered via MultiPoint, then this is
    			// a double registration and an error in the config.
    			if multiPointEnabled.has(ep.Name) {
    				return fmt.Errorf("plugin %q already registered as %q", ep.Name, pluginType.Name())
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue.go

    	moveRequestCycle int64
    
    	// preEnqueuePluginMap is keyed with profile name, valued with registered preEnqueue plugins.
    	preEnqueuePluginMap map[string][]framework.PreEnqueuePlugin
    	// queueingHintMap is keyed with profile name, valued with registered queueing hint functions.
    	queueingHintMap QueueingHintMapPerProfile
    
    	// closed indicates that the queue is closed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    // Here is the brief description of some of the arguments to the function below.
    //
    //	apiRouter - http.Handler with the relevant API endPoint (API endPoint under test) registered.
    //	anonReq   - unsigned *http.Request to invoke the handler's response for anonymous requests.
    //	policyFunc    - function to return bucketPolicy statement which would permit the anonymous request to be served.
    //
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/devicemanager/manager_test.go

    			require.Equal(t, resourceCapacity.Value(), resourceAllocatable.Value(), "capacity should equal to allocatable")
    			require.Equal(t, int64(1), resourceAllocatable.Value(), "Devices of plugin previously registered should be removed.")
    			p2.Stop()
    			p3.Stop()
    			cleanup(t, m, p1)
    		}
    	}
    }
    
    // Tests that the device plugin manager correctly handles registration and re-registration by
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  5. pkg/kubelet/server/server_test.go

    	// Ideally, these would move to registered web services and this list would get shorter
    	expectedPaths := []string{"/healthz", "/metrics", "/metrics/cadvisor"}
    	for _, expectedPath := range expectedPaths {
    		if _, expected := expectedCases["GET:"+expectedPath]; !expected {
    			t.Errorf("Expected registered handle path %s was missing", expectedPath)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/service/DefaultServiceRegistry.java

     * be registered as a listener of that type. Alternatively, service implementations can be annotated with {@link org.gradle.internal.service.scopes.ListenerService} to indicate that the should be
     * registered as a listener.</p>
     */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:40 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  7. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java

         * When a node exits the graph, its constraints need to be cleaned up.
         * This means:
         * * Rescheduling any deferred selection impacted by a constraint coming from this node
         * * Making sure we no longer are registered as pending interest on nodes pointed by constraints
         */
        private void cleanupConstraints() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 14:19:34 UTC 2024
    - 58.9K bytes
    - Viewed (0)
  8. src/testing/testing.go

    //	    }
    //	  })
    //	}
    //
    // A fuzz test maintains a seed corpus, or a set of inputs which are run by
    // default, and can seed input generation. Seed inputs may be registered by
    // calling (*F).Add or by storing files in the directory testdata/fuzz/<Name>
    // (where <Name> is the name of the fuzz test) within the package containing
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  9. src/runtime/traceback.go

    	return u.frame.pc
    }
    
    // cgoCallers populates pcBuf with the cgo callers of the current frame using
    // the registered cgo unwinder. It returns the number of PCs written to pcBuf.
    // If the current frame is not a cgo frame or if there's no registered cgo
    // unwinder, it returns 0.
    func (u *unwinder) cgoCallers(pcBuf []uintptr) int {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. src/net/http/transport.go

    // protocol were not registered.
    func (t *Transport) RegisterProtocol(scheme string, rt RoundTripper) {
    	t.altMu.Lock()
    	defer t.altMu.Unlock()
    	oldMap, _ := t.altProto.Load().(map[string]RoundTripper)
    	if _, exists := oldMap[scheme]; exists {
    		panic("protocol " + scheme + " already registered")
    	}
    	newMap := make(map[string]RoundTripper)
    	for k, v := range oldMap {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
Back to top