(opts *pullOpts)
| 2874 | type PullHeartbeat time.Duration |
| 2875 | |
| 2876 | func (h PullHeartbeat) configurePull(opts *pullOpts) error { |
| 2877 | if h <= 0 { |
| 2878 | return fmt.Errorf("%w: idle heartbeat has to be greater than 0", ErrInvalidArg) |
| 2879 | } |
| 2880 | opts.hb = time.Duration(h) |
| 2881 | return nil |
| 2882 | } |
| 2883 | |
| 2884 | // PullMaxBytes defines the max bytes allowed for a fetch request. |
| 2885 | type PullMaxBytes int |