Function BenchmarkReadOps_Changes

rest/api_benchmark_test.go:188–260

(b *testing.B)

}

func BenchmarkReadOps_Changes(b *testing.B) {

	base.DisableTestLogging(b)

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

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

	doc1k_putDoc := fmt.Sprintf(doc_1k_format, "")

	// Create branched doc
	response := rt.SendAdminRequest("PUT", "/{{.keyspace}}/doc1k", doc1k_putDoc)
	if response.Code != 201 {
		log.Printf("Unexpected create response: %d  %s", response.Code, response.Body.Bytes())
	}

	var body db.Body
	require.NoError(b, base.JSONUnmarshal(response.Body.Bytes(), &body))
	revid := body["rev"].(string)
	_, rev1_digest := db.ParseRevID(rt.Context(), revid)
	response = rt.SendAdminRequest("PUT", fmt.Sprintf("/{{.keyspace}}/doc1k?rev=%s", revid), doc1k_putDoc)
	if response.Code != 201 {
		log.Printf("Unexpected add rev response: %d  %s", response.Code, response.Body.Bytes())
	}

	doc1k_rev2_meta := fmt.Sprintf(`"_revisions":{"start":2, "ids":["two", "%s"]},`, rev1_digest)
	doc1k_rev2 := fmt.Sprintf(doc_1k_format, doc1k_rev2_meta)
	response = rt.SendAdminRequest("PUT", "/{{.keyspace}}/doc1k?new_edits=false", doc1k_rev2)
	if response.Code != 201 {
		log.Printf("Unexpected add conflicting rev response: %d  %s", response.Code, response.Body.Bytes())
	}

	// Changes benchmarks use since=1 to exclude the user doc from the response
	changesBenchmarks := []struct {
		name   string
		URI    string
		asUser string
	}{
		{"Admin_Simple", "/{{.keyspace}}/_changes?since=1", ""},
		{"Admin_Longpoll", "/{{.keyspace}}/_changes?since=1&feed=longpoll", ""},
		{"Admin_StyleAllDocs", "/{{.keyspace}}/_changes?since=1&style=all_docs", ""},
		{"Admin_StyleAllDocsChannelFilter", "/{{.keyspace}}/_changes?since=1&style=all_docs&filter=sync_gateway/bychannel&channels=channel_1", ""},
		{"Admin_IncludeDocs", "/{{.keyspace}}/_changes?since=1&include_docs=true", ""},
		{"User_Simple", "/{{.keyspace}}/_changes?since=1", username},
		{"User_Longpoll", "/{{.keyspace}}/_changes?since=1&feed=longpoll", username},
		{"User_StyleAllDocs", "/{{.keyspace}}/_changes?since=1&style=all_docs", username},
		{"User_StyleAllDocsChannelFilter", "/{{.keyspace}}/_changes?since=1&style=all_docs&filter=sync_gateway/bychannel&channels=channel_1", username},
		{"User_IncludeDocs", "/{{.keyspace}}/_changes?since=1&include_docs=true", username},
	}

	for _, bm := range changesBenchmarks {
		b.Run(bm.name, func(b *testing.B) {
			var changesResponse *TestResponse
			for i := 0; i < b.N; i++ {