- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for pushChannel (0.13 sec)
-
pilot/pkg/xds/pushqueue_test.go
done := make(chan struct{}) pushChannel := make(chan *model.PushRequest) go func() { // dequeue pushQueue and send to pushChannel for { _, request, shuttingdown := p.Dequeue() if shuttingdown { close(pushChannel) return } pushChannel <- request } }() go func() { // recv from pushChannel and simulate push for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/xds/server.go
// conID is the connection conID, used as a key in the connection table. // Currently based on the node name and a counter. conID string // Sending on this channel results in a push. pushChannel chan any // Both ADS and SDS streams implement this interface stream DiscoveryStream // initialized channel will be closed when proxy is initialized. Pushes, or anything accessing
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
// the push context, which means that the next push to a proxy will receive this configuration. CommittedUpdates *atomic.Int64 // pushChannel is the buffer used for debouncing. // after debouncing the pushRequest will be sent to pushQueue pushChannel chan *model.PushRequest // pushQueue is the buffer that used after debounce and before the real xds push. pushQueue *PushQueue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (1) -
pilot/pkg/xds/delta.go
// has more luck deltaLog.Warnf("Error reading config %v", err) return status.Error(codes.Unavailable, "error reading config") } con := newDeltaConnection(peerAddr, stream) // Do not call: defer close(con.pushChannel). The push channel will be garbage collected // when the connection is no longer used. Closing the channel can cause subtle race conditions
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)