Go to the source code of this file.
|
as_status | as_query_validate (as_error *err, struct as_node_s *node, const char *ns, uint32_t timeout, uint64_t expected_key) |
|
as_status | as_query_validate_begin (as_error *err, struct as_node_s *node, const char *ns, uint32_t timeout, uint64_t *cluster_key) |
|
as_status | as_query_validate_begin_async (struct as_event_executor *executor, const char *ns, as_error *err) |
|
void | as_query_validate_end_async (struct as_event_executor *executor, struct as_node_s *node, struct as_event_loop *event_loop) |
|
as_status | as_query_validate_next_async (struct as_event_executor *executor, uint32_t index) |
|
◆ as_query_validate()
as_status as_query_validate |
( |
as_error * | err, |
|
|
struct as_node_s * | node, |
|
|
const char * | ns, |
|
|
uint32_t | timeout, |
|
|
uint64_t | expected_key ) |
|
private |
Verify migrations are not occurring and expected cluster key has not changed.
◆ as_query_validate_begin()
as_status as_query_validate_begin |
( |
as_error * | err, |
|
|
struct as_node_s * | node, |
|
|
const char * | ns, |
|
|
uint32_t | timeout, |
|
|
uint64_t * | cluster_key ) |
|
private |
Verify migrations are not occurring and obtain cluster key.
◆ as_query_validate_begin_async()
Verify migrations are not occurring and obtain cluster key in async mode.
◆ as_query_validate_end_async()
Verify migrations are not occurring and expected cluster key has not changed in async mode. Then complete query.
◆ as_query_validate_next_async()
Verify migrations are not occurring and expected cluster key has not changed in async mode. Then execute query.