Function createMultiPartList

posting/list_test.go:1019–1065

(t *testing.T, size int, addFacet bool)

}

func createMultiPartList(t *testing.T, size int, addFacet bool) (*List, int) {
	// For testing, set the max list size to a lower threshold.
	defer setMaxListSize(maxListSize)
	maxListSize = 5000

	key := x.DataKey(x.AttrInRootNamespace(uuid.New().String()), 1331)
	ol, err := readPostingListFromDisk(key, ps, math.MaxUint64)
	require.NoError(t, err)
	commits := 0
	for i := 1; i <= size; i++ {
		edge := &pb.DirectedEdge{
			ValueId: uint64(i),
		}

		// Earlier we used to have label with the posting list to force creation of posting.
		if addFacet {
			edge.Facets = []*api.Facet{{Key: strconv.Itoa(i)}}
		}

		txn := Txn{StartTs: uint64(i)}
		addMutationHelper(t, ol, edge, Set, &txn)
		require.NoError(t, ol.commitMutation(uint64(i), uint64(i)+1))
		if i%2000 == 0 {
			kvs, err := ol.Rollup(nil, math.MaxUint64)
			require.NoError(t, err)
			require.NoError(t, writePostingListToDisk(kvs))
			ol, err = readPostingListFromDisk(key, ps, math.MaxUint64)
			require.NoError(t, err)
		}
		commits++
	}

	kvs, err := ol.Rollup(nil, math.MaxUint64)
	require.NoError(t, err)
	for _, kv := range kvs {
		require.Equal(t, uint64(size+1), kv.Version)
	}
	require.NoError(t, writePostingListToDisk(kvs))
	ol, err = readPostingListFromDisk(key, ps, math.MaxUint64)
	require.NoError(t, err)
	require.Nil(t, ol.plist.Pack)
	require.Equal(t, 0, len(ol.plist.Postings))
	require.True(t, len(ol.plist.Splits) > 0)
	verifySplits(t, ol.plist.Splits)

	return ol, commits
}

func createAndDeleteMultiPartList(t *testing.T, size int) (*List, int) {
	// For testing, set the max list size to a lower threshold.