Method queueInflightCommit

queue.go:308–329

queueInflightCommit enqueues a task to handle inflight commit for a transaction. Parameters: - transactionID string: The ID of the transaction. - commitAt time.Time: The scheduled time to automatically commit the inflight transaction. Returns: - error: An error if the task could not be enqueued.

(transactionID string, commitAt time.Time)

// Returns:
// - error: An error if the task could not be enqueued.
func (q *Queue) queueInflightCommit(transactionID string, commitAt time.Time) error {
	IPayload, err := json.Marshal(transactionID)
	if err != nil {
		return err
	}

	taskOptions := []asynq.Option{
		asynq.TaskID(transactionID),
		asynq.Queue(q.config.Queue.InflightCommitQueue),
		asynq.ProcessIn(time.Until(commitAt)),
	}

	task := asynq.NewTask(q.config.Queue.InflightCommitQueue, IPayload, taskOptions...)
	_, err = q.Client.Enqueue(task)
	if err != nil {
		logrus.WithError(err).WithField("transaction_id", transactionID).Error("failed to enqueue inflight commit")
		return err
	}

	logrus.WithField("transaction_id", transactionID).Debug("successfully enqueued inflight commit")
	return nil
}

// QueueInflightCommit schedules an automatic commit for an inflight transaction at the specified date.
//