hubcio opened a new pull request, #2271: URL: https://github.com/apache/iggy/pull/2271
- **initial setup and migration of shards** - **feat(io_uring): bootstrap the main function (#1788)** - **feat(io_uring): load server_config (#1798)** - **begin shard init** - **todos** - **refactors** - **fix state initialization with gate** - **temp** - **begin fix cg** - **fix issues with RefCell in core/server/src/streaming/topics/consumer_groups* files** - **fixes** - **fix iggy shard errors** - **finish handlers** - **broken iggyrwlock import** - **server compiles** - **fix sdk** - **fix segment writing/reading** - **finish send/poll messages** - **feat(io_uring): fix send/poll (#1930)** - **chore: reformat code on tpc branch (#1939)** - **feat(tpc): implement cooperative shutdown (#1941)** - **feat(tpc): implement async walk_dir and remove_dir_all (#1942)** - **refactor(io_uring): refactor the send/poll method flow (#1944)** - **feat(io_uring): fix metadata crud operations (#1950)** - **feat(io_uring): fix tcp tls server (#1952)** - **feat(io_uring): move to compio runtime (#1960)** - **refactor(io_uring): use tcp opts from compio instead of socket config (#1962)** - **fix(io_uring): skip thread_pool_limit(0) on macOS (#1963)** - **fix(io_uring): fix buffer reading with memory pool enabled (#1964)** - **chore(io_uring): merge master (#1966)** - **feat(io_uring): update compio and replace core_affinity with compio method (#1971)** - **fix(io_uring): fix memory pool bucket counter underflow (#1972)** - **feat(io_uring): add open method to partition and segment (#1975)** - **feat(io_uring): impl add/remove partitions functionality (#1978)** - **feat(io_uring): fix delete stream/topic events (#1979)** - **feat(io_uring): fix update stream/topic events (#1981)** - **feat(io_uring): fix race during opening partitions (#1987)** - **feat(io_uring): add configurable CPU sharding with validation (#1982)** - **feat(io_uring): fix pat/user/cg events (#1989)** - **feat(io_uring): merge master (#1991)** - **fix(io_uring): fix compilation, fix leaking segment indexes, fix detach (#1994)** - **feat(io_uring): fix stream/topic purge event handlers (#1996)** - **feat(io_uring): fix busy poll (#2002)** - **feat(io_uring): fix segment integration tests (#2005)** - **feat(io_uring): merge master (#2007)** - **feat(io_uring): fix shard integration tests (#2008)** - **feat(io_uring): fix remaining integration tests (#2011)** - **feat(io_uring): fix state integration tests (#2012)** - **feat(io_uring): fix config provider integration tests and move tokio from workspace to integration cargo.toml (#2015)** - **feat(io_uring): fix open descriptor when creating partition on origin shard (#2016)** - **feat(io_uring): replace tokio s3 crate (#2020)** - **feat(io_uring): revert config (#2023)** - **feat(io_uring): dump config to file after shard starts (#2024)** - **feat(io_uring): improve logging (#2029)** - **feat(io_uring): fix session for http protocol (#2033)** - **feat(io_uring): remove unnecessary copy of initial buffers, when read… (#2040)** - **feat(io_uring): merge upstream (#2047)** - **feat(io_uring): fix build (#2056)** - **Fix HTTP server using `compio`, `cyper` and restrict to shard 0 (#2032)** - **feat(io_uring): refactor memory storage used for streams/topics/parti… (#2062)** - **feat(io_uring): refactor statistics and implement topic creation (#2064)** - **feat(io_uring): implement add partitions method using new architecture (#2068)** - **feat(io_uring): move topic to new layout (#2073)** - **feat(io_uring): implement cg join/leave/rebalance and fuzz test it (#2079)** - **feat(io_uring): disable validations for new architecture (#2081)** - **feat(io_uring): create topic directories on topic creation and improv… (#2083)** - **feat(io_uring): implement consumer/cg offsets storage (#2084)** - **Merge master (#2088)** - **feat(io_uring): Move `Stream` to new architecture (#2086)** - **feat(io_uring): Move `Partition` to new architecture (#2087)** - **feat(io_uring): migrate to new architecture stream/topic create/delete/update using new interfaces. (#2103)** - **feat(io_uring): Make metrics shared between different shards (#2104)** - **feat(io_uring): Move stream and topic to new architecture. (#2113)** - **feat(io_uring): impl stats and metrics for create stream/topic/partitions (#2114)** - **feat(io_uring): impl store/delete/get consumer and consumer group offset (#2121)** - **fix(server): Update quic server with compio. (#2070)** - **feat(io_uring): impl delete storage operations for streams/topics/partitions (#2123)** - **feat(io_uring): initial loading stream/topic/partition state from disk (#2129)** - **fix(server): Update TCP TLS server with compio. (#2130)** - **feat(io_uring): migrate partitions to new architecture and impl send messages (#2144)** - **feat(io_uring): replace shards_table with dashmap (#2156)** - **feat(io_uring): rebase master (#2157)** - **feat(io_uring): fix config after rebase (#2161)** - **feat(io_uring): implement polling messages using new architecture (#2162)** - **feat(io_uring): fix integration tests for messages (#2170)** - **feat(io_uring): fix loading segments on startup (#2176)** - **feat(io_uring): migrate background tasks to new task runner (#2181)** - **feat(io_uring): merge master (#2184)** - **feat(io_uring): remove optional id from create stream/topic/cg apis in sdk (#2186)** - **feat(io_uring): remove tokio console build feature (#2192)** - **feat(io_uring): fix GetClusterMetadata command/endpoint (#2193)** - **feat(io_uring): remove old mod cluster, reformat code (#2194)** - **feat(io_uring): remove duplicated code and add annotations for backlog tasks (#2195)** - **feat(io_uring): fix get_snapshot command (#2196)** - **feat(io_uring): fix integration tests (#2200)** - **feat(io_uring): fix first shard annotation by making the id relative (#2212)** - **feat(io_uring): fix encryptor (#2211)** - **feat(io_uring): remove old storage from the shard (#2214)** - **feat(io_uring): implement the runtime trait from opentelemetry_sdk (#2215)** - **feat(io_uring): implement robust task supervision system, fix shutdown (#2219)** - **feat(io_uring): fix nasty concurrency bug (#2223)** - **feat(io_uring): fix flush_unsaved_buffer command (#2233)** - **feat(io_uring): fix cli tests (#2238)** - **fix(io_uring_tpc): fix most of lints via cargo fix (#2239)** - **fix(io_uring): fix lints (#2240)** - **feat(io_uring): adapt rust, python and csharp bdd tests to new interface (#2241)** - **feat(io_uring): fix rest of lints and tests (#2242)** - **feat(io_uring): remove tokio dependency and fix stream tests (#2247)** - **fix(server): resolve TODOs and optimize reference usage (#2248)** - **feat(io_uring): fix integration tests for http transport (#2249)** - **refactor(server): Utilize "usize" for stream ID and topic ID (#2246)** - **feat(io_uring): Add WebSocket server support to Iggy server (#2250)** - **feat(io_uring): implement Slab<User> (#2252)** - **fix(io_uring): fix websocket TestServer address discovery (#2254)** - **fix(io_uring): enable message flush test, update websocket cli docs (#2255)** - **fix(io_uring): resolve clippy lints and add WebSocket to benchmark tool (#2256)** - **feat(io_uring): fix cg tests. (#2257)** - **fix(io_uring): implement graceful HTTP shutdown and resolve TODOs (#2258)** - **feat(io_uring): improve error handling (#2260)** - **feat(io_uring): remove MockPersister and MockState (#2262)** - **feat(io_uring): fix data integrity test (#2263)** - **feat(io_uring): fix remaining mcp servers (#2266)** - **feat(io_uring): Add TLS support for iggy websocket server and client (#2265)** - **feat(io_uring): fix user scenario, invalid port in ws tests and lints** -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
