Function BenchmarkReadOps_Get

rest/api_benchmark_test.go:68–117

(b *testing.B)

  }`

func BenchmarkReadOps_Get(b *testing.B) {

	base.DisableTestLogging(b)

	rt := NewRestTesterDefaultCollection(b, nil) // use non default in CBG-2618
	defer rt.Close()
	defer PurgeDoc(rt, "doc1k")

	doc1k_putDoc := fmt.Sprintf(doc_1k_format, "")
	response := rt.SendAdminRequest("PUT", "/{{.keyspace}}/doc1k", doc1k_putDoc)
	var body db.Body
	require.NoError(b, base.JSONUnmarshal(response.Body.Bytes(), &body))
	revid := body["rev"].(string)

	// Create user
	username := "user1"
	rt.SendAdminRequest("PUT", "/{{.db}}/_user/"+username, fmt.Sprintf(`{"name":"%s", "password":"letmein", "admin_channels":["channel_1"]}`, username))

	getBenchmarks := []struct {
		name   string
		URI    string
		asUser string
	}{
		{"Admin_Simple", "/{{.keyspace}}/doc1k", ""},
		{"Admin_WithRev", "/{{.keyspace}}/doc1k?rev=" + revid, ""},
		{"Admin_OpenRevsAll", "/{{.keyspace}}/doc1k?open_revs=all&rev=" + revid, ""},
		{"User_Simple", "/{{.keyspace}}/doc1k", username},
		{"User_WithRev", "/{{.keyspace}}/doc1k?rev=" + revid, username},
		{"User_OpenRevsAll", "/{{.keyspace}}/doc1k?open_revs=all&rev=" + revid, username},
	}

	for _, bm := range getBenchmarks {
		b.Run(bm.name, func(b *testing.B) {
			var getResponse *TestResponse
			for i := 0; i < b.N; i++ {
				if bm.asUser == "" {
					getResponse = rt.SendAdminRequest("GET", bm.URI, "")
				} else {
					getResponse = rt.SendUserRequest("GET", bm.URI, "", bm.asUser)
				}
				b.StopTimer()
				if getResponse.Code != 200 {
					log.Printf("Unexpected response status code: %d", getResponse.Code)
					panic("here")
				}
				b.StartTimer()
			}
		})
	}
}

// Benchmark 100% rev cache miss scenario
func BenchmarkReadOps_GetRevCacheMisses(b *testing.B) {