Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NoOlderThan ¶
func NoOlderThan(max time.Duration) (consumer.StartingOffset, consumer.OffsetOutOfRange)
return a StartingOffset function which starts the consuming at no more than 'max' time in the past and a OffsetOutOfRange function which jumps forward to no more than 'max' time in the past
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.