1 file changed
+1
-1
lines changed- src/v/cloud_topics/BUILD+4-4
- src/v/cloud_topics/app.cc+18-41
- src/v/cloud_topics/app.h+4-1
- src/v/cloud_topics/batch_cache/batch_cache.cc+4
- src/v/cloud_topics/batch_cache/batch_cache.h+6
- src/v/cloud_topics/data_plane_impl.cc+76-54
- src/v/cloud_topics/data_plane_impl.h+7-3
- src/v/cloud_topics/frontend/BUILD+1-1
- src/v/cloud_topics/frontend/frontend.cc+4-5
- src/v/cloud_topics/frontend/frontend.h+2-3
- src/v/cloud_topics/level_zero/batcher/BUILD+1
- src/v/cloud_topics/level_zero/batcher/aggregator.cc+4-4
- src/v/cloud_topics/level_zero/batcher/aggregator.h+3-4
- src/v/cloud_topics/level_zero/batcher/batcher.cc+7-7
- src/v/cloud_topics/level_zero/batcher/batcher.h+11-9
- src/v/cloud_topics/level_zero/batcher/tests/aggregator_test.cc+8-8
- src/v/cloud_topics/level_zero/batcher/tests/batcher_test.cc+9-9
- src/v/cloud_topics/level_zero/cluster_services_impl/BUILD+22
- src/v/cloud_topics/level_zero/cluster_services_impl/cluster_services.h+44
- src/v/cloud_topics/level_zero/common/BUILD+1
- src/v/cloud_topics/level_zero/frontend_reader/BUILD+33
- src/v/cloud_topics/level_zero/frontend_reader/reader.cc+3-3
- src/v/cloud_topics/level_zero/frontend_reader/reader.h+2-2
- src/v/cloud_topics/level_zero/pipeline/BUILD+9-9
- src/v/cloud_topics/level_zero/pipeline/base_pipeline.h+10-3
- src/v/cloud_topics/level_zero/pipeline/event_filter.h+1-1
- src/v/cloud_topics/level_zero/pipeline/pipeline_stage.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/read_pipeline.cc+4-4
- src/v/cloud_topics/level_zero/pipeline/read_pipeline.h+5-5
- src/v/cloud_topics/level_zero/pipeline/read_request.cc+2-2
- src/v/cloud_topics/level_zero/pipeline/read_request.h+1-1
- src/v/cloud_topics/level_zero/pipeline/serializer.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/tests/circuit_breaker_test.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/tests/event_filter_test.cc+2-2
- src/v/cloud_topics/level_zero/pipeline/tests/pipeline_bench.cc+3-3
- src/v/cloud_topics/level_zero/pipeline/tests/serializer_test.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/tests/write_pipeline_test.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/tests/write_request_test.cc+1-1
- src/v/cloud_topics/level_zero/pipeline/write_pipeline.cc+4-4
- src/v/cloud_topics/level_zero/pipeline/write_pipeline.h+4-4
- src/v/cloud_topics/level_zero/pipeline/write_request.cc+3-3
- src/v/cloud_topics/level_zero/pipeline/write_request.h+2-2
- src/v/cloud_topics/level_zero/reader/BUILD-27
- src/v/cloud_topics/level_zero/reader/fetch_request_handler.cc+4-4
- src/v/cloud_topics/level_zero/reader/fetch_request_handler.h+3-3
- src/v/cloud_topics/level_zero/reader/materialized_extent.cc+2-2
- src/v/cloud_topics/level_zero/reader/materialized_extent.h+2-2
- src/v/cloud_topics/level_zero/reader/materialized_extent_reader.cc+2-2
- src/v/cloud_topics/level_zero/reader/materialized_extent_reader.h+2-2
- src/v/cloud_topics/level_zero/reader/tests/fetch_handler_test.cc+2-2
- src/v/cloud_topics/level_zero/reader/tests/materialized_extent_fixture.h+2-2
- src/v/cloud_topics/level_zero/reader/tests/materialized_extent_reader_test.cc+2-2
- src/v/cloud_topics/level_zero/reader/tests/materialized_extent_test.cc+26-22
- src/v/cloud_topics/level_zero/reconciler/reconciler.cc+3-2
- src/v/cloud_topics/level_zero/reconciler/reconciler.h+6-3
- src/v/cloud_topics/level_zero/stm/BUILD+1
- src/v/cloud_topics/level_zero/throttler/tests/throttler_test.cc+12-12
- src/v/cloud_topics/level_zero/throttler/throttler.cc+11-5
- src/v/cloud_topics/level_zero/throttler/throttler.h+7-4
- src/v/cloud_topics/state_accessors.h+7-11
- src/v/kafka/data/BUILD+1-1
- src/v/kafka/data/cloud_topic_partition.cc+1-1
0 commit comments