Function GetDefaultEmbeddingQueue

api/service/rag/embedding_queue.go:59–61

()

}

func GetDefaultEmbeddingQueue() EmbeddingQueue {
	return defaultEmbeddingQueue
}

// embeddingRedisQueue implements EmbeddingQueue using Redis Streams
type embeddingRedisQueue struct {