BinaryOutput plugin manage pool of workers which send request to replayed server By default workers pool is dynamic and starts with 10 workers You can specify fixed number of workers using `--output-tcp-workers`
| 20 | // By default workers pool is dynamic and starts with 10 workers |
| 21 | // You can specify fixed number of workers using `--output-tcp-workers` |
| 22 | type BinaryOutput struct { |
| 23 | // Keep this as first element of struct because it guarantees 64bit |
| 24 | // alignment. atomic.* functions crash on 32bit machines if operand is not |
| 25 | // aligned at 64bit. See https://github.com/golang/go/issues/599 |
| 26 | activeWorkers int64 |
| 27 | address string |
| 28 | queue chan *Message |
| 29 | responses chan response |
| 30 | needWorker chan int |
| 31 | quit chan struct{} |
| 32 | config *BinaryOutputConfig |
| 33 | queueStats *GorStat |
| 34 | } |
| 35 | |
| 36 | // NewBinaryOutput constructor for BinaryOutput |
| 37 | // Initialize workers |
nothing calls this directly
no outgoing calls
no test coverage detected