- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for newController (0.31 sec)
-
pkg/registry/core/replicationcontroller/strategy_test.go
}, } StatusStrategy.PrepareForUpdate(ctx, newController, oldController) if newController.Status.Replicas != 3 { t.Errorf("Replication controller status updates should allow change of replicas: %v", newController.Status.Replicas) } if newController.Spec.Replicas != 3 { t.Errorf("PrepareForUpdate should have preferred spec") } errs := StatusStrategy.ValidateUpdate(ctx, newController, oldController) if len(errs) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 13 16:56:29 UTC 2019 - 6.9K bytes - Viewed (0) -
pilot/pkg/config/memory/controller_test.go
store := memory.Make(collections.Mocks) ctl := memory.NewController(store) // Note that the operations must go through the controller since the store does not trigger back events mock.CheckCacheEvents(ctl, ctl, TestNamespace, 5, t) } func TestControllerCacheFreshness(t *testing.T) { store := memory.Make(collections.Mocks) ctl := memory.NewController(store) mock.CheckCacheFreshness(ctl, TestNamespace, t) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 18 15:37:45 UTC 2021 - 1.8K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller_test.go
return true } func TestListInvalidGroupVersionKind(t *testing.T) { g := NewWithT(t) clientSet := kube.NewFakeClient() clientSet.RunAndWait(test.NewStop(t)) store := memory.NewController(memory.Make(collections.All)) controller := NewController(clientSet, store, AlwaysReady, nil, controller.Options{}) typ := config.GroupVersionKind{Kind: "wrong-kind"} c := controller.List(typ, "ns1") g.Expect(c).To(HaveLen(0)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 16:47:06 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/strategy.go
func (rcStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newController := obj.(*api.ReplicationController) oldController := old.(*api.ReplicationController) // update is not allowed to set status newController.Status = oldController.Status pod.DropDisabledTemplateFields(newController.Spec.Template, oldController.Spec.Template)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 16 21:06:10 UTC 2022 - 9.7K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
namespaceLister listers.NamespaceLister namespaceSynced cache.InformerSynced systemNamespaces []string interval time.Duration } // NewController creates a new Controller to ensure system namespaces exist. func NewController(systemNamespaces []string, clientset kubernetes.Interface, namespaceInformer coreinformers.NamespaceInformer) *Controller { interval := 1 * time.Minute return &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
// or disabled. creationRatelimiter *rate.Limiter clock clock.Clock } // NewController returns a Controller struct. func NewController(cs kubernetes.Interface) *Controller { return newController(cs, clock.RealClock{}, rate.NewLimiter(rate.Every(30*time.Minute), 1)) } func newController(cs kubernetes.Interface, cl clock.Clock, limiter *rate.Limiter) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/discovery.go
} } func startEndpointSliceController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { go endpointslicecontroller.NewController( ctx, controllerContext.InformerFactory.Core().V1().Pods(), controllerContext.InformerFactory.Core().V1().Services(), controllerContext.InformerFactory.Core().V1().Nodes(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 3.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/controller.go
type Controller struct { stateStore *state.Store // healthCondition is a fifo queue used for updating health check status healthCondition controllers.Queue } // NewController returns a new Controller instance. func NewController(stateStore *state.Store, maxRetries int) *Controller { c := &Controller{ stateStore: stateStore, } c.healthCondition = controllers.NewQueue("healthcheck",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
pods kclient.Client[*corev1.Pod] queue controllers.Queue events *atomic.Int32 } // NewController creates a controller instance. A controller should typically take in a kube.Client, // and optionally whatever other configuration is needed. When a large number of options are needed, // prefer a struct as input. func NewController(cl kube.Client) *Controller { c := &Controller{events: atomic.NewInt32(0)}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
pkg/kube/watcher/configmapwatcher/configmapwatcher.go
queue controllers.Queue configMapNamespace string configMapName string callback func(*v1.ConfigMap) hasSynced atomic.Bool } // NewController returns a new ConfigMap watcher controller. func NewController(client kube.Client, namespace, name string, callback func(*v1.ConfigMap)) *Controller { c := &Controller{ configMapNamespace: namespace, configMapName: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 07:11:52 UTC 2023 - 2.8K bytes - Viewed (0)