fix: wire Dream embed protocol through scheduler → RunDreamCycle

Dream now uses EmbedWithProtocol instead of Embed, routing keyword
embeddings through the configured protocol (ollama or openai).

CTX_DREAM_EMBED_PROTOCOL env var controls the wire format.
With openai protocol + llama-embed sidecar, Dream embeddings run
on CPU via /v1/embeddings — verified in logs: llama-embed receives
POST /v1/embeddings from ctx container.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: GottZ

docker-compose.yml

@@ -109,7 +109,7 @@ services:
   #   volumes:
   #     - /opt/models:/models:ro
   #   command: >
-  #     --model /models/qwen3-embedding-8b.gguf
+  #     --model /models/Qwen3-Embedding-8B-Q4_K_M.gguf
   #     --embedding
   #     --pooling last
   #     --port 8081

go/cmd/ctxd/config.go

@@ -48,10 +48,11 @@ type Config struct {
 	DreamModel       string
 	DreamNumCtx      int
 	DreamThink       string // "true", "false", or "" (fallback: ChatThink)
-	DreamEmbedHost   string // Separate embed host for Dream (empty = EmbedHost)
-	DreamEmbedAPIKey string
-	DreamEmbedModel  string
-	DreamEmbedNumCtx int
+	DreamEmbedHost     string // Separate embed host for Dream (empty = EmbedHost)
+	DreamEmbedAPIKey   string
+	DreamEmbedProtocol string // "ollama" or "openai" (empty = EmbedProtocol)
+	DreamEmbedModel    string
+	DreamEmbedNumCtx   int
 
 	// Timezone for temporal resolution (e.g. "Europe/Berlin").
 	// Defaults to UTC. Ensures "heute" resolves correctly for the user's timezone.
@@ -143,10 +144,11 @@ func LoadConfig() (Config, error) {
 		DreamModel:    getEnv("CTX_DREAM_MODEL", ""),
 		DreamNumCtx:  dreamNumCtx,
 		DreamThink:       getEnv("CTX_DREAM_THINK", ""),
-		DreamEmbedHost:   getEnv("CTX_DREAM_EMBED_HOST", ""),
-		DreamEmbedAPIKey: getEnv("CTX_DREAM_EMBED_API_KEY", ""),
-		DreamEmbedModel:  getEnv("CTX_DREAM_EMBED_MODEL", ""),
-		DreamEmbedNumCtx: getEnvIntSafe("CTX_DREAM_EMBED_NUM_CTX", 0),
+		DreamEmbedHost:     getEnv("CTX_DREAM_EMBED_HOST", ""),
+		DreamEmbedAPIKey:   getEnv("CTX_DREAM_EMBED_API_KEY", ""),
+		DreamEmbedProtocol: getEnv("CTX_DREAM_EMBED_PROTOCOL", ""),
+		DreamEmbedModel:    getEnv("CTX_DREAM_EMBED_MODEL", ""),
+		DreamEmbedNumCtx:   getEnvIntSafe("CTX_DREAM_EMBED_NUM_CTX", 0),
 
 		Timezone: tz,
 

go/cmd/ctxd/main.go

@@ -94,17 +94,19 @@ func main() {
 		EmbedHost:    cfg.EmbedHost,
 		EmbedAPIKey:  cfg.EmbedAPIKey,
 		EmbedModel:   cfg.EmbedModel,
-		EmbedNumCtx:  cfg.EmbedNumCtx,
+		EmbedNumCtx:      cfg.EmbedNumCtx,
+		EmbedProtocol:    cfg.EmbedProtocol,
 		DreamHost:    cfg.DreamHost,
 		DreamAPIKey:  cfg.DreamAPIKey,
 		ChatModel:    cfg.ChatModel,
 		DreamModel:   cfg.DreamModel,
 		DreamThink:       dreamThink,
 		DreamNumCtx:      cfg.DreamNumCtx,
-		DreamEmbedHost:   cfg.DreamEmbedHost,
-		DreamEmbedAPIKey: cfg.DreamEmbedAPIKey,
-		DreamEmbedModel:  cfg.DreamEmbedModel,
-		DreamEmbedNumCtx: cfg.DreamEmbedNumCtx,
+		DreamEmbedHost:     cfg.DreamEmbedHost,
+		DreamEmbedAPIKey:   cfg.DreamEmbedAPIKey,
+		DreamEmbedProtocol: cfg.DreamEmbedProtocol,
+		DreamEmbedModel:    cfg.DreamEmbedModel,
+		DreamEmbedNumCtx:   cfg.DreamEmbedNumCtx,
 	}
 	scheduler := events.NewScheduler(pool, schedulerConfig)
 	go scheduler.Run(ctx)

go/internal/dream/dream.go

@@ -50,7 +50,7 @@ const CycleTimeout = 180 * time.Second
 
 // RunDreamCycle executes one dream cycle: pick → keywords → search → evaluate → link.
 // Returns the number of links created, or 0 if no block was available.
-func RunDreamCycle(ctx context.Context, pool *pgxpool.Pool, embedHost, embedAPIKey, embedModel string, embedNumCtx int, chatHost, chatAPIKey, chatModel string, think *bool, opts llm.Options, readScopes []string) (int, error) {
+func RunDreamCycle(ctx context.Context, pool *pgxpool.Pool, embedHost, embedAPIKey, embedProtocol, embedModel string, embedNumCtx int, chatHost, chatAPIKey, chatModel string, think *bool, opts llm.Options, readScopes []string) (int, error) {
 	ctx, cancel := context.WithTimeout(ctx, CycleTimeout)
 	defer cancel()
 	// Step 1: Pick a block.
@@ -87,7 +87,7 @@ func RunDreamCycle(ctx context.Context, pool *pgxpool.Pool, embedHost, embedAPIK
 	)
 
 	// Step 3: Search per keyword via RRF.
-	candidates, err := searchByKeywords(ctx, pool, embedHost, embedAPIKey, embedModel, embedNumCtx, keywords, readScopes, block.ID, block.Scope)
+	candidates, err := searchByKeywords(ctx, pool, embedHost, embedAPIKey, embedProtocol, embedModel, embedNumCtx, keywords, readScopes, block.ID, block.Scope)
 	if err != nil {
 		slog.Warn("dream: keyword search failed", "block_id", block.ID, "error", err)
 		_ = SetDreamCooldown(ctx, pool, block.ID, CooldownInertDays)
@@ -221,15 +221,15 @@ func SetDreamCooldown(ctx context.Context, pool *pgxpool.Pool, blockID string, d
 
 // searchByKeywords runs one RRF search per keyword, deduplicates results,
 // and returns candidate blocks (excluding the source block and cross-scope blocks).
-func searchByKeywords(ctx context.Context, pool *pgxpool.Pool, embedHost, embedAPIKey, embedModel string, embedNumCtx int, keywords []string, scopes []string, sourceID, sourceScope string) ([]BlockInfo, error) {
+func searchByKeywords(ctx context.Context, pool *pgxpool.Pool, embedHost, embedAPIKey, embedProtocol, embedModel string, embedNumCtx int, keywords []string, scopes []string, sourceID, sourceScope string) ([]BlockInfo, error) {
 	seen := make(map[string]bool)
 	seen[sourceID] = true // Exclude source block.
 	var candidates []BlockInfo
 	embedFailures := 0
 
 	for _, kw := range keywords {
 		// Embed the keyword for semantic search.
-		kwEmbedding, err := embed.Embed(ctx, embedHost, embedAPIKey, embedModel, kw, embed.PrefixQuery, embedNumCtx)
+		kwEmbedding, err := embed.EmbedWithProtocol(ctx, embedProtocol, embedHost, embedAPIKey, embedModel, kw, embed.PrefixQuery, embedNumCtx)
 		if err != nil {
 			embedFailures++
 			slog.Debug("dream: embed keyword failed", "keyword", kw, "error", err)

go/internal/events/scheduler.go

@@ -46,10 +46,12 @@ type Config struct {
 	EmbedAPIKey    string        // Embedding provider API key (query path)
 	EmbedModel     string        // Embedding model name (query path)
 	EmbedNumCtx    int           // Embedding num_ctx (query path)
-	DreamEmbedHost   string      // Dream embedding host (empty = EmbedHost)
-	DreamEmbedAPIKey string      // Dream embedding API key (empty = EmbedAPIKey)
-	DreamEmbedModel  string      // Dream embedding model (empty = EmbedModel)
-	DreamEmbedNumCtx int         // Dream embedding num_ctx (0 = EmbedNumCtx)
+	DreamEmbedHost     string    // Dream embedding host (empty = EmbedHost)
+	DreamEmbedAPIKey   string    // Dream embedding API key (empty = EmbedAPIKey)
+	DreamEmbedProtocol string    // Dream embedding protocol (empty = EmbedProtocol)
+	DreamEmbedModel    string    // Dream embedding model (empty = EmbedModel)
+	DreamEmbedNumCtx   int       // Dream embedding num_ctx (0 = EmbedNumCtx)
+	EmbedProtocol      string    // Query-path embed protocol ("ollama" or "openai")
 	DreamHost      string        // Dream LLM provider host
 	DreamAPIKey    string        // Dream LLM provider API key (empty = no auth)
 	ChatModel      string        // Chat model name (fallback for dream)
@@ -286,6 +288,10 @@ func (s *Scheduler) runDreamCycle(dreamModel string, dreamOpts llm.Options) (int
 	if embedAPIKey == "" {
 		embedAPIKey = s.config.EmbedAPIKey
 	}
+	embedProtocol := s.config.DreamEmbedProtocol
+	if embedProtocol == "" {
+		embedProtocol = s.config.EmbedProtocol
+	}
 	embedModel := s.config.DreamEmbedModel
 	if embedModel == "" {
 		embedModel = s.config.EmbedModel
@@ -297,7 +303,7 @@ func (s *Scheduler) runDreamCycle(dreamModel string, dreamOpts llm.Options) (int
 
 	return dream.RunDreamCycle(
 		dreamCtx, s.pool,
-		embedHost, embedAPIKey, embedModel, embedNumCtx,
+		embedHost, embedAPIKey, embedProtocol, embedModel, embedNumCtx,
 		s.config.DreamHost, s.config.DreamAPIKey, dreamModel,
 		s.config.DreamThink, dreamOpts,
 		s.config.ReadScopes,