- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 45 for newController (0.22 sec)
-
pkg/kubelet/metrics/collectors/resource_metrics_test.go
"container_swap_usage_bytes", "container_start_time_seconds", "pod_cpu_usage_seconds_total", "pod_memory_working_set_bytes", "pod_swap_usage_bytes", } mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() tests := []struct { name string summary *statsapi.Summary summaryErr error expectedMetrics string }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.3K bytes - Viewed (1) -
subprojects/core/src/main/java/org/gradle/internal/build/DefaultBuildLifecycleController.java
this.buildModelLifecycleListener = buildModelLifecycleListener; this.toolingModelControllerFactory = toolingModelControllerFactory; this.state = controllerFactory.newController(Describables.of("state of", targetBuild().getDisplayName()), State.Configure); } @Override public GradleInternal getGradle() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 11:17:11 UTC 2024 - 16.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
if !configCluster { options.SyncTimeout = features.RemoteClusterTimeout } log.Infof("Initializing Kubernetes service registry %q", options.ClusterID) options.ConfigCluster = configCluster kubeRegistry := NewController(client, options) kubeController := &kubeController{ MeshServiceController: opts.MeshServiceController, Controller: kubeRegistry, stop: stop, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
PodInformer coreinformers.PodInformer NodeInformer coreinformers.NodeInformer EnableDynamicProvisioning bool } // NewController creates a new PersistentVolume controller func NewController(ctx context.Context, p ControllerParameters) (*PersistentVolumeController, error) { eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller_test.go
env := &testEnv{ Interface: fake.NewSimpleClientset(), t: t, } factory := externalversions.NewSharedInformerFactoryWithOptions( env.Interface, 30*time.Second) c := NewController(factory.Apiextensions().V1().CustomResourceDefinitions()) ctx, cancel := context.WithCancel(context.Background()) factory.Start(ctx.Done()) factory.WaitForCacheSync(ctx.Done()) env.mux = http.NewServeMux()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 22 17:10:53 UTC 2023 - 12.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)