From fca3eb71267bf49639f0953121609ec69b811129 Mon Sep 17 00:00:00 2001 From: dragondriver Date: Tue, 1 Jun 2021 16:50:32 +0800 Subject: [PATCH] Add implementation of getMinTsStatistics function (#5524) Signed-off-by: dragondriver --- internal/proxynode/channels_time_ticker.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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() {