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 }

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

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 1416 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.

static void as_policy_base_read_init ( as_policy_base *  p )

inlinestatic

Initialize base defaults for reads.

Definition at line 1375 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.

static void as_policy_base_write_init ( as_policy_base *  p )

inlinestatic

Initialize base defaults for writes.

Definition at line 1389 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.