risingwave_stream::executor::source

Function get_infinite_backoff_strategy

source 
pub fn get_infinite_backoff_strategy() -> impl Iterator<Item = Duration>