- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewPushQueue (0.14 sec)
-
pilot/pkg/xds/pushqueue_test.go
t.Run("simple add and remove", func(t *testing.T) { t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{}) p.Enqueue(proxies[1], &model.PushRequest{}) ExpectDequeue(t, p, proxies[0]) ExpectDequeue(t, p, proxies[1]) }) t.Run("remove too many", func(t *testing.T) { t.Parallel() p := NewPushQueue() defer p.ShutDown() p.Enqueue(proxies[0], &model.PushRequest{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 8.8K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
case <-time.After(timeout): return false } } func TestSendPushesManyPushes(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh) semaphore := make(chan struct{}, 2) queue := NewPushQueue() defer queue.ShutDown() proxies := createProxies(5) pushes := make(map[string]int) pushesMu := &sync.Mutex{} for _, proxy := range proxies { proxy := proxy // Start receive thread
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/xds/pushqueue.go
// If model.PushRequest is not nil, it will be Enqueued again once MarkDone has been called. processing map[*Connection]*model.PushRequest shuttingDown bool } func NewPushQueue() *PushQueue { return &PushQueue{ pending: make(map[*Connection]*model.PushRequest), processing: make(map[*Connection]*model.PushRequest), cond: sync.NewCond(&sync.Mutex{}), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 16 01:37:15 UTC 2021 - 3.8K bytes - Viewed (0)