()
| 823 | } |
| 824 | |
| 825 | func (w *Writer) batchTimeout() time.Duration { |
| 826 | if w.BatchTimeout > 0 { |
| 827 | return w.BatchTimeout |
| 828 | } |
| 829 | return 1 * time.Second |
| 830 | } |
| 831 | |
| 832 | func (w *Writer) readTimeout() time.Duration { |
| 833 | if w.ReadTimeout > 0 { |
no outgoing calls
no test coverage detected