diff --git a/test/rekt/features/broker/control_plane.go b/test/rekt/features/broker/control_plane.go index 5cd8be2283..cc0cf2c2dc 100644 --- a/test/rekt/features/broker/control_plane.go +++ b/test/rekt/features/broker/control_plane.go @@ -56,10 +56,12 @@ func ControlPlaneConformance(brokerName string) *feature.FeatureSet { *ControlPlaneTrigger_WithBrokerLifecycle(), *ControlPlaneTrigger_WithValidFilters(brokerName), *ControlPlaneTrigger_WithInvalidFilters(brokerName), - *ControlPlaneDelivery(), - *ControlPlaneEventRouting(), }, } + + // Add each feature of event routing and Delivery tests as a new feature + addControlPlaneEventRouting(fs) + addControlPlaneDelivery(fs) // TODO: This is not a control plane test, or at best it is a blend with data plane. // Must("Events that pass the attributes filter MUST include context or extension attributes that match all key-value pairs exactly.", todo) @@ -286,8 +288,7 @@ func ControlPlaneTrigger_WithInvalidFilters(brokerName string) *feature.Feature return f } -func ControlPlaneDelivery() *feature.Feature { - f := feature.NewFeatureNamed("Delivery Spec") +func addControlPlaneDelivery(fs *feature.FeatureSet) { for i, tt := range []struct { name string @@ -331,7 +332,12 @@ func ControlPlaneDelivery() *feature.Feature { t1FailCount: 3, // Should get event. t2FailCount: 2, // Should end up in DLQ. }} { + // TODO: Each of these creates quite a few resources. We need to figure out a way + // to delete the resources for each Feature once the test completes. Today it's + // not easy (if at all possible) to do this, since Environment contains the References + // to created resources, but it's not granular enough. brokerName := fmt.Sprintf("dlq-test-%d", i) + f := feature.NewFeatureNamed(fmt.Sprintf("Delivery Spec - %s", brokerName)) prober := createBrokerTriggerDeliveryTopology(f, brokerName, tt.brokerDS, tt.t1DS, tt.t2DS, tt.t1FailCount, tt.t2FailCount) // Send an event into the matrix and hope for the best @@ -360,14 +366,11 @@ func ControlPlaneDelivery() *feature.Feature { }) f.Stable("Conformance").Should(tt.name, assertExpectedEvents(prober, expectedEvents)) + fs.Features = append(fs.Features, *f) } - - return f } -func ControlPlaneEventRouting() *feature.Feature { - f := feature.NewFeatureNamed("Event Routing Spec") - +func addControlPlaneEventRouting(fs *feature.FeatureSet) { for i, tt := range []struct { name string config []triggerTestConfig @@ -516,7 +519,12 @@ func ControlPlaneEventRouting() *feature.Feature { }, }, }} { + // TODO: Each of these creates quite a few resources. We need to figure out a way + // to delete the resources for each Feature once the test completes. Today it's + // not easy (if at all possible) to do this, since Environment contains the References + // to created resources, but it's not granular enough. brokerName := fmt.Sprintf("routing-test-%d", i) + f := feature.NewFeatureNamed(fmt.Sprintf("Event Routing Spec - %s", brokerName)) f.Setup("Set Broker Name", setBrokerName(brokerName)) prober := createBrokerTriggerEventRoutingTopology(f, brokerName, tt.config) @@ -549,9 +557,8 @@ func ControlPlaneEventRouting() *feature.Feature { }) f.Stable("Conformance").Should(tt.name, assertExpectedRoutedEvents(prober, expectedEvents)) + fs.Features = append(fs.Features, *f) } - - return f } type EventingClient struct {