Skip to content

Commit 9446dfe

Browse files
matzewpierDipi
andauthored
Update test/rekt/features/integrationsink/features.go
Co-authored-by: Pierangelo Di Pilato <[email protected]>
1 parent 3d508cf commit 9446dfe

File tree

1 file changed

+4
-11
lines changed

1 file changed

+4
-11
lines changed

test/rekt/features/integrationsink/features.go

+4-11
Original file line numberDiff line numberDiff line change
@@ -131,17 +131,10 @@ func OIDC() *feature.Feature {
131131
eventshub.AddSequence,
132132
eventshub.SendMultipleEvents(2, time.Millisecond)))
133133

134-
f.Requirement("install source for ksink without audience", func(ctx context.Context, t feature.T) {
135-
addr, err := integrationsink.Address(ctx, sourceNoAudience)
136-
if err != nil {
137-
t.Error(err)
138-
return
139-
}
140-
141-
eventshub.Install(sourceNoAudience,
142-
eventshub.StartSenderURLTLS(addr.URL.String(), addr.CACerts),
143-
eventshub.InputEvent(eventNoAudience))(ctx, t)
144-
})
134+
f.Requirement("install source for ksink without audience", eventshub.Install(sourceNoAudience,
135+
eventshub.StartSenderToResourceTLS(integrationsink.GVR(), integrationSink, nil),
136+
eventshub.InputEvent(eventNoAudience)
137+
))
145138

146139
f.Assert("IntegrationSink has audience in address", func(ctx context.Context, t feature.T) {
147140
gvk := schema.GroupVersionKind{

0 commit comments

Comments
 (0)