Skip to content
This repository was archived by the owner on Dec 11, 2023. It is now read-only.

Commit 084c879

Browse files
authored
Fix EventHubs old name (#188)
1 parent 21135a0 commit 084c879

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

pkg/triggermesh/adapter/adapter.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ func Image(object unstructured.Unstructured, version string) string {
4545
"AzureServiceBusQueueSource":
4646
return fmt.Sprintf("%s/azureservicebussource-adapter:%s", registry, version)
4747
case "AzureBlobStorageSource":
48-
return fmt.Sprintf("%s/azureeventhubsource-adapter:%s", registry, version)
48+
return fmt.Sprintf("%s/azureeventhubssource-adapter:%s", registry, version)
4949
case "GoogleCloudAuditLogsSource",
5050
"GoogleCloudStorageSource",
5151
"GoogleCloudSourceRepositoriesSource":

pkg/triggermesh/adapter/ce/sources.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ func sources(object unstructured.Unstructured) (EventAttributes, error) {
160160
ProducedEventTypes: o.GetEventTypes(),
161161
ProducedEventSource: o.AsEventSource(),
162162
}, nil
163-
case "AzureEventHubSource":
163+
case "AzureEventHubsSource":
164164
var o *sourcesv1alpha1.AzureEventHubsSource
165165
if err := runtime.DefaultUnstructuredConverter.FromUnstructured(object.Object, &o); err != nil {
166166
return EventAttributes{}, err

0 commit comments

Comments
 (0)