- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for DeltaAggregatedResources (0.24 sec)
-
pkg/istio-agent/tap_proxy.go
log.Errorf("failed to send: %v", err) return err } } else { log.Errorf("failed to call tap request: %v", err) return err } } return nil } func (p *tapProxy) DeltaAggregatedResources(downstream DeltaDiscoveryStream) error { return fmt.Errorf("not implemented")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta_test.go
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/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), ) *DeltaAdsTest {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0)