Struct embeddingRedisQueue

api/service/rag/embedding_queue.go:64–69

embeddingRedisQueue implements EmbeddingQueue using Redis Streams

// embeddingRedisQueue implements EmbeddingQueue using Redis Streams
type embeddingRedisQueue struct {
	rdb       redis.Cmdable
	opts      WorkerOptions
	workersMu sync.Mutex
	workers   map[int64]*eidWorkerPool // per-eid pool
}

type eidWorkerPool struct {
	eid        int64