Make sure the remote write storage uses a dedupe logger. (#6113)
Signed-off-by: Callum Styan <callumstyan@gmail.com>
This commit is contained in:
parent
706f3b2d17
commit
84ff928606
|
@ -52,8 +52,8 @@ func NewStorage(l log.Logger, reg prometheus.Registerer, stCallback startTimeCal
|
||||||
s := &Storage{
|
s := &Storage{
|
||||||
logger: logging.Dedupe(l, 1*time.Minute),
|
logger: logging.Dedupe(l, 1*time.Minute),
|
||||||
localStartTimeCallback: stCallback,
|
localStartTimeCallback: stCallback,
|
||||||
rws: NewWriteStorage(l, walDir, flushDeadline),
|
|
||||||
}
|
}
|
||||||
|
s.rws = NewWriteStorage(s.logger, walDir, flushDeadline)
|
||||||
return s
|
return s
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue