125
}
126
128
>
shardID := rand.Int31()
129
>
timestamp := s.now()
130
>
taskID := int64(1)
131
>
132
>
task := s.newRandomTimerTaskRow(shardID, timestamp, taskID)
133
>
result, err := s.store.InsertIntoTimerTasks(newExecutionContext(), []sqlplugin.TimerTasksRow{task})
134
>
s.NoError(err)
135
>
rowsAffected, err := result.RowsAffected()
136
>
s.NoError(err)
137
>
s.Equal(1, int(rowsAffected))
138
>
139
>
rangeFilter := sqlplugin.TimerTasksRangeFilter{
140
>
ShardID: shardID,
141
>
InclusiveMinTaskID: taskID,
142
>
InclusiveMinVisibilityTimestamp: timestamp,
143
>
ExclusiveMaxVisibilityTimestamp: timestamp.Add(common.ScheduledTaskMinPrecision),
144
>
PageSize: 1,
145
>
}
146
>
rows, err := s.store.RangeSelectFromTimerTasks(newExecutionContext(), rangeFilter)
147
>
s.NoError(err)
148
>
for index := range rows {
149
>
rows[index].ShardID = shardID
150
>
}
151
>
s.Equal([]sqlplugin.TimerTasksRow{task}, rows)
152
}
153