- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewDeltaAdsTest (0.57 sec)
-
pilot/pkg/xds/deltaadstest.go
"google.golang.org/grpc" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/test" ) func NewDeltaAdsTest(t test.Failer, conn *grpc.ClientConn) *DeltaAdsTest { test.SetForTest(t, &features.DeltaXds, true) return NewDeltaXdsTest(t, conn, func(conn *grpc.ClientConn) (DeltaDiscoveryClient, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/test/xds/fake.go
grpc.WithBlock(), grpc.WithContextDialer(func(context.Context, string) (net.Conn, error) { return f.BufListener.Dial() })) if err != nil { f.t.Fatalf("failed to connect: %v", err) } return xds.NewDeltaAdsTest(f.t, conn) } func APIWatches() []string { watches := []string{gvk.MeshConfig.String()} for _, sch := range collections.Pilot.All() { watches = append(watches, sch.GroupVersionKind().String()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0)