Was this page helpful?
Caution
You're viewing documentation for an unstable version of Scylla Rust Driver. Switch to the latest stable version.
Sometimes after performing queries some nodes have not been updated, so we need a mechanism that checks if every node have agreed on schema version.
The driver automatically awaits schema agreement after a schema-altering query is executed. Waiting for schema agreement more than necessary is never a bug, but might slow down applications which do a lot of schema changes (e.g. a migration). For instance, in case where somebody wishes to create a keyspace and then a lot of tables in it, it makes sense only to wait after creating a keyspace and after creating all the tables rather than after every query. Therefore, the said behaviour can be disabled:
let session = SessionBuilder::new()
.known_node("127.0.0.1:9042")
.auto_await_schema_agreement(false)
.build()
.await?;
Session::await_schema_agreement returns a Future that can be awaited as long as schema is not in an agreement.
However, it won’t wait forever; SessionConfig defines a timeout that limits the time of waiting. If the timeout elapses,
the return value is Err(QueryError::RequestTimeout), otherwise it is Ok(schema_version).
session.await_schema_agreement().await?;
If the schema is not agreed upon, the driver sleeps for a duration before checking it again. The default value is 200 milliseconds,
but it can be changed with SessionBuilder::schema_agreement_interval.
SessionBuilder::new()
.known_node("127.0.0.1:9042")
.schema_agreement_interval(Duration::from_secs(1))
.build()
.await?;
If you want to check if schema is in agreement now, without retrying after failure, you can use Session::check_schema_agreement function.
if session.check_schema_agreement().await?.is_some() {
println!("SCHEMA AGREED");
} else {
println!("SCHEMA IS NOT IN AGREEMENT");
}
Was this page helpful?