| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher_test.go | 52 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 2}, []int{4, 4}},
53 {10, &batcher.Options{MaxBatchSize: 5, MaxHandlers: 2}, []int{5, 5}},
54 {10, &batcher.Options{MaxBatchSize: 9, MaxHandlers: 2}, []int{9, 1}},
55 {9, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 1}},
56 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 2}},
58 {8, &batcher.Options{MinBatchSize: 5, MaxBatchSize: 7, MaxHandlers: 2}, []int{7}},
121 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: maxHandlers, MaxBatchSize: …
177 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: cap(c)}, func(x interface{}…
|
| H A D | batcher.go | 53 for n >= o.MinBatchSize && len(batches) < o.MaxHandlers {
85 MaxHandlers int member
99 if o.MaxHandlers == 0 {
100 o.MaxHandlers = 1
153 if b.nHandlers < b.opts.MaxHandlers {
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher_test.go | 52 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 2}, []int{4, 4}},
53 {10, &batcher.Options{MaxBatchSize: 5, MaxHandlers: 2}, []int{5, 5}},
54 {10, &batcher.Options{MaxBatchSize: 9, MaxHandlers: 2}, []int{9, 1}},
55 {9, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 1}},
56 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 2}},
58 {8, &batcher.Options{MinBatchSize: 5, MaxBatchSize: 7, MaxHandlers: 2}, []int{7}},
121 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: maxHandlers, MaxBatchSize: …
177 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: cap(c)}, func(x interface{}…
|
| H A D | batcher.go | 53 for n >= o.MinBatchSize && len(batches) < o.MaxHandlers {
85 MaxHandlers int member
99 if o.MaxHandlers == 0 {
100 o.MaxHandlers = 1
153 if b.nHandlers < b.opts.MaxHandlers {
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/batcher/ |
| H A D | batcher_test.go | 52 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 2}, []int{4, 4}},
53 {10, &batcher.Options{MaxBatchSize: 5, MaxHandlers: 2}, []int{5, 5}},
54 {10, &batcher.Options{MaxBatchSize: 9, MaxHandlers: 2}, []int{9, 1}},
55 {9, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 1}},
56 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 2}},
58 {8, &batcher.Options{MinBatchSize: 5, MaxBatchSize: 7, MaxHandlers: 2}, []int{7}},
121 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: maxHandlers, MaxBatchSize: …
177 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: cap(c)}, func(x interface{}…
|
| H A D | batcher.go | 53 for n >= o.MinBatchSize && len(batches) < o.MaxHandlers {
85 MaxHandlers int member
99 if o.MaxHandlers == 0 {
100 o.MaxHandlers = 1
153 if b.nHandlers < b.opts.MaxHandlers {
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/batcher/ |
| H A D | batcher_test.go | 52 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 2}, []int{4, 4}},
53 {10, &batcher.Options{MaxBatchSize: 5, MaxHandlers: 2}, []int{5, 5}},
54 {10, &batcher.Options{MaxBatchSize: 9, MaxHandlers: 2}, []int{9, 1}},
55 {9, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 1}},
56 {10, &batcher.Options{MaxBatchSize: 4, MaxHandlers: 3}, []int{4, 4, 2}},
58 {8, &batcher.Options{MinBatchSize: 5, MaxBatchSize: 7, MaxHandlers: 2}, []int{7}},
121 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: maxHandlers, MaxBatchSize: …
177 …b := batcher.New(reflect.TypeOf(int(0)), &batcher.Options{MaxHandlers: cap(c)}, func(x interface{}…
|
| H A D | batcher.go | 53 for n >= o.MinBatchSize && len(batches) < o.MaxHandlers {
85 MaxHandlers int member
99 if o.MaxHandlers == 0 {
100 o.MaxHandlers = 1
153 if b.nHandlers < b.opts.MaxHandlers {
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/gcppubsub/ |
| H A D | gcppubsub.go | 83 MaxHandlers: 2,
89 MaxHandlers: 10,
96 MaxHandlers: 2,
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/gcppubsub/ |
| H A D | gcppubsub.go | 83 MaxHandlers: 2,
89 MaxHandlers: 10,
96 MaxHandlers: 2,
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/gcppubsub/ |
| H A D | gcppubsub.go | 83 MaxHandlers: 2,
89 MaxHandlers: 10,
96 MaxHandlers: 2,
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/gcppubsub/ |
| H A D | gcppubsub.go | 84 MaxHandlers: 2,
90 MaxHandlers: 10,
97 MaxHandlers: 2,
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/awssnssqs/ |
| H A D | awssnssqs.go | 103 MaxHandlers: 100, // max concurrency for sends
108 MaxHandlers: 100, // max concurrency for sends
115 MaxHandlers: 100, // max concurrency for receives
123 MaxHandlers: 100, // max concurrency for acks
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/awssnssqs/ |
| H A D | awssnssqs.go | 103 MaxHandlers: 100, // max concurrency for sends
108 MaxHandlers: 100, // max concurrency for sends
115 MaxHandlers: 100, // max concurrency for receives
123 MaxHandlers: 100, // max concurrency for acks
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/awssnssqs/ |
| H A D | awssnssqs.go | 103 MaxHandlers: 100, // max concurrency for sends
108 MaxHandlers: 100, // max concurrency for sends
115 MaxHandlers: 100, // max concurrency for receives
123 MaxHandlers: 100, // max concurrency for acks
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/awssnssqs/ |
| H A D | awssnssqs.go | 104 MaxHandlers: 100, // max concurrency for sends
109 MaxHandlers: 100, // max concurrency for sends
116 MaxHandlers: 100, // max concurrency for receives
124 MaxHandlers: 100, // max concurrency for acks
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/azuresb/ |
| H A D | azuresb.go | 83 MaxHandlers: 100, // max concurrency for sends
88 MaxHandlers: 100, // max concurrency for reads
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/kafkapubsub/ |
| H A D | kafka.go | 76 MaxHandlers: 2,
81 MaxHandlers: 1,
|
| /dports/www/gohugo/hugo-0.91.2/vendor/gocloud.dev/pubsub/kafkapubsub/ |
| H A D | kafka.go | 75 MaxHandlers: 2,
80 MaxHandlers: 1,
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/kafkapubsub/ |
| H A D | kafka.go | 75 MaxHandlers: 2,
80 MaxHandlers: 1,
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/kafkapubsub/ |
| H A D | kafka.go | 75 MaxHandlers: 2,
80 MaxHandlers: 1,
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/azuresb/ |
| H A D | azuresb.go | 90 MaxHandlers: 100, // max concurrency for sends
95 MaxHandlers: 100, // max concurrency for reads
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/gocloud.dev/go-cloud-5094f54ed8bb/pubsub/azuresb/ |
| H A D | azuresb.go | 90 MaxHandlers: 100, // max concurrency for sends
95 MaxHandlers: 100, // max concurrency for reads
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gocloud.dev/pubsub/ |
| H A D | pubsub_test.go | 349 sub := NewSubscription(fs, &batcher.Options{MaxHandlers: 10, MaxBatchSize: 2}, nil)
411 sub := NewSubscription(fs, &batcher.Options{MaxHandlers: 10, MaxBatchSize: 2}, nil)
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/gocloud.dev/pubsub/ |
| H A D | pubsub_test.go | 345 sub := NewSubscription(fs, &batcher.Options{MaxHandlers: 10, MaxBatchSize: 2}, nil)
407 sub := NewSubscription(fs, &batcher.Options{MaxHandlers: 10, MaxBatchSize: 2}, nil)
|