diff --git a/internal/proxy/channels_time_ticker.go b/internal/proxy/channels_time_ticker.go index 2f4aacbbe0..90761c0639 100644 --- a/internal/proxy/channels_time_ticker.go +++ b/internal/proxy/channels_time_ticker.go @@ -33,6 +33,7 @@ type getPChanStatisticsFuncType func() (map[pChan]*pChanStatistics, error) type channelsTimeTicker interface { start() error close() error + // getLastTick returns the last write timestamp of specific pchan. getLastTick(pchan pChan) (Timestamp, error) getMinTsStatistics() (map[pChan]Timestamp, Timestamp, error) getMinTick() Timestamp