Zhichang Yu c69a2d4798 [go] Merged memory extractor with ingestion task handler (#17730) ...

Routes async memory extraction through the shared ingestion NATS
pipeline via task_type=memory, removing the dedicated Redis consumer.
Memory failures ack terminally, transient errors nack for redelivery.

2026-08-03 17:08:14 +08:00

..

tool

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

chunk_index_writer_test.go

Refactor: refactor dataflow_service.go and guard nats message re-delivery (#16826)

2026-07-13 11:08:04 +08:00

chunk_index_writer.go

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

chunk_process_test.go

fix: Go ingestion migration batch 5 (Parser 1.1/1.7/2.11, Chunker 1.7/1.8/2.6/2.7, Tokenizer 6x fixes) (#17419)

2026-07-28 11:12:52 +08:00

chunk_process.go

feat: parser pages range and parse type validation for dataset/document (#17293)

2026-07-23 19:57:27 +08:00

chunk_utils_test.go

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

chunk_utils.go

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

constants.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

debug_log_sink_test.go

Go: add context to redis client (#17689)

2026-08-02 22:50:54 +08:00

debug_log_sink.go

Go: add context to redis client (#17689)

2026-08-02 22:50:54 +08:00

debug_pages_integration_test.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

debug_result_dsl_test.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

debug_result_dsl.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

debug_test.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

debug.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

embedder_test.go

Go: add context, part5 (#17392)

2026-07-27 10:20:16 +08:00

embedder.go

Go: add context, part5 (#17392)

2026-07-27 10:20:16 +08:00

golden_compare_test.go

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

golden_compare.go

Feat: nats message processing refactor and support built in DSL (#16873)

2026-07-15 14:53:16 +08:00

knowledge_compiler_wiring.go

refactor(knowledge_compiler): derive variant from template kind via single template id (#17630)

2026-07-31 18:01:55 +08:00

pipeline_e2e_test.go

chore(go): classify tests into unit/integration/e2e/manual tiers via build tags (#17586)

2026-07-31 11:52:48 +08:00

pipeline_executor_defaults_test.go

Go port: doc-level metadata extraction and knowledge compiler (#17536)

2026-07-29 21:06:48 +08:00

pipeline_executor_persist_test.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

pipeline_executor_test.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

pipeline_executor.go

Feat(ingestion): add canvas pipeline debug (dry-run) mode with View result log (#17538)

2026-07-31 13:10:08 +08:00

pipeline_real_integration_test.go

Go: add context to storage (#17690)

2026-08-03 15:08:21 +08:00

pipeline_run_output_checklist.md

Feature: task executor migration to go (#16549)

2026-07-08 19:08:11 +08:00

pipeline_run_test.go

Go: add context, part14 (#17446)

2026-07-28 19:05:59 +08:00

position_test.go

fix: Go ingestion migration batch 5 (Parser 1.1/1.7/2.11, Chunker 1.7/1.8/2.6/2.7, Tokenizer 6x fixes) (#17419)

2026-07-28 11:12:52 +08:00

position.go

fix: Go ingestion migration batch 5 (Parser 1.1/1.7/2.11, Chunker 1.7/1.8/2.6/2.7, Tokenizer 6x fixes) (#17419)

2026-07-28 11:12:52 +08:00

real_consumer_test.go

chore(go): classify tests into unit/integration/e2e/manual tiers via build tags (#17586)

2026-07-31 11:52:48 +08:00

task_context_test.go

Go: add context (#17314)

2026-07-24 16:47:12 +08:00

task_context.go

[go] Merged memory extractor with ingestion task handler (#17730)

2026-08-03 17:08:14 +08:00