single instance parameter for server initialization

pkg/resolver/resolver.go

@@ -172,11 +172,11 @@ func (c *MiniResolver) Close() error {
 	return errors.Combine(errs...)
 }
 
-func (c *MiniResolver) NewServer(addr string, domains []string) (*Server, error) {
+func (c *MiniResolver) NewServer(addr string, domains []string, single bool) (*Server, error) {
 	if c.MiniResolverClient == nil {
 		return nil, errors.Errorf("no miniresolver client")
 	}
-	server, err := newServer(addr, domains, c.serverTLSConfig, c.MiniResolverClient, c.logger, c.serverOpts...)
+	server, err := newServer(addr, domains, c.serverTLSConfig, c.MiniResolverClient, single, c.logger, c.serverOpts...)
 	if err != nil {
 		return nil, errors.Wrapf(err, "cannot create server for %s", addr)
 	}

pkg/resolver/server.go

@@ -15,7 +15,7 @@ import (
 	"time"
 )
 
-func newServer(addr string, domains []string, tlsConfig *tls.Config, resolver pb.MiniResolverClient, logger zLogger.ZLogger, opts ...grpc.ServerOption) (*Server, error) {
+func newServer(addr string, domains []string, tlsConfig *tls.Config, resolver pb.MiniResolverClient, single bool, logger zLogger.ZLogger, opts ...grpc.ServerOption) (*Server, error) {
 	if tlsConfig == nil {
 		return nil, errors.New("no tls configuration")
 	}
@@ -44,6 +44,7 @@ func newServer(addr string, domains []string, tlsConfig *tls.Config, resolver pb
 		resolver:     resolver,
 		waitShutdown: sync.WaitGroup{},
 		domains:      domains,
+		single:       single,
 	}
 	return server, nil
 }
@@ -57,6 +58,7 @@ type Server struct {
 	resolver     pb.MiniResolverClient
 	addr         string
 	domains      []string
+	single       bool
 }
 
 func (s *Server) GetAddr() string {
@@ -97,6 +99,7 @@ func (s *Server) Startup() {
 					Service: name,
 					Port:    uint32(portInt),
 					Domains: s.domains,
+					Single:  s.single,
 				}); err != nil {
 					s.logger.Error().Err(err).Msg("cannot register service")
 				} else {