| 11 | ) |
| 12 | |
| 13 | type Producer struct { |
| 14 | Source string |
| 15 | Interval time.Duration |
| 16 | DrainPerTick int |
| 17 | Store *config.Store |
| 18 | Client *Client |
| 19 | Spool *Spool |
| 20 | } |
| 21 | |
| 22 | // Run blocks until ctx is cancelled. Each tick pings all enabled servers, |
| 23 | // pushes the batch, and (on success) drains up to DrainPerTick spooled |
nothing calls this directly
no outgoing calls
no test coverage detected