Please run goimports. diff --git a/test/rekt/features/broker_deleted_recreated.go b/test/rekt/features/broker_deleted_recreated.go index 52fe1bc..a0f21c0 100644 --- a/test/rekt/features/broker_deleted_recreated.go +++ b/test/rekt/features/broker_deleted_recreated.go @@ -121,9 +121,9 @@ func BrokerDeletedRecreated() *feature.Feature { // therefore, we check that eventually, the last few events sent (16 for no particular reason) are all received by the sink2 only // and contain an uninterrupted (without any missing sequence numbers) source sequence as sent by the source with eventshub.AddSequence EventSequenceOnStores(sink1, sink2). - MatchingReceived(eventMatchers...). // ... when ... - OrderedBySourceSequence(). // ..., and taken the ... - LastN(16). // ... events, the sequence... + MatchingReceived(eventMatchers...). // ... when ... + OrderedBySourceSequence(). // ..., and taken the ... + LastN(16). // ... events, the sequence... ContainsOnlyEventsObservedBy(sink2). // ...and... IsAnUninterruptedSourceSequence(). Eventually(),

Please run goimports. diff --git a/test/rekt/features/sequence_assertions.go b/test/rekt/features/sequence_assertions.go index 2abd279..40087bb 100644 --- a/test/rekt/features/sequence_assertions.go +++ b/test/rekt/features/sequence_assertions.go @@ -20,15 +20,17 @@ import ( "cmp" "context" "fmt" + "knative.dev/reconciler-test/pkg/eventshub/assert" + "slices" + cetest "github.com/cloudevents/sdk-go/v2/test" types2 "github.com/cloudevents/sdk-go/v2/types" "k8s.io/apimachinery/pkg/util/wait" "knative.dev/reconciler-test/pkg/environment" "knative.dev/reconciler-test/pkg/eventshub" "knative.dev/reconciler-test/pkg/feature" - "slices" ) type sequenceTransformationOrAssertion func(ctx context.Context, events []eventshub.EventInfo) ([]eventshub.EventInfo, error)

Process completed with exit code 1.