21 lines
1.0 KiB
Go
21 lines
1.0 KiB
Go
|
package public
|
|||
|
|
|
|||
|
|
const KnowledgeLockEsKey = "rag:knowledge:lock:knowledgeIdEs-%v"
|
|||
|
|
const KnowledgeLockSqlKey = "rag:knowledge:lock:knowledgeIdSql-%v"
|
|||
|
|
const KnowledgeContentHashEsKey = "rag:knowledge:knowledgeId:contentHashEs-%v"
|
|||
|
|
const KnowledgeContentHashSqlKey = "rag:knowledge:knowledgeId:contentHashSql-%v"
|
|||
|
|
|
|||
|
|
const (
|
|||
|
|
KnowledgeDocumentVectorStatusTopic = "knowledge:document:vector:status:stream"
|
|||
|
|
KnowledgeDocumentVectorStatusConsumer = "knowledge-document-vector-status-consumer"
|
|||
|
|
KnowledgeDocumentVectorStatusBatchSize = 1
|
|||
|
|
KnowledgeDocumentVectorStatusAutoAck = false
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
const (
|
|||
|
|
KnowledgeDocumentChunkTopic = "knowledge:document:chunk:stream" // 请求 Stream 键名（与发消息的key一致）
|
|||
|
|
KnowledgeDocumentChunkConsumer = "knowledge-document-chunk-consumer" // 消费者名称（唯一标识）
|
|||
|
|
KnowledgeDocumentChunkBatchSize = 1 // 批处理大小（每次读取1条）
|
|||
|
|
KnowledgeDocumentChunkAutoAck = false // ACK是否自动确认（true自动确认，false不确认）
|
|||
|
|
)
|