- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for XdsUpdater (0.19 sec)
-
pilot/pkg/serviceregistry/serviceregistry_test.go
delegate := model.NewEndpointIndexUpdater(endpoints) xdsUpdater := xdsfake.NewWithDelegate(delegate) delegate.ConfigUpdateFunc = xdsUpdater.ConfigUpdate meshWatcher := mesh.NewFixedWatcher(&meshconfig.MeshConfig{}) kc := kubecontroller.NewController( client, kubecontroller.Options{ XDSUpdater: xdsUpdater, DomainSuffix: "cluster.local", MeshWatcher: meshWatcher,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
xdsUpdater := xdsfake.NewWithDelegate(delegate) meshcfg := mesh.NewFixedWatcher(mesh.DefaultMeshConfig()) istioStore := configController var controller *Controller if !workloadOnly { controller = NewController(configController, xdsUpdater, meshcfg, opts...) } else { controller = NewWorkloadEntryController(configController, xdsUpdater, meshcfg, opts...) } go controller.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
{ Port: 80, Name: "http-example", Protocol: corev1.ProtocolTCP, // Not added automatically by fake }, }, }, }) log.Infof("Created service %s", n) cl.opts.XDSUpdater.(*xdsfake.Updater).WaitOrFail(t, "service") } func TestController_GetPodLocality(t *testing.T) { pod1 := generatePod("128.0.1.1", "pod1", "nsA", "", "node1", map[string]string{"app": "prod-app"}, map[string]string{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
type ConsolidatedDestRule struct { // rule is merged from the following destinationRules. rule *config.Config // the original dest rules from which above rule is merged. from []types.NamespacedName } // XDSUpdater is used for direct updates of the xDS model and incremental push. // Pilot uses multiple registries - for example each K8S cluster is a registry // instance. Each registry is responsible for tracking a set
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
} { clienttest.MakeCRD(t, cl, crd) } idx := New(Options{ Client: cl, SystemNamespace: systemNS, DomainSuffix: "company.com", ClusterID: clusterID, XDSUpdater: up, LookupNetwork: func(endpointIP string, labels labels.Instance) network.ID { return networkID }, }) cl.RunAndWait(test.NewStop(t)) t.Cleanup(func() { if t.Failed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)