Function TestInstrumentation

elasticsearch_internal_test.go:1240–1471

nolint:gocyclo

(t *testing.T)

//nolint:gocyclo
func TestInstrumentation(t *testing.T) {
	successTp := func(_ *http.Request) (*http.Response, error) {
		h := http.Header{}
		h.Add("X-Elastic-Product", "Elasticsearch")
		h.Add("X-Found-Handling-Cluster", "foo-bar-cluster-id")
		h.Add("X-Found-Handling-Instance", "0123456789")
		return &http.Response{
			StatusCode: http.StatusOK,
			Header:     h,
			Body:       io.NopCloser(strings.NewReader(`{}`)),
		}, nil
	}

	errorTp := func(_ *http.Request) (*http.Response, error) {
		h := http.Header{}
		h.Add("X-Elastic-Product", "Elasticsearch")
		h.Add("X-Found-Handling-Cluster", "foo-bar-cluster-id")
		h.Add("X-Found-Handling-Instance", "0123456789")
		return &http.Response{
			StatusCode: http.StatusNotFound,
			Header:     h,
			Body: io.NopCloser(strings.NewReader(`{
  "error": {
    "root_cause": [
      {
        "type": "index_not_found_exception",
        "reason": "no such index [foo]",
        "resource.type": "index_or_alias",
        "resource.id": "foo",
        "index_uuid": "_na_",
        "index": "foo"
      }
    ],
    "type": "index_not_found_exception",
    "reason": "no such index [foo]",
    "resource.type": "index_or_alias",
    "resource.id": "foo",
    "index_uuid": "_na_",
    "index": "foo"
  },
  "status": 404
}`)),
		}, nil
	}

	reason := "index_not_found_exception"

	type args struct {
		roundTripFunc   func(request *http.Request) (*http.Response, error)
		instrumentation *FakeInstrumentation
	}
	tests := []struct {
		name string
		args args
		want *FakeInstrumentation
	}{
		{
			name: "with query",