ctx context.Context,
filter sqlplugin.BufferedEventsFilter,
var rows []sqlplugin.BufferedEventsRow
if err := mdb.SelectContext(ctx,
&rows,
getBufferedEventsQuery,
filter.ShardID,
filter.NamespaceID,
filter.WorkflowID,
filter.RunID,
); err != nil {
return nil, err
}
rows[i].NamespaceID = filter.NamespaceID
rows[i].WorkflowID = filter.WorkflowID