29
enableFairness bool,
30
serializer serialization.Serializer,
32
>
store := SqlStore{
33
>
DB: db,
34
>
logger: logger,
35
>
serializer: serializer,
36
>
}
37
>
userDataStore := userDataStore{SqlStore: store}
38
>
taskQueueStore := taskQueueStore{
39
>
SqlStore: store,
40
>
version: sqlplugin.MatchingTaskVersion1,
41
>
taskScanPartitions: uint32(taskScanPartitions),
42
>
}
43
>
if enableFairness {
44
taskQueueStore.version = sqlplugin.MatchingTaskVersion2
45
return newTaskManagerV2(db, userDataStore, taskQueueStore, logger, serializer)