code: func (c *Consumer) SetMinRetryDelay(d time.Duration) {
  	atomic.StoreInt64(&c.minRetryDelay, int64(d))
  }
docs: // 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.