()
| 59 | } |
| 60 | |
| 61 | func (o *BinaryOutput) workerMaster() { |
| 62 | for { |
| 63 | newWorkers := <-o.needWorker |
| 64 | for i := 0; i < newWorkers; i++ { |
| 65 | go o.startWorker() |
| 66 | } |
| 67 | |
| 68 | // Disable dynamic scaling if workers poll fixed size |
| 69 | if o.config.Workers != 0 { |
| 70 | return |
| 71 | } |
| 72 | } |
| 73 | } |
| 74 | |
| 75 | func (o *BinaryOutput) startWorker() { |
| 76 | client := NewTCPClient(o.address, &TCPClientConfig{ |
no test coverage detected