Updated InstancerOption

dreamsxin · May 1, 2024 · 7cff930 · 7cff930
1 parent 269cffb
commit 7cff930
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/sd/consul/instancer.go b/sd/consul/instancer.go
@@ -36,7 +36,7 @@ func TagsInstancerOptions(tags []string) InstancerOption {
 	}
 }
 
-func NewInstancer(client Client, logger *log.Logger, service string, passingOnly bool) *Instancer {
+func NewInstancer(client Client, logger *log.Logger, service string, passingOnly bool, options ...InstancerOption) *Instancer {
 	s := &Instancer{
 		cache:       instance.NewCache(),
 		client:      client,
@@ -52,6 +52,9 @@ func NewInstancer(client Client, logger *log.Logger, service string, passingOnly
 	} else {
 		s.logger.Sugar().Debugln("err", err)
 	}
+	for _, option := range options {
+		option(s)
+	}
 
 	s.cache.Update(events.Event{Instances: instances, Err: err})
 	go s.loop(index)