change ConsumeGoroutineNums max value allowed (#1049)

twz915 · web-flow · commit 8c4e3884d91a · 2023-05-09T11:50:06.000+08:00
ConsumeGoroutineNums should allow large values to be set, detail see #883 (comment)
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -614,11 +614,11 @@ func (pc *pushConsumer) validate() error {
 		}
 	}
 
-	if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums > 1000 {
+	if pc.option.ConsumeGoroutineNums < 1 || pc.option.ConsumeGoroutineNums > 100000 {
 		if pc.option.ConsumeGoroutineNums == 0 {
 			pc.option.ConsumeGoroutineNums = 20
 		} else {
-			return errors.New("option.ConsumeGoroutineNums out of range [1, 1000]")
+			return errors.New("option.ConsumeGoroutineNums out of range [1, 100000]")
 		}
 	}
 	return nil

Original file line number	Diff line number	Diff line change
`@@ -614,11 +614,11 @@ func (pc *pushConsumer) validate() error {`
`614`	`614`	`}`
`615`	`615`	`}`
`616`	`616`
`617`		`- if pc.option.ConsumeGoroutineNums < 1 \|\| pc.option.ConsumeGoroutineNums > 1000 {`
	`617`	`+ if pc.option.ConsumeGoroutineNums < 1 \|\| pc.option.ConsumeGoroutineNums > 100000 {`
`618`	`618`	`if pc.option.ConsumeGoroutineNums == 0 {`
`619`	`619`	`pc.option.ConsumeGoroutineNums = 20`
`620`	`620`	`} else {`
`621`		`- return errors.New("option.ConsumeGoroutineNums out of range [1, 1000]")`
	`621`	`+ return errors.New("option.ConsumeGoroutineNums out of range [1, 100000]")`
`622`	`622`	`}`
`623`	`623`	`}`
`624`	`624`	`return nil`