newhttp.go

func newHTTPOutput(_ outputs.IndexManager, _ beat.Info,	stats outputs.Observer, cfg *common.Config) (outputs.Group, error) {
	config := clientConfig{}
	if err := cfg.Unpack(&config); err != nil {
		return outputs.Fail(err)
	}

	clients := make([]outputs.NetworkClient, config.Workers)
	for i := 0; i < config.Workers; i++ {
		clients[i] = &httpClient{
			stats:    stats,
			endpoint: config.Endpoint,
		}
	}

	return outputs.Success(confg.BatchSize, config.RetryLimit, clients...)
}