Skip to content

Commit

Permalink
docs: add entries about client timeouts
Browse files Browse the repository at this point in the history
A short description of client-side timeouts is added to the docs.
  • Loading branch information
psarna committed Nov 12, 2021
1 parent 33aca97 commit b993a7c
Show file tree
Hide file tree
Showing 3 changed files with 64 additions and 0 deletions.
1 change: 1 addition & 0 deletions docs/source/SUMMARY.md
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
- [Lightweight transaction query (LWT)](queries/lwt.md)
- [USE keyspace](queries/usekeyspace.md)
- [Schema agreement](queries/schema_agreement.md)
- [Client timeout](queries/client_timeout.md)

- [Data Types](data-types/data-types.md)
- [Bool, Tinyint, Smallint, Int, Bigint, Float, Double](data-types/primitive.md)
Expand Down
60 changes: 60 additions & 0 deletions docs/source/queries/client_timeout.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,60 @@
# Client timeouts

In order to make sure that your application can handle network failures and other disasters, database queries issued by
Scylla Rust Driver can time out on the client side, without waiting (potentially indefinitely) for a server to respond.

## Per-session settings

A default per-session client timeout is set to 30 seconds. This parameter can be modified via the query builder by using the `client_timeout` method:
```rust
# extern crate scylla;
# extern crate tokio;
use scylla::{Session, SessionBuilder};
use std::error::Error;
use std::time::Duration;
use std::net::{IpAddr, Ipv4Addr, SocketAddr};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
let uri = std::env::var("SCYLLA_URI")
.unwrap_or_else(|_| "127.0.0.1:9042".to_string());

let session: Session = SessionBuilder::new()
.known_node(uri)
.known_node("127.0.0.72:4321")
.known_node("localhost:8000")
.connection_timeout(Duration::from_secs(3))
.client_timeout(Duration::from_millis(1500))
.known_node_addr(SocketAddr::new(
IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)),
9000,
))
.build()
.await?;

Ok(())
}
```

## Per-query settings

Queries, prepared statements and batches can also have their own, unique client timeout parameter. That allows overriding the default session configuration and specifying a timeout for a single particular type of query. Example:

```rust
# extern crate scylla;
# use scylla::Session;
# use std::error::Error;
# async fn check_only_compiles(session: &Session) -> Result<(), Box<dyn Error>> {
use std::time::Duration;
use scylla::query::Query;

// Create a Query manually to change the client timeout
let mut my_query: Query = Query::new("INSERT INTO ks.tab (a) VALUES(?) IF NOT EXISTS".to_string());
my_query.set_client_timeout(Some(Duration::from_secs(3)));

// Insert a value into the table
let to_insert: i32 = 12345;
session.query(my_query, (to_insert,)).await?;
# Ok(())
# }
```
3 changes: 3 additions & 0 deletions docs/source/queries/queries.md
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,8 @@ This driver supports all query types available in Scylla:
Additionaly there is special functionality to enable `USE KEYSPACE` queries:
[USE keyspace](usekeyspace.md)

Queries can be subject to driver-side timeouts: [client timeout](client_timeout.md)

Queries are fully asynchronous - you can run as many of them in parallel as you wish,
but be mindful of the per-connection limit of 32768 limit per connection imposed
by the CQL protocol.
Expand All @@ -37,4 +39,5 @@ by the CQL protocol.
usekeyspace
schema_agreement
lwt
client_timeout
```

0 comments on commit b993a7c

Please sign in to comment.