- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for deltaStream (0.14 sec)
-
pkg/istio-agent/xds_proxy_delta_test.go
setDialOptions(proxy, f.BufListener) conn := setupDownstreamConnection(t, proxy) downstream := deltaStream(t, conn) sendDeltaDownstreamWithNode(t, downstream, model.NodeMetadata{ Namespace: "default", InstanceIPs: []string{"1.1.1.1"}, }) } func deltaStream(t *testing.T, conn *grpc.ClientConn) discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesClient { t.Helper()
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/delta.go
select { case <-con.InitializedCh(): default: close(con.InitializedCh()) } }() firstRequest := true for { req, err := con.deltaStream.Recv() if err != nil { if istiogrpc.IsExpectedGRPCError(err) { deltaLog.Infof("ADS: %q %s terminated", con.Peer(), con.ID()) return } con.ErrorCh() <- err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
// This is included in internal events. node *core.Node // proxy is the client to which this connection is established. proxy *model.Proxy // deltaStream is used for Delta XDS. Only one of deltaStream or stream will be set deltaStream DeltaDiscoveryStream deltaReqChan chan *discovery.DeltaDiscoveryRequest s *DiscoveryServer ids []string }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
doneFunc := func() { queue.MarkDone(client) <-semaphore } proxiesQueueTime.Record(time.Since(push.Start).Seconds()) var closed <-chan struct{} if client.deltaStream != nil { closed = client.deltaStream.Context().Done() } else { closed = client.StreamDone() } go func() { pushEv := &Event{ pushRequest: push, done: doneFunc, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)