as_policy.h File Reference

#include <aerospike/as_std.h>

Include dependency graph for as_policy.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	as_policies
struct	as_policy_admin
struct	as_policy_apply
struct	as_policy_base
struct	as_policy_batch
struct	as_policy_batch_apply
struct	as_policy_batch_read
struct	as_policy_batch_remove
struct	as_policy_batch_write
struct	as_policy_info
struct	as_policy_operate
struct	as_policy_query
struct	as_policy_read
struct	as_policy_remove
struct	as_policy_scan
struct	as_policy_write

Macros
#define	AS_POLICY_COMMIT_LEVEL_DEFAULT   AS_POLICY_COMMIT_LEVEL_ALL
#define	AS_POLICY_COMPRESSION_THRESHOLD_DEFAULT   0
#define	AS_POLICY_EXISTS_DEFAULT   AS_POLICY_EXISTS_IGNORE
#define	AS_POLICY_GEN_DEFAULT   AS_POLICY_GEN_IGNORE
#define	AS_POLICY_KEY_DEFAULT   AS_POLICY_KEY_DIGEST
#define	AS_POLICY_READ_MODE_AP_DEFAULT   AS_POLICY_READ_MODE_AP_ONE
#define	AS_POLICY_READ_MODE_SC_DEFAULT   AS_POLICY_READ_MODE_SC_SESSION
#define	AS_POLICY_REPLICA_DEFAULT   AS_POLICY_REPLICA_SEQUENCE
#define	AS_POLICY_SOCKET_TIMEOUT_DEFAULT   30000
#define	AS_POLICY_TOTAL_TIMEOUT_DEFAULT   1000

Enumerations
enum	as_policy_commit_level { AS_POLICY_COMMIT_LEVEL_ALL , AS_POLICY_COMMIT_LEVEL_MASTER }
enum	as_policy_exists {   AS_POLICY_EXISTS_IGNORE , AS_POLICY_EXISTS_CREATE , AS_POLICY_EXISTS_UPDATE , AS_POLICY_EXISTS_REPLACE ,   AS_POLICY_EXISTS_CREATE_OR_REPLACE }
enum	as_policy_gen { AS_POLICY_GEN_IGNORE , AS_POLICY_GEN_EQ , AS_POLICY_GEN_GT }
enum	as_policy_key { AS_POLICY_KEY_DIGEST , AS_POLICY_KEY_SEND }
enum	as_policy_read_mode_ap { AS_POLICY_READ_MODE_AP_ONE , AS_POLICY_READ_MODE_AP_ALL }
enum	as_policy_read_mode_sc { AS_POLICY_READ_MODE_SC_SESSION , AS_POLICY_READ_MODE_SC_LINEARIZE , AS_POLICY_READ_MODE_SC_ALLOW_REPLICA , AS_POLICY_READ_MODE_SC_ALLOW_UNAVAILABLE }
enum	as_policy_replica { AS_POLICY_REPLICA_MASTER , AS_POLICY_REPLICA_ANY , AS_POLICY_REPLICA_SEQUENCE , AS_POLICY_REPLICA_PREFER_RACK }
enum	as_policy_retry { AS_POLICY_RETRY_NONE , AS_POLICY_RETRY_ONCE }
enum	as_query_duration { AS_QUERY_DURATION_LONG , AS_QUERY_DURATION_SHORT , AS_QUERY_DURATION_LONG_RELAX_AP }

Functions
static void	as_policy_base_query_init (as_policy_base *p)
static void	as_policy_base_read_init (as_policy_base *p)
static void	as_policy_base_write_init (as_policy_base *p)

Function Documentation

as_policy_base_query_init()

static void as_policy_base_query_init ( as_policy_base * p )

inlinestatic

Initialize base defaults for scan/query.

Set max_retries for scans and non-aggregation queries with a null filter. All other queries are not retried.

The latest servers support retries on individual data partitions. This feature is useful when a cluster is migrating and partition(s) are missed or incomplete on the first query (with null filter) attempt.

If the first query attempt misses 2 of 4096 partitions, then only those 2 partitions are retried in the next query attempt from the last key digest received for each respective partition. A higher default max_retries is used because it's wasteful to invalidate all query results because a single partition was missed.

Definition at line 1560 of file as_policy.h.

References AS_POLICY_SOCKET_TIMEOUT_DEFAULT, as_policy_base::compress, as_policy_base::filter_exp, as_policy_base::max_retries, as_policy_base::sleep_between_retries, as_policy_base::socket_timeout, and as_policy_base::total_timeout.

as_policy_base_read_init()

static void as_policy_base_read_init ( as_policy_base * p )

inlinestatic

Initialize base defaults for reads.

Definition at line 1519 of file as_policy.h.

References AS_POLICY_SOCKET_TIMEOUT_DEFAULT, AS_POLICY_TOTAL_TIMEOUT_DEFAULT, as_policy_base::compress, as_policy_base::filter_exp, as_policy_base::max_retries, as_policy_base::sleep_between_retries, as_policy_base::socket_timeout, and as_policy_base::total_timeout.

as_policy_base_write_init()

static void as_policy_base_write_init ( as_policy_base * p )

inlinestatic

Initialize base defaults for writes.

Definition at line 1533 of file as_policy.h.

References AS_POLICY_SOCKET_TIMEOUT_DEFAULT, AS_POLICY_TOTAL_TIMEOUT_DEFAULT, as_policy_base::compress, as_policy_base::filter_exp, as_policy_base::max_retries, as_policy_base::sleep_between_retries, as_policy_base::socket_timeout, and as_policy_base::total_timeout.