alexpikalov / cdrs-async

Async Cassandra driver made in Rust

Hi there 👋

• 🔭 I’m currently working on:

  • Rasmus - standalone WebAssembly engine.
  • TeleMQ - MQTT broker.

• Previous projects:

  • CDRS - first Rust-native Apache Cassandra client.

cdrs-async's Issues

How can we help?

Hi Alex!

We're (@stadiamaps) using the synchronous variant of your CDRS crate in one of our Rust applications and we really like it. We're wrapping the sync operations in a Tokio blocking thread, so it's not ideal.

How can we help push the async version along?

Looking forward to helping!

cdrs-helpers-derive can't work with cdrs-async

I'm trying to make cdrs-helper-derive work with cdrs-aync, but failed. Is there any plan to support this use case.

there may be a Bug with paging.

`let mut loop_index = 0;
let mut paging_state = None;
loop {
println!("loop index: {:?}", &loop_index);
println!("pagin state: {:?}", &paging_state);
let params = page_request.build_query_params(paging_state, None);
let body: ResponseBody = scylladb
.query_body(&page_request.row_query_str, params)
.await
.unwrap();

        let mut rows_cnt = 0;
        match &body {
            ResponseBody::Result(res) => {
                match res {
                    ResResultBody::Rows(rows) => {
                        rows_cnt = rows.rows_count;
                    },
                    _ => ()
                }
            },
            _ => (),
        }
        if rows_cnt == 0 {
            return Ok(PageResult {
                page_size: page_request.page_size,
                page_index: page_request.page_index,
                total: 0,
                data: Vec::new(),
            });
        }

        paging_state = body.as_rows_metadata().unwrap().paging_state;
        if page_request.page_index == loop_index {
            let rows = body.into_rows().unwrap();
            let mut result: Vec<K> = Vec::new();
            for row in rows {
                result.push(K::try_from_row(row).expect("row transform error"));
            }
            // dbg!(rows);
            // dbg!(paging_state);
            return Ok(PageResult {
                page_size: page_request.page_size,
                page_index: page_request.page_index,
                total: 0,
                data: result,
            });
        } else {
            loop_index = loop_index + 1;
        }
    }`

Best way to deserialize result

Hi,

I have a little server app with tokio and I need to perform a basic query. I can perform the query, but now I'm stuck on the deserialization of the result. I know this is in early stages of development, so not sure if this is in place, or has to be implemented. Which would be the right way to deserialize a result row? Can we use "cdrs" (non async library) for deserialization? Or we have to deserialize each field by hand?

Thanks.

...

I'm sorry... this was created by accident by my IDE :(

Question: any way to make it runtime agnostic?

I see a lot of libraries starting to move to async/await, but being dependent on specific runtimes (either async-std or tokio) and this can become a mess when developers starts to need different libraries depending on different runtimes...

Also are you planning to merge it with the synchronous version or maintaining both in parallel?