Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove deprecated httpclient msgsender #7018

Merged
Merged
Show file tree
Hide file tree
Changes from 7 commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
2a88d67
remove legacy http client and message sender
g1rjeevan Jun 13, 2023
5931f45
Merge branch 'main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jun 13, 2023
fd39d49
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jun 15, 2023
d7391ce
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jun 21, 2023
59efdbb
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jun 29, 2023
5e1a422
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 13, 2023
a2b7256
Removed legacy http client and message sender along with usage.
g1rjeevan Jul 13, 2023
5547f28
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 15, 2023
a20347c
resolving on review commits.
g1rjeevan Jul 15, 2023
a96b312
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 18, 2023
341c882
resolving on review commits and fixing test failures
g1rjeevan Jul 18, 2023
e2f54d2
resolving on review commits and fixing test failures
g1rjeevan Jul 18, 2023
7d71130
Merge remote-tracking branch 'origin/remove-deprecated-httpclient-msg…
g1rjeevan Jul 18, 2023
6544a80
Update pkg/inmemorychannel/message_dispatcher_test.go
g1rjeevan Jul 18, 2023
e967f38
resolving on review commits and fixing test failures
g1rjeevan Jul 18, 2023
de8cab8
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 20, 2023
26efabb
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 21, 2023
67e22e1
Merge branch 'knative:main' into remove-deprecated-httpclient-msgsender
g1rjeevan Jul 21, 2023
54b3be8
remove the dispatcher benchmark test
g1rjeevan Jul 22, 2023
54abccc
import fix
g1rjeevan Jul 25, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 0 additions & 7 deletions pkg/inmemorychannel/message_dispatcher_benchmark_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,12 +76,6 @@ func BenchmarkDispatcher_dispatch_ok_through_2_channels(b *testing.B) {
},
}

// Let's mock this stuff!
httpSender, err := kncloudevents.NewHTTPMessageSenderWithTarget(channelA.URL.String())
if err != nil {
b.Fatal(err)
}

creydr marked this conversation as resolved.
Show resolved Hide resolved
multiChannelFanoutHandler, err := multichannelfanout.NewMessageHandlerWithConfig(context.TODO(), logger, channel.NewMessageDispatcher(logger), config, reporter)
if err != nil {
b.Fatal(err)
Expand All @@ -96,7 +90,6 @@ func BenchmarkDispatcher_dispatch_ok_through_2_channels(b *testing.B) {

dispatcher := NewMessageDispatcher(dispatcherArgs)
requestHandler := kncloudevents.CreateHandler(dispatcher.handler)
httpSender.Client = mockedHTTPClient(clientMock(channelA.URL.Host, transformations.URL.Host, channelB.URL.Host, receiver.URL.Host, requestHandler))

// Start the bench
b.ResetTimer()
Expand Down
20 changes: 0 additions & 20 deletions pkg/inmemorychannel/message_dispatcher_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -258,29 +258,9 @@ func TestDispatcher_dispatch(t *testing.T) {
}()
dispatcher.WaitReady()

// Ok now everything should be ready to send the event
httpsender, err := kncloudevents.NewHTTPMessageSenderWithTarget(channelAProxy.URL)
if err != nil {
t.Fatal(err)
}

req, err := httpsender.NewCloudEventRequest(context.Background())
if err != nil {
t.Fatal(err)
}

event := test.FullEvent()
_ = protocolhttp.WriteRequest(context.Background(), binding.ToMessage(&event), req)

res, err := httpsender.Send(req)
if err != nil {
t.Fatal(err)
}

if res.StatusCode != http.StatusAccepted {
t.Fatal("Expected 202, Have", res.StatusCode)
}

transformationsFailureWg.Wait()
deadLetterWg.Wait()
err = <-transformationsCh
Expand Down
83 changes: 0 additions & 83 deletions pkg/kncloudevents/http_client.go

This file was deleted.

1 change: 0 additions & 1 deletion pkg/kncloudevents/http_client_new.go
100644 → 100755
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,6 @@ func DeleteAddressableHandler(addressable duckv1.Addressable) {
// ConfigureConnectionArgs configures the new connection args.
// Use sparingly, because it might lead to creating a lot of clients, none of them sharing their connection pool!
func ConfigureConnectionArgs(ca *ConnectionArgs) {
configureConnectionArgsOldClient(ca) //also configure the connection args of the old client

clients.clientsMu.Lock()
defer clients.clientsMu.Unlock()
Expand Down
72 changes: 0 additions & 72 deletions pkg/kncloudevents/http_client_test.go

This file was deleted.

82 changes: 0 additions & 82 deletions pkg/kncloudevents/message_sender.go

This file was deleted.

Loading