3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-08-06 10:21:05 +02:00
Code Issues Projects Releases Packages Wiki Activity

core/zero: lower log level (#5065)

Browse source
This commit is contained in:
Caleb Doxsey 2024-04-11 15:31:25 -06:00 • committed by GitHub
parent dc7820ea3e
commit ed378af744
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
internal/zero/connect-mux/service.go
View file

@ -83,7 +83,7 @@ func (svc *Mux) subscribeAndDispatch(ctx context.Context, onConnected func()) (e
log.Ctx(ctx).Debug().Msg("subscribed to connect service") log.Ctx(ctx).Debug().Msg("subscribed to connect service")
for { for {
msg, err := stream.Recv() msg, err := stream.Recv()
log.Ctx(ctx).Info().Interface("msg", msg).Err(err).Msg("receive") log.Ctx(ctx).Debug().Interface("msg", msg).Err(err).Msg("receive")
if err != nil { if err != nil {
return fmt.Errorf("receive: %w", err) return fmt.Errorf("receive: %w", err)
} }

2
internal/zero/grpcconn/client.go
View file

@ -105,7 +105,7 @@ func interceptorLogger(ctx context.Context, lvl logging.Level, msg string, field
case logging.LevelDebug: case logging.LevelDebug:
l.Debug().Msg(msg) l.Debug().Msg(msg)
case logging.LevelInfo: case logging.LevelInfo:
l.Info().Msg(msg) l.Debug().Msg(msg)
case logging.LevelWarn: case logging.LevelWarn:
l.Warn().Msg(msg) l.Warn().Msg(msg)
case logging.LevelError: case logging.LevelError:

6
internal/zero/reconciler/sync.go
View file

@ -36,19 +36,19 @@ func (c *service) SyncLoop(ctx context.Context) error {
case <-ctx.Done(): case <-ctx.Done():
return ctx.Err() return ctx.Err()
case <-c.bundleSyncRequest: case <-c.bundleSyncRequest:
log.Ctx(ctx).Info().Msg("bundle sync triggered") log.Ctx(ctx).Debug().Msg("bundle sync triggered")
err := c.syncBundles(ctx) err := c.syncBundles(ctx)
if err != nil { if err != nil {
return fmt.Errorf("reconciler: sync bundles: %w", err) return fmt.Errorf("reconciler: sync bundles: %w", err)
} }
case <-c.fullSyncRequest: case <-c.fullSyncRequest:
log.Ctx(ctx).Info().Msg("full sync triggered") log.Ctx(ctx).Debug().Msg("full sync triggered")
err := c.syncAll(ctx) err := c.syncAll(ctx)
if err != nil { if err != nil {
return fmt.Errorf("reconciler: sync all: %w", err) return fmt.Errorf("reconciler: sync all: %w", err)
} }
case <-ticker.C: case <-ticker.C:
log.Ctx(ctx).Info().Msg("periodic sync triggered") log.Ctx(ctx).Debug().Msg("periodic sync triggered")
err := c.syncAll(ctx) err := c.syncAll(ctx)
if err != nil { if err != nil {
return fmt.Errorf("reconciler: sync all: %w", err) return fmt.Errorf("reconciler: sync all: %w", err)