diff --git a/internal/proxy/channels_time_ticker.go b/internal/proxy/channels_time_ticker.go index 2e1011d0ae..598f0ab153 100644 --- a/internal/proxy/channels_time_ticker.go +++ b/internal/proxy/channels_time_ticker.go @@ -37,6 +37,7 @@ type channelsTimeTicker interface { getLastTick(pchan pChan) (Timestamp, error) // getMinTsStatistics returns the last write timestamp of all pchans. getMinTsStatistics() (map[pChan]Timestamp, Timestamp, error) + // getMinTick returns the minimum last write timestamp between all pchans. getMinTick() Timestamp }