- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 103 for newController (0.72 sec)
-
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) -
pilot/pkg/autoregistration/controller_test.go
checkHealthOrFail(t, store, p, false) }) } func setup(t *testing.T) (*Controller, *Controller, model.ConfigStoreController) { store := memory.NewController(memory.Make(collections.All)) c1 := NewController(store, "pilot-1", time.Duration(math.MaxInt64)) c2 := NewController(store, "pilot-2", time.Duration(math.MaxInt64)) createOrFail(t, store, wgA) createOrFail(t, store, wgAWrongNs) createOrFail(t, store, wgWithoutSA)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K 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) -
pilot/pkg/serviceregistry/kube/controller/fake.go
} f := namespace.NewDiscoveryNamespacesFilter( kclient.New[*corev1.Namespace](opts.Client), opts.MeshWatcher, stop, ) kubelib.SetObjectFilter(opts.Client, f) meshServiceController := aggregate.NewController(aggregate.Options{MeshHolder: opts.MeshWatcher}) options := Options{ DomainSuffix: domainSuffix, XDSUpdater: xdsUpdater, Metrics: &model.Environment{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
netutils "k8s.io/utils/net" "k8s.io/utils/ptr" ) type testController struct { *Controller servicecidrsStore cache.Store ipaddressesStore cache.Store } func newController(ctx context.Context, t *testing.T, cidrs []*networkingapiv1alpha1.ServiceCIDR, ips []*networkingapiv1alpha1.IPAddress) (*fake.Clientset, *testController) { client := fake.NewSimpleClientset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
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/serviceregistry/aggregate/controller_test.go
DiscoveryController: discovery1, } registry2 := serviceregistry.Simple{ ProviderID: provider.ID("mockAdapter2"), DiscoveryController: discovery2, } ctls := NewController(Options{&mockMeshConfigHolder{}}) ctls.AddRegistry(registry1) ctls.AddRegistry(registry2) return ctls } // return aggregator and cluster1 and cluster2 service discovery
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go
endpointSliceStore cache.Store serviceStore cache.Store } func newController(ctx context.Context, batchPeriod time.Duration) (*fake.Clientset, *endpointSliceMirroringController) { client := newClientset() informerFactory := informers.NewSharedInformerFactory(client, controller.NoResyncPeriodFunc()) esController := NewController( ctx, informerFactory.Core().V1().Endpoints(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 13.9K 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)