Skip to content

Instantly share code, notes, and snippets.

@bschaeffer

bschaeffer/init.go

Created July 8, 2020 12:25
Show Gist options
  • Save bschaeffer/64b6ae409337ddc217bd95a3e19923c5 to your computer and use it in GitHub Desktop.
Save bschaeffer/64b6ae409337ddc217bd95a3e19923c5 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
init.go
package fshttp
import (
"github.com/elastic/beats/libbeat/beat"
"github.com/elastic/beats/libbeat/common"
"github.com/elastic/beats/libbeat/outputs"
)
func init() {
outputs.RegisterType("http", newHTTPOutput)
}
func newHTTPOutput(_ outputs.IndexManager, _ beat.Info, stats outputs.Observer, cfg *common.Config) (outputs.Group, error) {
clients := []outputs.NetworkClient{}
return outputs.Success(batchSize, retryLimit, clients...)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment