diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-04-05 10:41:18 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-04-11 10:27:09 +0200 |
commit | 071da64bb540ded7f56b83cf68419d885184079b (patch) | |
tree | e103b38c08cd4c49e64640bc2cee26b54bc5c6c1 /client/go/internal/vespa/document/dispatcher_test.go | |
parent | 724ca1704c58d9b40da0f0730cefd63557c04215 (diff) |
Adjust min inflight based on connection count
Diffstat (limited to 'client/go/internal/vespa/document/dispatcher_test.go')
-rw-r--r-- | client/go/internal/vespa/document/dispatcher_test.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/client/go/internal/vespa/document/dispatcher_test.go b/client/go/internal/vespa/document/dispatcher_test.go index fc96adabc96..80bc5f603ae 100644 --- a/client/go/internal/vespa/document/dispatcher_test.go +++ b/client/go/internal/vespa/document/dispatcher_test.go @@ -39,7 +39,7 @@ func (f *mockFeeder) Send(doc Document) Result { func TestDispatcher(t *testing.T) { feeder := &mockFeeder{} clock := &manualClock{tick: time.Second} - throttler := newThrottler(clock.now) + throttler := newThrottler(8, clock.now) breaker := NewCircuitBreaker(time.Second, 0) dispatcher := NewDispatcher(feeder, throttler, breaker, io.Discard) docs := []Document{ @@ -72,7 +72,7 @@ func TestDispatcherOrdering(t *testing.T) { {Id: mustParseId("id:ns:type::doc9"), Operation: OperationPut}, } clock := &manualClock{tick: time.Second} - throttler := newThrottler(clock.now) + throttler := newThrottler(8, clock.now) breaker := NewCircuitBreaker(time.Second, 0) dispatcher := NewDispatcher(feeder, throttler, breaker, io.Discard) for _, d := range docs { @@ -108,7 +108,7 @@ func TestDispatcherOrderingWithFailures(t *testing.T) { } feeder.failAfterN(2) clock := &manualClock{tick: time.Second} - throttler := newThrottler(clock.now) + throttler := newThrottler(8, clock.now) breaker := NewCircuitBreaker(time.Second, 0) dispatcher := NewDispatcher(feeder, throttler, breaker, io.Discard) for _, d := range docs { |