Method queueIndexBatch

queue.go:110–129

queueIndexBatch enqueues a batch of items to be indexed in dependency order. This ensures that dependencies (e.g., balances) are indexed before the primary item (e.g., transaction). Uses the same IndexQueue but with a different task type for routing. Parameters: - batch interface{}: The batch conta

(batch interface{})

// Returns:
// - error: An error if the task could not be enqueued.
func (q *Queue) queueIndexBatch(batch interface{}) error {
	if q.config.TypeSense.Dns == "" {
		return nil
	}

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

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

// queueIndexData enqueues a task to index data in a specified collection.
//