Function newTaskPersistence

common/persistence/sql/task_store.go:25–48

newTaskPersistence creates a new instance of TaskStore

(
	db sqlplugin.DB,
	taskScanPartitions int,
	logger log.Logger,
	enableFairness bool,
	serializer serialization.Serializer,
)

// newTaskPersistence creates a new instance of TaskStore
func newTaskPersistence(
	db sqlplugin.DB,
	taskScanPartitions int,
	logger log.Logger,
	enableFairness bool,
	serializer serialization.Serializer,
) (persistence.TaskStore, error) {
	store := SqlStore{
		DB:         db,
		logger:     logger,
		serializer: serializer,
	}
	userDataStore := userDataStore{SqlStore: store}
	taskQueueStore := taskQueueStore{
		SqlStore:           store,
		version:            sqlplugin.MatchingTaskVersion1,
		taskScanPartitions: uint32(taskScanPartitions),
	}
	if enableFairness {
		taskQueueStore.version = sqlplugin.MatchingTaskVersion2
		return newTaskManagerV2(db, userDataStore, taskQueueStore, logger, serializer)
	}
	return newTaskManagerV1(db, userDataStore, taskQueueStore, logger, serializer)
}