diff --git a/internal/proxynode/channels_time_ticker.go b/internal/proxynode/channels_time_ticker.go index 19a890c412..aaa6e750d2 100644 --- a/internal/proxynode/channels_time_ticker.go +++ b/internal/proxynode/channels_time_ticker.go @@ -52,7 +52,10 @@ type channelsTimeTickerImpl struct { } func (ticker *channelsTimeTickerImpl) getMinTsStatistics() (map[pChan]Timestamp, error) { - panic("implement me") + ticker.statisticsMtx.RLock() + defer ticker.statisticsMtx.RUnlock() + + return ticker.minTsStatistics, nil } func (ticker *channelsTimeTickerImpl) initStatistics() {