From 1b9c9110498e08da418156a63378fc639dd946de Mon Sep 17 00:00:00 2001 From: Arko Dasgupta Date: Tue, 1 Aug 2023 16:14:20 -0700 Subject: [PATCH] change subscriber logs to debug Relates to https://github.com/envoyproxy/gateway/pull/1723#discussion_r1276978964 Signed-off-by: Arko Dasgupta --- internal/gatewayapi/runner/runner.go | 2 +- internal/globalratelimit/runner/runner.go | 2 +- internal/infrastructure/runner/runner.go | 2 +- internal/xds/server/runner/runner.go | 2 +- internal/xds/translator/runner/runner.go | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/gatewayapi/runner/runner.go b/internal/gatewayapi/runner/runner.go index 7db9c05b96..7e03b4c514 100644 --- a/internal/gatewayapi/runner/runner.go +++ b/internal/gatewayapi/runner/runner.go @@ -51,7 +51,7 @@ func (r *Runner) Start(ctx context.Context) error { func (r *Runner) subscribeAndTranslate(ctx context.Context) { message.HandleSubscription(r.ProviderResources.GatewayAPIResources.Subscribe(ctx), func(update message.Update[string, *gatewayapi.Resources]) { - r.Logger.Info("received an update") + r.Logger.Debug("received an update") val := update.Value diff --git a/internal/globalratelimit/runner/runner.go b/internal/globalratelimit/runner/runner.go index 88acfcefc7..fd266db572 100644 --- a/internal/globalratelimit/runner/runner.go +++ b/internal/globalratelimit/runner/runner.go @@ -110,7 +110,7 @@ func (r *Runner) subscribeAndTranslate(ctx context.Context) { // Subscribe to resources. message.HandleSubscription(r.XdsIR.Subscribe(ctx), func(update message.Update[string, *ir.Xds]) { - r.Logger.Info("received a notification") + r.Logger.Debug("received an update") if update.Delete { if err := r.addNewSnapshot(ctx, nil); err != nil { diff --git a/internal/infrastructure/runner/runner.go b/internal/infrastructure/runner/runner.go index 2f7bd146df..9defd0caea 100644 --- a/internal/infrastructure/runner/runner.go +++ b/internal/infrastructure/runner/runner.go @@ -57,7 +57,7 @@ func (r *Runner) subscribeToProxyInfraIR(ctx context.Context) { // Subscribe to resources message.HandleSubscription(r.InfraIR.Subscribe(ctx), func(update message.Update[string, *ir.Infra]) { - r.Logger.Info("received an update") + r.Logger.Debug("received an update") val := update.Value if update.Delete { diff --git a/internal/xds/server/runner/runner.go b/internal/xds/server/runner/runner.go index e76224a739..5cf76a79cc 100644 --- a/internal/xds/server/runner/runner.go +++ b/internal/xds/server/runner/runner.go @@ -130,7 +130,7 @@ func (r *Runner) subscribeAndTranslate(ctx context.Context) { key := update.Key val := update.Value - r.Logger.Info("received an update") + r.Logger.Debug("received an update") var err error if update.Delete { err = r.cache.GenerateNewSnapshot(key, nil) diff --git a/internal/xds/translator/runner/runner.go b/internal/xds/translator/runner/runner.go index defbc7fc51..f7ab28910c 100644 --- a/internal/xds/translator/runner/runner.go +++ b/internal/xds/translator/runner/runner.go @@ -51,7 +51,7 @@ func (r *Runner) subscribeAndTranslate(ctx context.Context) { // Subscribe to resources message.HandleSubscription(r.XdsIR.Subscribe(ctx), func(update message.Update[string, *ir.Xds]) { - r.Logger.Info("received an update") + r.Logger.Debug("received an update") key := update.Key val := update.Value