- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for FX (1.87 sec)
-
pilot/pkg/serviceregistry/util/xdsfake/updater.go
// LDS/RDS. func (fx *Updater) SvcUpdate(c model.ShardKey, hostname string, ns string, ev model.Event) { select { case fx.Events <- Event{Type: "service", ID: hostname, Namespace: ns}: default: } if fx.Delegate != nil { fx.Delegate.SvcUpdate(c, hostname, ns, ev) } } func (fx *Updater) RemoveShard(shardKey model.ShardKey) { select {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
_, kube, fx := setupTest(t) makeService(t, kube, headlessServiceHTTP) fx.WaitOrFail(t, "service") makePod(t, kube, pod) createEndpoints(t, kube, service.Name, namespace, []v1.EndpointPort{{Name: "http", Port: 80}}, []string{pod.Status.PodIP}) fx.WaitOrFail(t, "eds") // Endpoint update is triggered since its a brand new service
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/kube/controller/pod_test.go
addPods(t, c, fx, pod) createEndpoints(t, c, "rating", "nsa", []string{"tcp-port"}, []string{"128.0.0.1"}, []*v1.ObjectReference{ { Kind: "Pod", Namespace: "nsa", Name: "cpod1", }, }, nil) fx.WaitOrFail(t, "eds") fx.Clear() // Verify podCache got := c.pods.getPodsByIP("128.0.0.1")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
createExternalNameService(controller, "svc2", "nsA", []int32{8081}, "test-app-2.test.svc."+defaultFakeDomainSuffix, t, fx), createExternalNameService(controller, "svc3", "nsA", []int32{8082}, "test-app-3.test.pod."+defaultFakeDomainSuffix, t, fx), createExternalNameService(controller, "svc4", "nsA", []int32{8083}, "g.co", t, fx), }
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/serviceregistry/kube/controller/fake.go
clienttest.MakeCRD(t, c.client, crd) } opts.Client.RunAndWait(c.stop) var fx *xdsfake.Updater if x, ok := xdsUpdater.(*xdsfake.Updater); ok { fx = x } if !opts.SkipRun { go c.Run(c.stop) kubelib.WaitForCacheSync("test", c.stop, c.HasSynced) } return &FakeController{Controller: c, Endpoints: endpoints}, fx
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice_test.go
"istio.io/istio/pkg/test/util/assert" ) func TestEndpointSliceFromMCSShouldBeIgnored(t *testing.T) { const ( ns = "nsa" svcName = "svc1" appName = "prod-app" ) controller, fx := NewFakeControllerWithOptions(t, FakeControllerOptions{}) node := generateNode("node1", map[string]string{ NodeZoneLabel: "zone1", NodeRegionLabel: "region1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 4.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
pod1 := generatePod("127.0.0.1", "pod1", testNS, "sa1", "node1", map[string]string{"app": "a"}, nil) pc.CreateOrUpdateStatus(pod1) fx.WaitOrFail(t, "xds") pod2 := generatePod("127.0.0.2", "pod2", testNS, "sa2", "node1", map[string]string{"app": "a"}, nil) pc.CreateOrUpdateStatus(pod2) fx.WaitOrFail(t, "xds") sc.CreateOrUpdate(generateService("svc1", testNS, map[string]string{}, // labels map[string]string{}, // annotations
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/test/groovy/org/gradle/jvm/toolchain/internal/LinuxInstallationSupplierTest.groovy
def nonExistent = temporaryFolder.file("non-existent") def setup() { candidates.createDir("11.0.6.hs-adpt") candidates.createDir("14") otherCandidates.createDir("8.0.262.fx-librca") } def "supplies no installations non-linux operating system"() { given: def supplier = new LinuxInstallationSupplier(OperatingSystem.WINDOWS, candidates) when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 10 18:03:55 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/test/groovy/org/gradle/jvm/toolchain/internal/JabbaInstallationSupplierTest.groovy
given: def expectedLocation1 = candidates.createDir("jdk/11.0.6.hs-adpt") def expectedLocation2 = candidates.createDir("jdk/14") def expectedLocation3 = candidates.createDir("jdk/8.0.262.fx-librca") when: def directories = supplier.get() then: directories.size() == 3 directories*.location.containsAll(expectedLocation1, expectedLocation2, expectedLocation3)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 22:17:53 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/jvm/jvm-services/src/test/groovy/org/gradle/jvm/toolchain/internal/SdkmanInstallationSupplierTest.groovy
given: def expectedLocation1 = candidates.createDir("java/11.0.6.hs-adpt") def expectedLocation2 = candidates.createDir("java/14") def expectedLocation3 = candidates.createDir("java/8.0.262.fx-librca") when: def directories = supplier.get() then: directories.size() == 3 directories*.location.containsAll(expectedLocation1, expectedLocation2, expectedLocation3)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 22:17:53 UTC 2024 - 3.5K bytes - Viewed (0)