-
Notifications
You must be signed in to change notification settings - Fork 404
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
Update NATS ClusterChannelProvisioner to NATS CRD #5517
Conversation
passing test cases Init Messaging Client
ba42a1b
to
51c03c2
Compare
components/event-bus/internal/knative/util/kn-subscription-builder.go
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@anishj0shi On another note, I just found this
kyma/components/event-bus/cmd/event-publish-service/handlers/publish.go
Lines 160 to 161 in 4ae04fa
channelName := eventBusUtil.GetChannelName(&publishRequest.SourceID, &publishRequest.EventType, | |
&publishRequest.EventTypeVersion) |
the publish service gets the channel name using the same algorithm instead of hitting the apiserver. Almost overlooked this. Querying with labels won't be enough.
Edit: Not true, it indeed hits the api server and gets the channel URL.
components/event-bus/cmd/event-publish-service/publisher/publisher.go
Outdated
Show resolved
Hide resolved
components/event-bus/cmd/event-publish-service/publisher/publisher.go
Outdated
Show resolved
Hide resolved
components/event-bus/cmd/event-publish-service/publisher/publisher.go
Outdated
Show resolved
Hide resolved
payload *[]byte) (*api.Error, string, string) { | ||
|
||
// knative Channel reference should not be nil | ||
if channel == nil { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
channel will never be nil
as in GetChannelByLabels(), error is thrown if no channels are found
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Initially, it was designed to be a public method. Now I've removed this check as the method is now private
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Thanks for the good work!
components/event-bus/cmd/event-publish-service/application/application_test.go
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
evclientset "github.com/knative/eventing/pkg/client/clientset/versioned" | ||
eventingv1alpha1 "github.com/knative/eventing/pkg/client/clientset/versioned/typed/eventing/v1alpha1" | ||
messagingv1alpha1 "github.com/knative/eventing/pkg/client/clientset/versioned/typed/messaging/v1alpha1" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
could we rename this? it is kinda confusing if you compare it to line 15
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
- Upgrade knative eventing chart to 0.8.0 - Pre and Post Upgrade hooks - Working NATS Provisioner - remove old NATS deployment - Bump latest image from #5517
Description
Changes proposed in this pull request:
Related issue(s)