Function TestScopedDistinctDiff

pkg/collector/scoped_distinct_string_test.go:95–143

(t *testing.T)

}

func TestScopedDistinctDiff(t *testing.T) {
	c := NewScopedDistinctStringWithDiff(0, 0, 0)

	c.Collect("scope1", "val1")
	expected := map[string][]string{
		"scope1": {"val1"},
	}
	assertMaps(t, expected, readScopedDistinctStringDiff(t, c))

	// no diff
	c.Collect("scope1", "val1")
	expected = map[string][]string{}
	assertMaps(t, expected, readScopedDistinctStringDiff(t, c))
	assertMaps(t, map[string][]string{}, readScopedDistinctStringDiff(t, c))

	// new value
	c.Collect("scope1", "val2")
	expected = map[string][]string{
		"scope1": {"val2"},
	}
	assertMaps(t, expected, readScopedDistinctStringDiff(t, c))
	assertMaps(t, map[string][]string{}, readScopedDistinctStringDiff(t, c))

	// new scope
	c.Collect("scope2", "val1")
	expected = map[string][]string{
		"scope2": {"val1"},
	}
	assertMaps(t, expected, readScopedDistinctStringDiff(t, c))
	assertMaps(t, map[string][]string{}, readScopedDistinctStringDiff(t, c))

	// all
	c.Collect("scope2", "val1")
	c.Collect("scope2", "val2")
	c.Collect("scope1", "val3")
	expected = map[string][]string{
		"scope1": {"val3"},
		"scope2": {"val2"},
	}
	assertMaps(t, expected, readScopedDistinctStringDiff(t, c))
	assertMaps(t, map[string][]string{}, readScopedDistinctStringDiff(t, c))

	// diff should error when diff is not enabled
	col := NewScopedDistinctString(0, 0, 0)
	col.Collect("scope1", "val1")
	res, err := col.Diff()
	require.Nil(t, res)
	require.Error(t, err, errDiffNotEnabled)
}

func readScopedDistinctStringDiff(t *testing.T, d *ScopedDistinctString) map[string][]string {
	res, err := d.Diff()