Function BenchmarkReadOps_RevsDiff

rest/api_benchmark_test.go:262–318

(b *testing.B)

}

func BenchmarkReadOps_RevsDiff(b *testing.B) {

	base.DisableTestLogging(b)

	rt := NewRestTester(b, nil)
	defer rt.Close()
	defer PurgeDoc(rt, "doc1k")

	// Create target doc for revs_diff:
	doc1k_bulkDocs_meta := `"_id":"doc1k",
	"_rev":"12-abc",
	"_revisions":{
		"start": 12,
		"ids": ["abc", "eleven", "ten", "nine"]
		},`

	doc1k_bulkDocs_entry := fmt.Sprintf(doc_1k_format, doc1k_bulkDocs_meta)
	bulkDocs_body := fmt.Sprintf(`{"new_edits":false, "docs": [%s]}`, doc1k_bulkDocs_entry)
	response := rt.SendAdminRequest("POST", "/{{.keyspace}}/_bulk_docs", bulkDocs_body)
	if response.Code != 201 {
		log.Printf("Unexpected response: %d", response.Code)
		log.Printf("Response:%s", response.Body.Bytes())
	}

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

	revsDiffBody := `{"doc1k": ["10-ten", "9-nine"]}`
	revsDiffBenchmarks := []struct {
		name   string
		URI    string
		asUser string
	}{
		{"Admin", "/{{.keyspace}}/_revs_diff", ""},
		{"User", "/{{.keyspace}}/_revs_diff", username},
	}

	for _, bm := range revsDiffBenchmarks {
		b.Run(bm.name, func(b *testing.B) {
			var getResponse *TestResponse
			for i := 0; i < b.N; i++ {
				if bm.asUser == "" {
					getResponse = rt.SendAdminRequest("POST", bm.URI, revsDiffBody)
				} else {
					getResponse = rt.SendUserRequest("POST", bm.URI, revsDiffBody, bm.asUser)
				}
				b.StopTimer()
				if getResponse.Code != 200 {
					b.Logf("Unexpected response: %v", getResponse)
				}
				b.StartTimer()
			}
		})
	}

}