consumer/async.go
func (c *Consumer) SetMinRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.minRetryDelay, int64(d))
}
func (c *Consumer) SetMinRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.minRetryDelay, int64(d))
}
func ( c * Consumer ) SetMinRetryDelay ( d time . Duration ) { atomic . StoreInt64 ( & c . minRetryDelay , int64 ( d ) ) }
// SetMinRetryDelay sets the duration that automatically reconnecting methods
// on c (e.g. Firehose, Stream, TailingLogs) will sleep for after receiving
// an error from the traffic controller.
//
// Successive errors will double the sleep time, up to c's max retry delay,
// set by c.SetMaxRetryDelay.
//
// Defaults to DefaultMinRetryDelay.
SetMinRetryDelay sets the duration that automatically reconnecting methods on c ( e . g . Firehose Stream TailingLogs ) will sleep for after receiving an error from the traffic controller . Successive errors will double the sleep time up to c s max retry delay set by c . SetMaxRetryDelay . Defaults to DefaultMinRetryDelay .