Zhen Ye 66cc194ab2

enhance: add partition gc at streaming arch (#42179) ...

issue: #41976

- make drop partition message as a broadcast message.
- add gc when drop partition message is acked.
- add a call back to handle the broadcast message when ack.
- the ack operation of broadcast message will retry until success.

Signed-off-by: chyezh <chyezh@outlook.com>

2025-05-29 23:20:30 +08:00

..

hash_test.go

fix: Fix no candidate segments error for small import (#41771)

2025-05-14 15:30:21 +08:00

hash.go

enhance: bulkinsert handles nullable/default (#42127)

2025-05-28 18:02:28 +08:00

mock_task.go

fix: Fix no candidate segments error for small import (#41771)

2025-05-14 15:30:21 +08:00

pool_test.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

pool.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

scheduler_test.go

enhance: Pooling for data tasks (#41256)

2025-05-20 21:06:24 +08:00

scheduler.go

enhance: Pooling for data tasks (#41256)

2025-05-20 21:06:24 +08:00

task_import.go

enhance: bulkinsert handles nullable/default (#42127)

2025-05-28 18:02:28 +08:00

task_l0_import_test.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task_l0_import.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task_l0_preimport.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task_manager_test.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task_manager.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task_preimport.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

task.go

enhance: Use v2 package name for pkg module (#39990)

2025-02-22 23:15:58 +08:00

util_test.go

enhance: bulkinsert handles nullable/default (#42127)

2025-05-28 18:02:28 +08:00

util.go

enhance: add partition gc at streaming arch (#42179)

2025-05-29 23:20:30 +08:00