1 file changed
+1
-1
lines changed- src/v/cluster/cluster_link/frontend.cc+109
- src/v/cluster/cluster_link/frontend.h+11-1
- src/v/cluster/cluster_link/table.cc+49-1
- src/v/cluster/cluster_link/table.h+4
- src/v/cluster/cluster_link/tests/frontend_validation_test.cc+185
- src/v/cluster/cluster_link/tests/table_test.cc+114
- src/v/cluster/cluster_link/tests/utils.cc+7
- src/v/cluster/cluster_link/tests/utils.h+3
- src/v/cluster/commands.h+9
- src/v/cluster/controller.json+6-1
- src/v/cluster/service.cc+10
- src/v/cluster/service.h+3
- src/v/cluster/types.h+32
- src/v/cluster_link/deps.h+18-3
- src/v/cluster_link/link.cc+33-8
- src/v/cluster_link/link.h+18-15
- src/v/cluster_link/manager.cc+48-3
- src/v/cluster_link/manager.h+20
- src/v/cluster_link/model/types.cc+27
- src/v/cluster_link/model/types.h+38-2
- src/v/cluster_link/service.cc+22-6
- src/v/cluster_link/source_topic_syncer.cc+386-107
- src/v/cluster_link/source_topic_syncer.h+35-3
- src/v/cluster_link/task.cc+1-1
- src/v/cluster_link/tests/BUILD+1
- src/v/cluster_link/tests/deps.h+48-6
- src/v/cluster_link/tests/link_test.cc-24
- src/v/cluster_link/tests/source_topic_syncer_test.cc+25-8
- src/v/cluster_link/tests/topic_properties_syncer_test.cc+313
- src/v/kafka/client/test/cluster_mock.cc+112
- src/v/kafka/client/test/cluster_mock.h+7
- src/v/kafka/client/topic_cache.cc+3-2
- src/v/kafka/client/topic_cache.h+3-3
- src/v/test_utils/async.h+2-2
0 commit comments