@@ -35,7 +35,7 @@ func (m *Module) batchRequests(ctx context.Context, requests []*model.QueueEvent
35
35
}
36
36
37
37
// Persist the events
38
- createRequest := & model.CreateRequest {Document : eventDocs , Operation : utils .All }
38
+ createRequest := & model.CreateRequest {Document : convertToArray ( eventDocs ) , Operation : utils .All }
39
39
if err := m .crud .InternalCreate (ctx , m .config .DBType , m .project , m .config .Col , createRequest ); err != nil {
40
40
return errors .New ("eventing module couldn't log the request -" + err .Error ())
41
41
}
@@ -133,21 +133,20 @@ func getCreateRows(doc interface{}, op string) []interface{} {
133
133
return rows
134
134
}
135
135
136
- func (m * Module ) getMatchingRules (name string , options map [string ]string ) []* config.EventingRule {
137
- rules := make ([] * config.EventingRule , 0 )
136
+ func (m * Module ) getMatchingRules (name string , options map [string ]string ) []config.EventingRule {
137
+ var rules [] config.EventingRule
138
138
139
139
for _ , rule := range m .config .Rules {
140
140
if rule .Type == name && isOptionsValid (rule .Options , options ) {
141
- rules = append (rules , & rule )
141
+ rules = append (rules , rule )
142
142
}
143
143
}
144
144
145
145
for _ , rule := range m .config .InternalRules {
146
146
if rule .Type == name && isOptionsValid (rule .Options , options ) {
147
- rules = append (rules , & rule )
147
+ rules = append (rules , rule )
148
148
}
149
149
}
150
-
151
150
return rules
152
151
}
153
152
0 commit comments