- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for deltaStream (0.53 sec)
-
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)