Method EnqueueIfNotExists

api/service/rag/embedding_queue.go:47–47

(ctx context.Context, task EmbeddingTask)

// EmbeddingQueue is the interface for enqueue and worker management
type EmbeddingQueue interface {
	EnqueueIfNotExists(ctx context.Context, task EmbeddingTask) (bool, error)
	StartOrUpdateWorkers(ctx context.Context, eid int64) error
	Shutdown(ctx context.Context) error
}