(maxThreads int)
| 71 | } |
| 72 | |
| 73 | func WithMaxThreads(maxThreads int) Option { |
| 74 | return func(o *opt) error { |
| 75 | o.maxThreads = maxThreads |
| 76 | |
| 77 | return nil |
| 78 | } |
| 79 | } |
| 80 | |
| 81 | func WithMetrics(m Metrics) Option { |
| 82 | return func(o *opt) error { |
no outgoing calls