- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 106 for newController (0.31 sec)
-
pkg/kube/multicluster/secretcontroller.go
secrets kclient.Client[*corev1.Secret] configOverrides []func(*rest.Config) cs *ClusterStore meshWatcher mesh.Watcher handlers []handler } // NewController returns a new secret controller func NewController(kubeclientset kube.Client, namespace string, clusterID cluster.ID, meshWatcher mesh.Watcher, configOverrides ...func(*rest.Config), ) *Controller { informerClient := kubeclientset
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
EnableDynamicProvisioning: controllerContext.ComponentConfig.PersistentVolumeBinderController.VolumeConfiguration.EnableDynamicProvisioning, } volumeController, volumeControllerErr := persistentvolumecontroller.NewController(ctx, params) if volumeControllerErr != nil { return nil, true, fmt.Errorf("failed to construct persistentvolume controller: %v", volumeControllerErr) } go volumeController.Run(ctx) return nil, true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
volumetest "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util/hostutil" "k8s.io/utils/clock" ) func TestRunOnce(t *testing.T) { ctx := context.Background() mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() cadvisor := cadvisortest.NewMockInterface(mockCtrl) cadvisor.EXPECT().MachineInfo().Return(&cadvisorapi.MachineInfo{}, nil).AnyTimes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
maxConnectionAge time.Duration stateStore *state.Store healthController *health.Controller } type HealthEvent = health.HealthEvent // NewController create a controller which manages workload lifecycle and health status. func NewController(store model.ConfigStoreController, instanceID string, maxConnAge time.Duration) *Controller { if !features.WorkloadEntryAutoRegistration && !features.WorkloadEntryHealthChecks {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
w := &configMapWatcher{ client: client, namespace: namespace, name: name, configKey: configKey, valuesKey: valuesKey, } w.c = configmapwatcher.NewController(client, namespace, name, func(cm *v1.ConfigMap) { sidecarConfig, valuesConfig, err := readConfigMap(cm, configKey, valuesKey) if err != nil { log.Warnf("failed to read injection config from ConfigMap: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller_test.go
} for _, test := range tests { t.Run(test.name, func(t *testing.T) { client := fake.NewSimpleClientset(test.clientObjects...) limiter := rate.NewLimiter(rate.Every(throttlePeriod), 1) controller := newController(client, testingclock.NewFakeClock(now), limiter) if test.existingConfigMap != nil { controller.configMapCache.Add(test.existingConfigMap) } if err := controller.syncConfigMap(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 19 17:33:34 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller_test.go
SchemaResolver: resolver.NewDefinitionsSchemaResolver(openapi.GetOpenAPIDefinitions, scheme.Scheme), RestMapper: testrestmapper.TestOnlyStaticRESTMapper(scheme.Scheme), } controller, err := NewController( informerFactory.Admissionregistration().V1().ValidatingAdmissionPolicies(), client.AdmissionregistrationV1().ValidatingAdmissionPolicies(), typeChecker, ) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 8.2K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
clock clock.Clock workers *status.Controller StaleInterval time.Duration cmInformer cache.SharedIndexInformer cmHandle cache.ResourceEventHandlerRegistration } func NewController(restConfig *rest.Config, namespace string, cs model.ConfigStore, m *status.Manager) *Controller { c := &Controller{ CurrentState: make(map[status.Resource]map[string]Progress), ObservationTime: make(map[string]time.Time),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller_test.go
podInformer := informerFactory.Core().V1().Pods() pvcInformer := informerFactory.Core().V1().PersistentVolumeClaims() c, err := NewController(ctx, fakeKubeClient, podInformer, pvcInformer) if err != nil { t.Fatalf("error creating ephemeral controller : %v", err) } ec, _ := c.(*ephemeralController) // Ensure informers are up-to-date.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0)