Method Enqueue

queue.go:174–196

Enqueue enqueues a transaction to the Redis queue. Parameters: - ctx context.Context: The context for the operation. - transaction *model.Transaction: The transaction to be enqueued. Returns: - error: An error if the transaction could not be enqueued.

(ctx context.Context, transaction *model.Transaction)

// Returns:
// - error: An error if the transaction could not be enqueued.
func (q *Queue) Enqueue(ctx context.Context, transaction *model.Transaction) error {
	ctx, span := tracer.Start(ctx, "Adding Transaction To Redis Queue")
	defer span.End()

	payload, err := json.Marshal(transaction)
	if err != nil {
		return err
	}
	task := q.geTask(transaction, payload)
	_, err = q.Client.EnqueueContext(ctx, task, asynq.MaxRetry(q.config.Queue.MaxRetryAttempts))
	if err != nil {
		logrus.WithError(err).WithField("reference", transaction.Reference).Error("failed to enqueue transaction")
		return err
	}
	logrus.WithField("reference", transaction.Reference).Debug("successfully enqueued transaction")

	// Record enqueue metrics.
	metrics.QueueEnqueuedTotal.Add(ctx, 1,
		otelmetric.WithAttributes(attribute.String("queue_name", task.Type())),
	)

	return nil
}

// QueueInflightExpiry handles queuing a transaction for inflight expiration.
// This method is separate from the main Enqueue to ensure expiration is handled