- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewAggregatedDiscoveryServiceClient (0.37 sec)
-
pkg/istio-agent/xds_proxy_delta_test.go
InstanceIPs: []string{"1.1.1.1"}, }) } func deltaStream(t *testing.T, conn *grpc.ClientConn) discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient { t.Helper() adsClient := discovery.NewAggregatedDiscoveryServiceClient(conn) downstream, err := adsClient.DeltaAggregatedResources(ctx) if err != nil { t.Fatal(err) } return downstream }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
"istio.io/istio/pkg/test" ) func NewAdsTest(t test.Failer, conn *grpc.ClientConn) *AdsTest { return NewXdsTest(t, conn, func(conn *grpc.ClientConn) (DiscoveryClient, error) { xds := discovery.NewAggregatedDiscoveryServiceClient(conn) return xds.StreamAggregatedResources(context.Background()) }) } func NewSdsTest(t test.Failer, conn *grpc.ClientConn) *AdsTest {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
test.SetForTest(t, &features.DeltaXds, true) return NewDeltaXdsTest(t, conn, func(conn *grpc.ClientConn) (DeltaDiscoveryClient, error) { xds := discovery.NewAggregatedDiscoveryServiceClient(conn) return xds.DeltaAggregatedResources(context.Background()) }) } func NewDeltaXdsTest(t test.Failer, conn *grpc.ClientConn, getClient 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)