golang: add SetRequestTimeout implements producer/simpleConsumer/pushConsumer (#1016)

Co-authored-by: guyinyou <[email protected]>

Author: guyinyou

golang/client.go

@@ -46,6 +46,7 @@ type Client interface {
 
 type isClient interface {
 	isClient()
+	SetRequestTimeout(timeout time.Duration)
 	wrapHeartbeatRequest() *v2.HeartbeatRequest
 	onRecoverOrphanedTransactionCommand(endpoints *v2.Endpoints, command *v2.RecoverOrphanedTransactionCommand) error
 	onVerifyMessageCommand(endpoints *v2.Endpoints, command *v2.VerifyMessageCommand) error

golang/producer.go

@@ -455,3 +455,8 @@ func (p *defaultProducer) onRecoverOrphanedTransactionCommand(endpoints *v2.Endp
 func (p *defaultProducer) onVerifyMessageCommand(endpoints *v2.Endpoints, command *v2.VerifyMessageCommand) error {
 	return nil
 }
+
+func (p *defaultProducer) SetRequestTimeout(timeout time.Duration) {
+	p.cli.opts.timeout = timeout
+	p.pSetting.requestTimeout = p.cli.opts.timeout
+}

golang/push_consumer.go

@@ -70,6 +70,11 @@ type defaultPushConsumer struct {
 	consumptionErrorQuantity atomic.Int64
 }
 
+func (pc *defaultPushConsumer) SetRequestTimeout(timeout time.Duration) {
+	pc.cli.opts.timeout = timeout
+	pc.pcSettings.requestTimeout = pc.cli.opts.timeout
+}
+
 func (pc *defaultPushConsumer) isOn() bool {
 	return pc.cli.on.Load()
 }

golang/simple_consumer.go

@@ -61,6 +61,11 @@ type defaultSimpleConsumer struct {
 	subTopicRouteDataResultCache sync.Map
 }
 
+func (sc *defaultSimpleConsumer) SetRequestTimeout(timeout time.Duration) {
+	sc.cli.opts.timeout = timeout
+	sc.scSettings.requestTimeout = sc.cli.opts.timeout
+}
+
 func (sc *defaultSimpleConsumer) isOn() bool {
 	return sc.cli.on.Load()
 }