Struct HTTPOutput

output_http.go:54–64

HTTPOutput plugin manage pool of workers which send request to replayed server By default workers pool is dynamic and starts with 1 worker or workerMin workers You can specify maximum number of workers using `--output-http-workers`

// By default workers pool is dynamic and starts with 1 worker or workerMin workers
// You can specify maximum number of workers using `--output-http-workers`
type HTTPOutput struct {
	activeWorkers int32
	config        *HTTPOutputConfig
	queueStats    *GorStat
	elasticSearch *ESPlugin
	client        *HTTPClient
	stopWorker    chan struct{}
	queue         chan *Message
	responses     chan *response
	stop          chan bool // Channel used only to indicate goroutine should shutdown
}

// NewHTTPOutput constructor for HTTPOutput
// Initialize workers