8
8
"sort"
9
9
10
10
"github.com/argoproj/argo-events/pkg/apis/events/v1alpha1"
11
- aev1 "github.com/argoproj/argo-events/pkg/apis/events/v1alpha1"
12
11
controllerscommon "github.com/argoproj/argo-events/pkg/reconciler/common"
13
12
sharedutil "github.com/argoproj/argo-events/pkg/shared/util"
14
13
"go.uber.org/zap"
@@ -26,15 +25,15 @@ import (
26
25
// AdaptorArgs are the args needed to create a sensor deployment
27
26
type AdaptorArgs struct {
28
27
Image string
29
- EventSource * aev1 .EventSource
28
+ EventSource * v1alpha1 .EventSource
30
29
Labels map [string ]string
31
30
}
32
31
33
32
// Reconcile does the real logic
34
33
func Reconcile (client controllerClient.Client , args * AdaptorArgs , logger * zap.SugaredLogger ) error {
35
34
ctx := context .Background ()
36
35
eventSource := args .EventSource
37
- eventBus := & aev1 .EventBus {}
36
+ eventBus := & v1alpha1 .EventBus {}
38
37
eventBusName := v1alpha1 .DefaultEventBusName
39
38
if len (eventSource .Spec .EventBusName ) > 0 {
40
39
eventBusName = eventSource .Spec .EventBusName
@@ -351,7 +350,7 @@ func buildDeployment(args *AdaptorArgs, eventBus *aev1.EventBus) (*appv1.Deploym
351
350
},
352
351
Spec : * deploymentSpec ,
353
352
}
354
- if err := controllerscommon .SetObjectMeta (args .EventSource , deployment , aev1 .EventSourceGroupVersionKind ); err != nil {
353
+ if err := controllerscommon .SetObjectMeta (args .EventSource , deployment , v1alpha1 .EventSourceGroupVersionKind ); err != nil {
355
354
return nil , err
356
355
}
357
356
0 commit comments