Function TestDrain_Train_PatternEmergence

pkg/drain/drain_test.go:196–213

(t *testing.T)

}

func TestDrain_Train_PatternEmergence(t *testing.T) {
	t.Parallel()

	drain := New("test-tenant", DefaultConfig())

	// First span - creates initial cluster
	cluster1 := drain.Train("GET /api/users/123")
	require.NotNil(t, cluster1)
	pattern1 := cluster1.String()

	// Second similar span - should match and update pattern
	cluster2 := drain.Train("GET /api/users/456")
	require.NotNil(t, cluster2)

	pattern2 := cluster2.String()
	require.Contains(t, pattern2, "<_>", "pattern should emerge with parameter marker")
	require.NotEqual(t, pattern1, pattern2, "pattern should change after merging")
}