Method queueIndexData

queue.go:140–164

queueIndexData enqueues a task to index data in a specified collection. Parameters: - id string: The ID of the data to index. - collection string: The name of the collection to index the data in. - data interface{}: The data to be indexed. Returns: - error: An error if the task could not be enqueu

(id string, collection string, data interface{})

// Returns:
// - error: An error if the task could not be enqueued.
func (q *Queue) queueIndexData(id string, collection string, data interface{}) error {
	if q.config.TypeSense.Dns == "" {
		return nil
	}

	payload := map[string]interface{}{
		"collection": collection,
		"payload":    data,
	}

	IPayload, err := json.Marshal(payload)
	if err != nil {
		return err
	}

	taskOptions := []asynq.Option{asynq.Queue(q.config.Queue.IndexQueue)}
	task := asynq.NewTask(q.config.Queue.IndexQueue, IPayload, taskOptions...)
	_, err = q.Client.Enqueue(task)
	if err != nil {
		logrus.WithError(err).WithField("id", id).Error("failed to enqueue index data")
		return err
	}
	logrus.WithField("id", id).Debug("successfully enqueued index data")
	return nil
}

// Enqueue enqueues a transaction to the Redis queue.
//