diff --git a/pkg/extension/service/registrar.go b/pkg/extension/service/registrar.go index dc58f97d69ebdfd17d2d7a7bbc972652cdb0d339..8a096ef2047058e70f355ece9136069b7d94d3af 100644 --- a/pkg/extension/service/registrar.go +++ b/pkg/extension/service/registrar.go @@ -25,11 +25,16 @@ type Registrar struct { } func NewRegistrar(addr string, man extension.Manager, exts []extension.Extension, logger *zap.Logger) *Registrar { + extNames := make([]string, 0, len(exts)) + for _, ext := range exts { + extNames = append(extNames, ext.GetDescriptor().GetExtension()) + } + return &Registrar{ addr: addr, manager: man, exts: exts, - logger: logger, + logger: logger.Named("Registrar").With(zap.Strings("extensions", extNames)), } } @@ -75,7 +80,7 @@ func (reg *Registrar) Start() error { extList = append(extList, &extension.ExtensionConnector{Descriptor: &desc}) } - reg.logger.Info("Start registration process") + reg.logger.Debug("Start registration process") go func() { for { @@ -84,7 +89,7 @@ func (reg *Registrar) Start() error { reg.register(regCtx, reg.manager, extList) registrationDelay = RegistrationDelay case <-regCtx.Done(): - reg.logger.Info("Stop registration process") + reg.logger.Debug("Stop registration process") return } }