- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ConnectDeltaADS (0.13 sec)
-
pilot/pkg/xds/delta_test.go
) func TestDeltaAds(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.ClusterType) ads.RequestResponseAck(nil) } func TestDeltaAdsClusterUpdate(t *testing.T) { s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{}) ads := s.ConnectDeltaADS().WithType(v3.EndpointType) nonce := "" sendEDSReqAndVerify := func(add, remove, expect []string) { t.Helper()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
t.Run("ondemand", func(t *testing.T) { expect := buildExpect(t) s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{ KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")}, }) ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"}) ads.Request(&discovery.DeltaDiscoveryRequest{ ResourceNamesSubscribe: []string{"*"}, ResourceNamesUnsubscribe: []string{"*"}, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/test/xds/fake.go
})) if err != nil { f.t.Fatalf("failed to connect: %v", err) } return xds.NewAdsTest(f.t, conn) } // ConnectDeltaADS starts a Delta ADS connection to the server. It will automatically be cleaned up when the test ends func (f *FakeDiscoveryServer) ConnectDeltaADS() *xds.DeltaAdsTest { conn, err := grpc.Dial("buffcon", grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0)