654
ctx context.Context,
655
filter sqlplugin.TimerTasksRangeFilter,
657
>
var rows []sqlplugin.TimerTasksRow
658
>
filter.InclusiveMinVisibilityTimestamp = mdb.converter.ToMySQLDateTime(filter.InclusiveMinVisibilityTimestamp)
659
>
filter.ExclusiveMaxVisibilityTimestamp = mdb.converter.ToMySQLDateTime(filter.ExclusiveMaxVisibilityTimestamp)
660
>
if err := mdb.SelectContext(ctx,
661
>
&rows,
662
>
getTimerTasksQuery,
663
>
filter.ShardID,
664
>
filter.InclusiveMinVisibilityTimestamp,
665
>
filter.InclusiveMinTaskID,
666
>
filter.InclusiveMinVisibilityTimestamp,
667
>
filter.ExclusiveMaxVisibilityTimestamp,
668
>
filter.PageSize,
669
>
); err != nil {
670
return nil, err
671
}
673
rows[i].VisibilityTimestamp = mdb.converter.FromMySQLDateTime(rows[i].VisibilityTimestamp)
674
}
676
}
677