- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for NewAggregatedDiscoveryServiceClient (0.54 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) -
pkg/istio-agent/xds_proxy_delta.go
proxyLog.Errorf("failed to connect to upstream %s: %v", p.istiodAddress, err) metrics.IstiodConnectionFailures.Increment() return err } defer upstreamConn.Close() xds := discovery.NewAggregatedDiscoveryServiceClient(upstreamConn) ctx = metadata.AppendToOutgoingContext(context.Background(), "ClusterID", p.clusterID) for k, v := range p.xdsHeaders { ctx = metadata.AppendToOutgoingContext(ctx, k, v) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen_test.go
grpc.WithResolvers(xdsresolver)) if err != nil { t.Fatal("XDS gRPC", err) } defer conn.Close() s, err := discovery.NewAggregatedDiscoveryServiceClient(conn).StreamAggregatedResources(ctx) if err != nil { t.Fatal(err) } _ = s.Send(&discovery.DiscoveryRequest{}) }) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 09:04:02 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
} } func stream(t *testing.T, conn *grpc.ClientConn) discovery.AggregatedDiscoveryService_StreamAggregatedResourcesClient { t.Helper() adsClient := discovery.NewAggregatedDiscoveryServiceClient(conn) downstream, err := adsClient.StreamAggregatedResources(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 - 18.6K bytes - Viewed (0) -
pkg/adsc/delta.go
} return t.New().Interface() } func (c *Client) Run(ctx context.Context) error { if err := c.Dial(); err != nil { return fmt.Errorf("dial context: %v", err) } xds := discovery.NewAggregatedDiscoveryServiceClient(c.conn) xdsClient, err := xds.DeltaAggregatedResources(ctx, grpc.MaxCallRecvMsgSize(math.MaxInt32)) if err != nil { return fmt.Errorf("delta stream: %v", err) } c.sendNodeMeta.Store(true)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
proxyLog.Errorf("failed to connect to upstream %s: %v", p.istiodAddress, err) metrics.IstiodConnectionFailures.Increment() return err } defer upstreamConn.Close() xds := discovery.NewAggregatedDiscoveryServiceClient(upstreamConn) ctx = metadata.AppendToOutgoingContext(context.Background(), "ClusterID", p.clusterID) for k, v := range p.xdsHeaders { ctx = metadata.AppendToOutgoingContext(ctx, k, v) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/adsc/adsc.go
// And then it will run a go routine receiving and handling xds response. // Note: it is non blocking func (a *ADSC) Run() error { var err error a.client = discovery.NewAggregatedDiscoveryServiceClient(a.conn) a.stream, err = a.client.StreamAggregatedResources(context.Background()) if err != nil { return err } a.sendNodeMeta = true a.initialLoad = 0 a.initialLds = false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0)