Function init

_benchmarks/benchmarks/actions/005_bulk.go:34–109

()

)

func init() {
	benchmarks.Register(
		benchmarks.Action{
			Name:     "bulk",
			Category: "core",

			NumWarmups:     10,
			NumRepetitions: 1000,
			NumOperations:  10000,

			SetupFunc: func(n int, c runner.Config) (*esapi.Response, error) {
				var (
					res *esapi.Response
					err error

					indexName     = "test-bench-bulk"
					indexSettings = `{"settings": { "number_of_shards": 3, "refresh_interval":"5s"}}`
				)
				res, _ = c.RunnerClient.Indices.Delete([]string{indexName})
				if res != nil && res.Body != nil {
					res.Body.Close()
				}
				res, err = c.RunnerClient.Indices.Create(
					indexName,
					c.RunnerClient.Indices.Create.WithBody(strings.NewReader(indexSettings)),
					c.RunnerClient.Indices.Create.WithWaitForActiveShards("1"))
				if err != nil {
					return res, err
				}
				res.Body.Close()
				return res, err
			},

			RunnerFunc: func(n int, c runner.Config) (*esapi.Response, error) {
				var (
					res *esapi.Response
					err error

					indexName = "test-bench-bulk"
					opMeta    = []byte("{ \"index\" : {} }\n")
					opBody    bytes.Buffer
				)

				opBody.Reset()

				docBody := bytes.NewBuffer(bytes.ReplaceAll(benchmarks.DataSources["small"].Bytes(), []byte("\n"), []byte("")))
				docBody.WriteRune('\n')

				for i := 0; i < c.NumOperations; i++ {
					var copyDocBody bytes.Buffer
					tr := io.TeeReader(docBody, &copyDocBody)
					opBody.Write(opMeta)
					opBody.ReadFrom(tr)
					docBody = &copyDocBody
				}

				res, err = c.RunnerClient.Bulk(&opBody, c.RunnerClient.Bulk.WithIndex(indexName))
				if err != nil {