fresh-borzoni opened a new issue, #315: URL: https://github.com/apache/fluss-rust/issues/315
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss-rust/issues) and found nothing similar. ### Description Add the wire protocol and message types needed for the LimitScan RPC. ``rust message LimitScanRequest { required int64 table_id = 2; optional int64 partition_id = 3; required int32 bucket_id = 4; required int32 limit = 5; } message LimitScanResponse { optional int32 error_code = 1; optional string error_message = 2; optional bool is_log_table = 3; optional bytes records = 4; } ``` Add LimitScan = 1033 variant to ApiKey enum, mappings, test Follow lookup.rs pattern to define LimitScanRequest in rpc messages ```rust pub struct LimitScanRequest { pub inner_request: proto::LimitScanRequest } impl RequestBody for LimitScanRequest { type ResponseBody = proto::LimitScanResponse; const API_KEY: ApiKey = ApiKey::LimitScan; const REQUEST_VERSION: ApiVersion = ApiVersion(0); } impl_write_version_type!(LimitScanRequest); impl_read_version_type!(LimitScanResponse); ``` ### Willingness to contribute - [ ] I'm willing to submit a PR! -- 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]
