Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 106 for newController (0.26 sec)

  1. pkg/kubelet/apis/podresources/server_v1alpha1_test.go

    	containerName := "container-name"
    
    	devs := []*podresourcesv1.ContainerDevices{
    		{
    			ResourceName: "resource",
    			DeviceIds:    []string{"dev0", "dev1"},
    		},
    	}
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	for _, tc := range []struct {
    		desc             string
    		pods             []*v1.Pod
    		devices          []*podresourcesv1.ContainerDevices
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/api/internal/project/ProjectLifecycleController.java

        }
    
        public ProjectLifecycleController(DisplayName displayName, StateTransitionControllerFactory factory, ServiceRegistry buildServices) {
            this.buildServices = buildServices;
            controller = factory.newController(displayName, State.NotCreated);
        }
    
        public boolean isCreated() {
            return project != null;
        }
    
        public void createMutableModel(
            DefaultProjectDescriptor descriptor,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go

    				openapiController := openapicontroller.NewController(s.Informers.Apiextensions().V1().CustomResourceDefinitions())
    				go openapiController.Run(s.GenericAPIServer.StaticOpenAPISpec, s.GenericAPIServer.OpenAPIVersionedService, context.StopCh)
    			}
    
    			if s.GenericAPIServer.OpenAPIV3VersionedService != nil {
    				openapiv3Controller := openapiv3controller.NewController(s.Informers.Apiextensions().V1().CustomResourceDefinitions())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 14:31:43 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  4. pkg/webhooks/validation/controller/controller_test.go

    	c := kube.NewFakeClient()
    	revision := "default"
    	ns := "default"
    	watcher := keycertbundle.NewWatcher()
    	watcher.SetAndNotify(nil, nil, caBundle0)
    	control := newController(Options{
    		WatchedNamespace: ns,
    		CABundleWatcher:  watcher,
    		Revision:         revision,
    		ServiceName:      "istiod",
    	}, c)
    	stop := test.NewStop(t)
    	c.RunAndWait(stop)
    	go control.Run(stop)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 05 03:21:04 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. subprojects/core/src/main/java/org/gradle/internal/buildtree/DefaultBuildTreeLifecycleController.java

            this.workController = workController;
            this.modelCreator = modelCreator;
            this.finishExecutor = finishExecutor;
            this.state = controllerFactory.newController(Describables.of("build tree state"), State.NotStarted);
            this.startParameter = startParameter;
            this.buildModelParameters = buildModelParameters;
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Feb 08 07:46:55 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. pkg/webhooks/validation/controller/controller.go

    ) *Controller {
    	o := Options{
    		WatchedNamespace: ns,
    		CABundleWatcher:  caBundleWatcher,
    		Revision:         revision,
    		ServiceName:      "istiod",
    	}
    	return newController(o, client)
    }
    
    func newController(o Options, client kube.Client) *Controller {
    	c := &Controller{
    		o:      o,
    		client: client,
    	}
    
    	c.queue = controllers.NewQueue("validation",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 16:52:19 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  7. pkg/controller/volume/ephemeral/controller.go

    	podIndexer cache.Indexer
    
    	// recorder is used to record events in the API server
    	recorder record.EventRecorder
    
    	queue workqueue.TypedRateLimitingInterface[string]
    }
    
    // NewController creates an ephemeral volume controller.
    func NewController(
    	ctx context.Context,
    	kubeClient clientset.Interface,
    	podInformer coreinformers.PodInformer,
    	pvcInformer coreinformers.PersistentVolumeClaimInformer) (Controller, error) {
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. pkg/kubelet/apis/podresources/server_v1_test.go

    	podName := "pod-name"
    	podNamespace := "pod-namespace"
    	podUID := types.UID("pod-uid")
    	containerName := "container-name"
    	numaID := int64(1)
    
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    
    	devs := []*podresourcesapi.ContainerDevices{
    		{
    			ResourceName: "resource",
    			DeviceIds:    []string{"dev0", "dev1"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  9. pkg/kubelet/pleg/generic_test.go

    		events = append(events, event)
    
    	}
    	return pods, statuses, events
    }
    
    func TestRelistWithCache(t *testing.T) {
    	ctx := context.Background()
    	mockCtrl := gomock.NewController(t)
    	defer mockCtrl.Finish()
    	runtimeMock := containertest.NewMockRuntime(mockCtrl)
    
    	pleg := newTestGenericPLEGWithRuntimeMock(runtimeMock)
    	ch := pleg.Watch()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    			if err != nil {
    				return nil, "", err
    			}
    		}
    		return mergeSpec, generateCRDHash(crd), nil
    	}, &s.crdCache)
    	return &s
    }
    
    // NewController creates a new Controller with input CustomResourceDefinition informer
    func NewController(crdInformer informers.CustomResourceDefinitionInformer) *Controller {
    	c := &Controller{
    		crdLister:  crdInformer.Lister(),
    		crdsSynced: crdInformer.Informer().HasSynced,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
Back to top