(opts *pullOpts)
| 1250 | } |
| 1251 | |
| 1252 | func (ttl MaxWait) configurePull(opts *pullOpts) error { |
| 1253 | opts.ttl = time.Duration(ttl) |
| 1254 | return nil |
| 1255 | } |
| 1256 | |
| 1257 | // AckWait sets the maximum amount of time we will wait for an ack. |
| 1258 | type AckWait time.Duration |