Function BenchmarkReadOps_GetRevCacheMisses

rest/api_benchmark_test.go:120–186

Benchmark 100% rev cache miss scenario

(b *testing.B)

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

	base.DisableTestLogging(b)

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

	// Get database handle
	rtDatabase := rt.GetDatabase()
	revCacheSize := rtDatabase.Options.RevisionCacheOptions.MaxItemCount

	doc1k_putDoc := fmt.Sprintf(doc_1k_format, "")
	numDocs := int(revCacheSize + 1)
	var revid string
	for i := 0; i < numDocs; i++ {
		response := rt.SendAdminRequest("PUT", fmt.Sprintf("/{{.keyspace}}/doc1k_%d", i), doc1k_putDoc)
		// revid will be the same for all docs
		if i == 0 {
			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", fmt.Sprintf("/{{.keyspace}}/doc1k?rev=%s", revid), ""},
		{"Admin_OpenRevsAll", fmt.Sprintf("/{{.keyspace}}/doc1k?open_revs=all&rev=%s", revid), ""},
		{"User_Simple", "/{{.keyspace}}/doc1k", username},
		{"User_WithRev", fmt.Sprintf("/{{.keyspace}}/doc1k?rev=%s", revid), username},
		{"User_OpenRevsAll", fmt.Sprintf("/{{.keyspace}}/doc1k?open_revs=all&rev=%s", revid), username},
	}

	for _, bm := range getBenchmarks {
		b.Run(bm.name, func(b *testing.B) {
			var getResponse *TestResponse
			rt.GetDatabase().FlushRevisionCacheForTest()
			for i := 0; i < b.N; i++ {
				// update key in URI
				docNum := i % numDocs
				newDocID := fmt.Sprintf("doc1k_%d", docNum)
				docURI := strings.Replace(bm.URI, "doc1k", newDocID, 1)

				if bm.asUser == "" {
					getResponse = rt.SendAdminRequest("GET", docURI, "")
				} else {
					getResponse = rt.SendUserRequest("GET", docURI, "", bm.asUser)
				}
				b.StopTimer()