- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for newController (0.16 sec)
-
tests/fuzz/autoregistration_controller_fuzzer.go
proxy := &model.Proxy{} err := f.GenerateStruct(proxy) if err != nil { return 0 } if !proxy.FuzzValidate() { return 0 } store := memory.NewController(memory.Make(collections.All)) c := autoregistration.NewController(store, "", keepalive.Infinity) err = createStore(store, wgA) if err != nil { fmt.Println(err) return 0 } stop := make(chan struct{}) go c.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
pilot/pkg/config/memory/controller.go
namespacesFilter func(obj interface{}) bool } // NewController return an implementation of ConfigStoreController // This is a client-side monitor that dispatches events as the changes are being // made on the client. func NewController(cs model.ConfigStore) *Controller { out := &Controller{ configStore: cs, monitor: NewMonitor(cs), } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher.go
func NewConfigMapWatcher(client kube.Client, namespace, name, key string, multiWatch bool, stop <-chan struct{}) *mesh.MultiWatcher { w := mesh.NewMultiWatcher(mesh.DefaultMeshConfig()) c := configmapwatcher.NewController(client, namespace, name, func(cm *v1.ConfigMap) { meshNetworks, err := ReadNetworksConfigMap(cm, "meshNetworks") if err != nil { // Keep the last known config in case there's a misconfiguration issue.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
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) -
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/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)