|
static void | as_partition_error (as_partitions_status *parts_all) |
|
as_status | as_partition_tracker_assign (as_partition_tracker *pt, struct as_cluster_s *cluster, const char *ns, struct as_error_s *err) |
|
void | as_partition_tracker_destroy (as_partition_tracker *pt) |
|
static uint16_t | as_partition_tracker_get_id (as_vector *list, uint32_t index) |
|
static as_partition_status * | as_partition_tracker_get_status (as_partition_tracker *pt, as_vector *list, uint32_t index) |
|
as_status | as_partition_tracker_init_filter (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, uint32_t cluster_size, as_partition_filter *pf, struct as_error_s *err) |
|
void | as_partition_tracker_init_node (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, struct as_node_s *node) |
|
void | as_partition_tracker_init_nodes (as_partition_tracker *pt, struct as_cluster_s *cluster, const as_policy_base *policy, uint64_t max_records, as_policy_replica replica, as_partitions_status **parts_all, bool paginate, uint32_t cluster_size) |
|
as_status | as_partition_tracker_is_complete (as_partition_tracker *pt, struct as_cluster_s *cluster, struct as_error_s *err) |
|
void | as_partition_tracker_part_unavailable (as_partition_tracker *pt, as_node_partitions *np, uint32_t part_id) |
|
static bool | as_partition_tracker_reached_max_records_async (as_partition_tracker *pt, as_node_partitions *np) |
|
static bool | as_partition_tracker_reached_max_records_sync (as_partition_tracker *pt, as_node_partitions *np) |
|
static void | as_partition_tracker_set_digest (as_partition_tracker *pt, as_node_partitions *np, as_digest *digest, uint32_t n_partitions) |
|
static void | as_partition_tracker_set_last (as_partition_tracker *pt, as_node_partitions *np, as_digest *digest, uint64_t bval, uint32_t n_partitions) |
|
bool | as_partition_tracker_should_retry (as_partition_tracker *pt, as_node_partitions *np, as_status status) |
|