Method geTask

queue.go:226–235

geTask generates a task for a transaction and assigns it to a specific queue based on the balance ID. It ensures that transactions are evenly distributed across multiple queues by hashing the balance ID. This approach helps to avoid race conditions on a balance by ensuring that all transactions rela

(transaction *model.Transaction, payload []byte)

// Returns:
// - *asynq.Task: The generated task ready to be enqueued.
func (q *Queue) geTask(transaction *model.Transaction, payload []byte) *asynq.Task {
	queueName := q.transactionQueueName(transaction)

	taskOptions := []asynq.Option{asynq.TaskID(transaction.TransactionID), asynq.Queue(queueName)}
	if !transaction.ScheduledFor.IsZero() {
		taskOptions = append(taskOptions, asynq.ProcessIn(time.Until(transaction.ScheduledFor)))
	}

	return asynq.NewTask(queueName, payload, taskOptions...)
}

func (q *Queue) transactionQueueName(transaction *model.Transaction) string {
	if q.config.Queue.EnableHotLane && transaction != nil && transaction.MetaData != nil {