Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 106 for newController (0.23 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    			return fmt.Errorf("expected equal objects: %v", cmp.Diff(obj, reconciledObj))
    		case <-ctx.Done():
    			return fmt.Errorf("context done before reconcile: %w", ctx.Err())
    		}
    	}
    
    	myController := generic.NewController(
    		generic.NewInformer[*unstructured.Unstructured](informer),
    		reconciler,
    		generic.ControllerOptions{},
    	)
    
    	verifyNoMoreEvents = func() bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. pilot/pkg/config/kube/gateway/controller.go

    	statusController *atomic.Pointer[status.Controller]
    
    	waitForCRD func(class schema.GroupVersionResource, stop <-chan struct{}) bool
    }
    
    var _ model.GatewayController = &Controller{}
    
    func NewController(
    	kc kube.Client,
    	c model.ConfigStoreController,
    	waitForCRD func(class schema.GroupVersionResource, stop <-chan struct{}) bool,
    	credsController credentials.MulticlusterController,
    	options controller.Options,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_gc_test.go

    	}
    	podStateProvider.removed["012"] = struct{}{}
    	podStateProvider.removed["789"] = struct{}{}
    	podStateProvider.removed["654"] = struct{}{}
    
    	ctrl := gomock.NewController(t)
    	defer ctrl.Finish()
    
    	fakeOS.ReadDirFn = func(string) ([]os.DirEntry, error) {
    		var dirEntries []os.DirEntry
    		for _, file := range files {
    			mockDE := containertest.NewMockDirEntry(ctrl)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  4. pkg/controlplane/instance.go

    		s.ControlPlane.GenericAPIServer.AddPostStartHookOrDie("start-kubernetes-service-cidr-controller", func(hookContext genericapiserver.PostStartHookContext) error {
    			controller := defaultservicecidr.NewController(
    				c.Extra.ServiceIPRange,
    				c.Extra.SecondaryServiceIPRange,
    				client,
    			)
    			// The default serviceCIDR must exist before the apiserver is healthy
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. pkg/controller/resourceclaim/controller_test.go

    			claimInformer := informerFactory.Resource().V1alpha2().ResourceClaims()
    			templateInformer := informerFactory.Resource().V1alpha2().ResourceClaimTemplates()
    
    			ec, err := NewController(klog.FromContext(ctx), fakeKubeClient, podInformer, podSchedulingInformer, claimInformer, templateInformer)
    			if err != nil {
    				t.Fatalf("error creating ephemeral controller : %v", err)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 08:56:16 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  6. pkg/controller/resourceclaim/controller.go

    	// that a ReservedFor entry needs to be removed.
    	deletedObjects *uidCache
    }
    
    const (
    	claimKeyPrefix = "claim:"
    	podKeyPrefix   = "pod:"
    )
    
    // NewController creates a ResourceClaim controller.
    func NewController(
    	logger klog.Logger,
    	kubeClient clientset.Interface,
    	podInformer v1informers.PodInformer,
    	podSchedulingInformer resourcev1alpha2informers.PodSchedulingContextInformer,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/controller.go

    	podsClient kclient.Client[*v1.Pod]
    
    	configCluster bool
    
    	networksHandlerRegistration *mesh.WatcherHandlerRegistration
    }
    
    // NewController creates a new Kubernetes controller
    // Created by bootstrap and multicluster (see multicluster.Controller).
    func NewController(kubeClient kubelib.Client, options Options) *Controller {
    	c := &Controller{
    		opts:                     options,
    		client:                   kubeClient,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  8. pilot/pkg/bootstrap/server.go

    	e := model.NewEnvironment()
    	e.DomainSuffix = args.RegistryOptions.KubeOptions.DomainSuffix
    	e.SetLedger(buildLedger(args.RegistryOptions))
    
    	ac := aggregate.NewController(aggregate.Options{
    		MeshHolder: e,
    	})
    	e.ServiceDiscovery = ac
    
    	s := &Server{
    		clusterID:               getClusterID(args),
    		environment:             e,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    	configController := memory.NewController(store)
    
    	stop := test.NewStop(t)
    	go configController.Run(stop)
    	fx := xdsfake.NewFakeXDS()
    	go func() {
    		for {
    			select {
    			case <-stop:
    				return
    			case <-fx.Events: // drain
    			}
    		}
    	}()
    
    	meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig())
    	serviceController := NewController(configController, fx, meshcfg)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller_test.go

    		InformersStarted:          alwaysStarted,
    		InformerFactory:           informerFactory,
    	}
    	_, ctx := ktesting.NewTestContext(t)
    	qc, err := NewController(ctx, resourceQuotaControllerOptions)
    	if err != nil {
    		t.Fatal(err)
    	}
    	stop := make(chan struct{})
    	informerFactory.Start(stop)
    	return quotaController{qc, stop}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 16:29:33 UTC 2023
    - 42.6K bytes
    - Viewed (0)
Back to top