(eid int64, query string, channelID int64, modelName string)
| 70 | const queryEmbeddingCacheTTL = 24 * time.Hour |
| 71 | |
| 72 | func buildQueryEmbeddingCacheKey(eid int64, query string, channelID int64, modelName string) string { |
| 73 | if eid <= 0 || channelID <= 0 || modelName == "" { |
| 74 | return "" |
| 75 | } |
| 76 | queryHash := sha256.Sum256([]byte(query)) |
| 77 | modelHash := sha256.Sum256([]byte(modelName)) |
| 78 | return fmt.Sprintf("Cache:rag:query_embedding:eid:%d:ch:%d:m:%s:q:%s", |
| 79 | eid, |
| 80 | channelID, |
| 81 | hex.EncodeToString(modelHash[:]), |
| 82 | hex.EncodeToString(queryHash[:]), |
| 83 | ) |
| 84 | } |
| 85 | |
| 86 | func (s *EmbeddingService) getCachedQueryEmbedding(cacheKey string) ([]float64, bool) { |
| 87 | if cacheKey == "" || !common.IsRedisEnabled() { |
no outgoing calls
no test coverage detected