MCPcopy Index your code
hub / github.com/probelabs/goreplay / BinaryOutput

Struct BinaryOutput

output_binary.go:22–34  ·  view source on GitHub ↗

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`

Source from the content-addressed store, hash-verified

20// By default workers pool is dynamic and starts with 10 workers
21// You can specify fixed number of workers using `--output-tcp-workers`
22type 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

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected