golang: Add ClientFunc option for simple consumer (#863)

* golang: Add ClientFunc option for simple consumer * golang: Add ClientFunc option for simple consumer
apache · Nov 7, 2024 · 198f997 · 198f997
1 parent 4f05fb7
commit 198f997
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/golang/simple_consumer_options.go b/golang/simple_consumer_options.go
@@ -85,6 +85,14 @@ func newFuncSimpleConsumerOption(f func(*simpleConsumerOptions)) *funcSimpleCons
 	}
 }
 
+// WithClientFuncForSimpleConsumer returns a consumerOption that sets ClientFunc for simple consumer.
+// Default is nameserver.New.
+func WithClientFuncForSimpleConsumer(f NewClientFunc) SimpleConsumerOption {
+	return newFuncSimpleConsumerOption(func(o *simpleConsumerOptions) {
+		o.clientFunc = f
+	})
+}
+
 // WithTag returns a consumerOption that sets tag for consumer.
 // Note: Default it uses *.
 func WithSubscriptionExpressions(subscriptionExpressions map[string]*FilterExpression) SimpleConsumerOption {