- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 103 for newController (0.33 sec)
-
cmd/kube-controller-manager/app/networking.go
features.MultiCIDRServiceAllocator, }} } func startServiceCIDRsController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { go servicecidrs.NewController( ctx, controllerContext.InformerFactory.Networking().V1alpha1().ServiceCIDRs(), controllerContext.InformerFactory.Networking().V1alpha1().IPAddresses(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller_test.go
k8stesting "k8s.io/client-go/testing" "k8s.io/client-go/tools/record" "k8s.io/utils/ptr" ) const ( defaultIPv4CIDR = "10.16.0.0/16" defaultIPv6CIDR = "2001:db8::/64" ) func newController(t *testing.T, objects []*networkingapiv1alpha1.ServiceCIDR) (*fake.Clientset, *Controller) { client := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 14 23:31:58 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
controllerName = "endpointslice-controller.k8s.io" // topologyQueueItemKey is the key for all items in the topologyQueue. topologyQueueItemKey = "topologyQueueItemKey" ) // NewController creates and initializes a new Controller func NewController(ctx context.Context, podInformer coreinformers.PodInformer, serviceInformer coreinformers.ServiceInformer, nodeInformer coreinformers.NodeInformer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
type endpointSliceController struct { *Controller endpointSliceStore cache.Store nodeStore cache.Store podStore cache.Store serviceStore cache.Store } func newController(t *testing.T, nodeNames []string, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceController) { client := fake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/model/StateTransitionControllerFactory.java
this.workerLeaseService = workerLeaseService; } public <T extends StateTransitionController.State> StateTransitionController<T> newController(DisplayName displayName, T initialState) { return new StateTransitionController<>(displayName, initialState, workerLeaseService.newResource()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.4K bytes - Viewed (0) -
cmd/kube-controller-manager/app/validatingadmissionpolicystatus.go
typeChecker := &pluginvalidatingadmissionpolicy.TypeChecker{ SchemaResolver: schemaResolver, RestMapper: controllerContext.RESTMapper, } c, err := validatingadmissionpolicystatus.NewController( controllerContext.InformerFactory.Admissionregistration().V1().ValidatingAdmissionPolicies(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 2.6K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator_test.go
}, Spec: k8sv1.PodSpec{ Volumes: podVolumes, }, } volumeCondition = &csipbv1.VolumeCondition{} ) func TestPVCRef(t *testing.T) { mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() // Setup mock stats provider mockStats := statstest.NewMockProvider(mockCtrl) volumes := map[string]volume.Volume{vol0: &fakeVolume{}, vol1: &fakeVolume{}, vol3: &fakeVolume{}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/batch.go
initFunc: startJobController, } } func startJobController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) { jobController, err := job.NewController( ctx, controllerContext.InformerFactory.Core().V1().Pods(), controllerContext.InformerFactory.Batch().V1().Jobs(), controllerContext.ClientBuilder.ClientOrDie("job-controller"), ) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 2.5K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
return nil, err } if len(c.SystemNamespaces) > 0 { s.GenericAPIServer.AddPostStartHookOrDie("start-system-namespaces-controller", func(hookContext genericapiserver.PostStartHookContext) error { go systemnamespaces.NewController(c.SystemNamespaces, client, s.VersionedInformers.Core().V1().Namespaces()).Run(hookContext.StopCh) return nil }) } _, publicServicePort, err := c.Generic.SecureServing.HostPort() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
DefaultServiceCIDRName = "kubernetes" ) // NewController returns a new *Controller that generates the default ServiceCIDR // from the `--service-cluster-ip-range` flag and recreates it if necessary, // but doesn't update it if is different. // It follows the same logic that the kubernetes.default Service. func NewController( primaryRange net.IPNet, secondaryRange net.IPNet, client clientset.Interface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0)