allow setting min log level for logger

logger/logger.go

@@ -189,6 +189,7 @@ type ZapLogger interface {
 	Logger
 	ToZap() *zap.SugaredLogger
 	ComponentLeveler() ZapComponentLeveler
+	WithMinLevel(lvl zapcore.LevelEnabler) Logger
 }
 
 type zapLogger[T zaputil.Encoder[T]] struct {
@@ -198,6 +199,7 @@ type zapLogger[T zaputil.Encoder[T]] struct {
 	component string
 	deferred  []*zaputil.Deferrer
 	sampler   *zaputil.Sampler
+	minLevel  zapcore.LevelEnabler
 }
 
 func FromZapLogger(log *zap.Logger, conf *Config, opts ...ZapLoggerOption) (ZapLogger, error) {
@@ -253,9 +255,15 @@ func newZapLogger[T zaputil.Encoder[T]](zap *zap.SugaredLogger, zc *zapConfig, e
 }
 
 func (l *zapLogger[T]) ToZap() *zap.SugaredLogger {
-	console, _ := l.writeEnablers.LoadOrCompute(l.component, func() *zaputil.WriteEnabler {
-		return zaputil.NewWriteEnabler(os.Stderr, l.sc.ComponentLevel(l.component))
-	})
+	var console *zaputil.WriteEnabler
+	if l.minLevel == nil {
+		console, _ = l.writeEnablers.LoadOrCompute(l.component, func() *zaputil.WriteEnabler {
+			return zaputil.NewWriteEnabler(os.Stderr, l.sc.ComponentLevel(l.component))
+		})
+	} else {
+		enab := zaputil.OrLevelEnabler{l.minLevel, l.sc.ComponentLevel(l.component)}
+		console = zaputil.NewWriteEnabler(os.Stderr, enab)
+	}
 
 	c := l.enc.Core(console, l.tap)
 	for i := range l.deferred {
@@ -291,6 +299,13 @@ func (l *zapLogger[T]) Debugw(msg string, keysAndValues ...interface{}) {
 	l.zap.Debugw(msg, keysAndValues...)
 }
 
+func (l *zapLogger[T]) WithMinLevel(lvl zapcore.LevelEnabler) Logger {
+	dup := *l
+	dup.minLevel = lvl
+	dup.zap = dup.ToZap()
+	return &dup
+}
+
 func (l *zapLogger[T]) Infow(msg string, keysAndValues ...interface{}) {
 	l.zap.Infow(msg, keysAndValues...)
 }

logger/pionlogger/logadapter.go

@@ -23,7 +23,7 @@ import (
 // implements webrtc.LeveledLogger
 type logAdapter struct {
 	logger          logger.Logger
-	ignoredPrefixes prefixSet
+	ignoredPrefixes *prefixSet
 }
 
 func (l *logAdapter) Trace(msg string) {

logger/pionlogger/logger.go

@@ -23,7 +23,7 @@ import (
 )
 
 var (
-	pionIgnoredPrefixes = map[string]prefixSet{
+	pionIgnoredPrefixes = map[string]*prefixSet{
 		"ice": {
 			"pingAllCandidates called with no candidate pairs",
 			"failed to send packet: io: read/write on closed pipe",
@@ -52,8 +52,12 @@ var (
 
 type prefixSet []string
 
-func (s prefixSet) Match(msg string) bool {
-	for _, prefix := range s {
+func (s *prefixSet) Match(msg string) bool {
+	if s == nil {
+		return false
+	}
+
+	for _, prefix := range *s {
 		if strings.HasPrefix(msg, prefix) {
 			return true
 		}

logger/pionlogger/zaplogadapter.go

@@ -36,7 +36,7 @@ type zapLogAdapter struct {
 	logger          logger.Logger
 	level           zapcore.LevelEnabler
 	scope           string
-	ignoredPrefixes prefixSet
+	ignoredPrefixes *prefixSet
 }
 
 func (l *zapLogAdapter) init() {

utils/hedge.go

@@ -29,7 +29,7 @@ type HedgeParams[T any] struct {
 	Func          func(context.Context) (T, error)
 }
 
-// race retries if the function takes to long to return
+// race retries if the function takes too long to return
 // |---------------- attempt 1 ----------------|
 // |    delay    |--------- attempt 2 ---------|
 func HedgeCall[T any](ctx context.Context, params HedgeParams[T]) (v T, err error) {