@@ -537,7 +537,7 @@ func createEventsReporter(ctx context.Context, cloneOpts *git.CloneOptions, opts
537
537
return err
538
538
}
539
539
540
- if err := createSensor (repofs , store .Get ().EventsReporterName , resPath , opts .RuntimeName , store .Get ().EventsReporterName , "events" ); err != nil {
540
+ if err := createSensor (repofs , store .Get ().EventsReporterName , resPath , opts .RuntimeName , store .Get ().EventsReporterName , "events" , "data" ); err != nil {
541
541
return err
542
542
}
543
543
@@ -571,7 +571,7 @@ func createWorkflowReporter(ctx context.Context, cloneOpts *git.CloneOptions, op
571
571
return err
572
572
}
573
573
574
- if err := createSensor (repofs , store .Get ().WorkflowReporterName , resPath , opts .RuntimeName , store .Get ().WorkflowReporterName , "workflows" ); err != nil {
574
+ if err := createSensor (repofs , store .Get ().WorkflowReporterName , resPath , opts .RuntimeName , store .Get ().WorkflowReporterName , "workflows" , "data.object" ); err != nil {
575
575
return err
576
576
}
577
577
@@ -738,14 +738,15 @@ func createWorkflowReporterEventSource(repofs fs.FS, path, namespace string) err
738
738
return repofs .WriteYamls (repofs .Join (path , "event-source.yaml" ), eventSource )
739
739
}
740
740
741
- func createSensor (repofs fs.FS , name , path , namespace , eventSourceName , trigger string ) error {
741
+ func createSensor (repofs fs.FS , name , path , namespace , eventSourceName , trigger , dataKey string ) error {
742
742
sensor := eventsutil .CreateSensor (& eventsutil.CreateSensorOptions {
743
743
Name : name ,
744
744
Namespace : namespace ,
745
745
EventSourceName : eventSourceName ,
746
746
EventBusName : store .Get ().EventBusName ,
747
747
TriggerURL : cfConfig .GetCurrentContext ().URL + store .Get ().EventReportingEndpoint ,
748
748
Triggers : []string {trigger },
749
+ TriggerDestKey : dataKey ,
749
750
})
750
751
return repofs .WriteYamls (repofs .Join (path , "sensor.yaml" ), sensor )
751
752
}
0 commit comments