#include <inttypes.h>
#include <stdbool.h>
#include <netinet/in.h>
#include "citrusleaf/cf_atomic.h"
#include "citrusleaf/cf_log.h"
#include "citrusleaf/cf_ll.h"
#include "citrusleaf/cf_clock.h"
#include "citrusleaf/cf_vector.h"
#include "citrusleaf/cf_queue.h"
#include "citrusleaf/cf_alloc.h"
#include "citrusleaf/cf_digest.h"
#include "citrusleaf/cf_shash.h"

Include dependency graph for citrusleaf.h:

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

Go to the source code of this file.

Classes
struct	cl_object_s
struct	cl_bin_s
struct	cl_rec
struct	cl_batchresult
struct	cl_operation_s
struct	cl_addrmap
struct	cl_write_parameters
struct	cl_scan_parameters_s
struct	cl_node_response_s

Macros
#define	STACK_BUF_SZ (1024 * 16)
#define	DEFAULT_PROGRESS_TIMEOUT 50
#define	INFO_TIMEOUT_MS 500
#define	NODE_NAME_SIZE 20

Typedefs
typedef enum cl_rv	cl_rv
typedef enum cl_rvclient	cl_rvclient
typedef struct cl_conn_s	cl_conn
typedef enum cl_type	cl_type
typedef enum cl_write_policy	cl_write_policy
typedef enum cl_scan_priority	cl_scan_priority
typedef struct cl_object_s	cl_object
typedef enum cl_operator_type	cl_operator
typedef struct cl_bin_s	cl_bin
typedef struct cl_rec	cl_rec
typedef struct cl_batchresult	cl_batchresult
typedef struct cl_operation_s	cl_operation
typedef struct cl_addrmap	cl_addrmap
typedef void(*	cl_async_fail_cb )(void *udata, int rv, uint64_t)
typedef void(*	cl_async_success_cb )(void *udata, int rv, uint64_t)
typedef struct cl_cluster_s	cl_cluster
typedef struct cl_cluster_compression_stat_s	cl_cluster_compression_stat
typedef struct cl_scan_parameters_s	cl_scan_parameters
typedef struct cl_node_response_s	cl_node_response
typedef int(*	citrusleaf_get_many_cb )(char ns, cf_digest keyd, char set, uint32_t generation, uint32_t record_ttl, cl_bin bins, int n_bins, bool is_last, void *udata)

Enumerations
enum	cl_rv { CITRUSLEAF_FAIL_ASYNCQ_FULL = -3, CITRUSLEAF_FAIL_TIMEOUT = -2, CITRUSLEAF_FAIL_CLIENT = -1, CITRUSLEAF_OK = 0, CITRUSLEAF_FAIL_UNKNOWN = 1, CITRUSLEAF_FAIL_NOTFOUND = 2, CITRUSLEAF_FAIL_GENERATION = 3, CITRUSLEAF_FAIL_PARAMETER = 4, CITRUSLEAF_FAIL_KEY_EXISTS = 5, CITRUSLEAF_FAIL_BIN_EXISTS = 6, CITRUSLEAF_FAIL_CLUSTER_KEY_MISMATCH = 7, CITRUSLEAF_FAIL_PARTITION_OUT_OF_SPACE = 8, CITRUSLEAF_FAIL_SERVERSIDE_TIMEOUT = 9, CITRUSLEAF_FAIL_NOXDS = 10, CITRUSLEAF_FAIL_UNAVAILABLE = 11, CITRUSLEAF_FAIL_INCOMPATIBLE_TYPE = 12, CITRUSLEAF_FAIL_RECORD_TOO_BIG = 13, CITRUSLEAF_FAIL_KEY_BUSY = 14 }
enum	cl_rvclient { CITRUSLEAF_FAIL_DC_DOWN = 1, CITRUSLEAF_FAIL_DC_UP = 2 }
enum	cl_type { CL_NULL = 0x00, CL_INT = 0x01, CL_FLOAT = 2, CL_STR = 0x03, CL_BLOB = 0x04, CL_TIMESTAMP = 5, CL_DIGEST = 6, CL_JAVA_BLOB = 7, CL_CSHARP_BLOB = 8, CL_PYTHON_BLOB = 9, CL_RUBY_BLOB = 10, CL_PHP_BLOB = 11, CL_ERLANG_BLOB = 12, CL_UNKNOWN = 666666 }
enum	cl_write_policy { CL_WRITE_ASYNC, CL_WRITE_ONESHOT, CL_WRITE_RETRY, CL_WRITE_ASSURED }
enum	cl_scan_priority { CL_SCAN_PRIORITY_AUTO, CL_SCAN_PRIORITY_LOW, CL_SCAN_PRIORITY_MEDIUM, CL_SCAN_PRIORITY_HIGH }
enum	cl_operator_type { CL_OP_WRITE, CL_OP_READ, CL_OP_INCR, CL_OP_MC_INCR, CL_OP_PREPEND, CL_OP_APPEND, CL_OP_MC_PREPEND, CL_OP_MC_APPEND, CL_OP_TOUCH, CL_OP_MC_TOUCH }

Functions
int	citrusleaf_init (void)
void	citrusleaf_change_tend_speed (int secs)
int	citrusleaf_async_init (int size_limit, int num_receiver_threads, cl_async_fail_cb fail_cb_fn, cl_async_success_cb success_cb_fn)
int	citrusleaf_async_reinit (int size_limit, unsigned int num_receiver_threads)
void	citrusleaf_async_getstats (uint64_t retries, uint64_t dropouts, int *workitems)
void	citrusleaf_async_set_nw_timeout (int nw_timeout)
void	citrusleaf_shutdown (void)
void	citrusleaf_set_debug (bool debug_flag)
void	citrusleaf_print_stats (void)
void	citrusleaf_object_init (cl_object *o)
void	citrusleaf_object_init_str (cl_object o, char const str)
void	citrusleaf_object_init_str2 (cl_object o, char const str, size_t str_len)
void	citrusleaf_object_init_blob (cl_object o, void const buf, size_t buf_len)
void	citrusleaf_object_init_blob2 (cl_object o, void const buf, size_t buf_len, cl_type type)
void	citrusleaf_object_init_int (cl_object *o, int64_t i)
void	citrusleaf_object_init_null (cl_object *o)
void	citrusleaf_object_free (cl_object *o)
void	citrusleaf_bins_free (cl_bin *bins, int n_bins)
int	citrusleaf_copy_bins (cl_bin *destbins, const cl_bin srcbins, int n_bins)
cl_cluster *	citrusleaf_cluster_create (void)
void	citrusleaf_cluster_destroy (cl_cluster *asc)
void	citrusleaf_cluster_shutdown (void)
cl_cluster *	citrusleaf_cluster_get_or_create (char *host, short port, int timeout_ms)
void	citrusleaf_cluster_release_or_destroy (cl_cluster **asc)
void	citrusleaf_cluster_change_tend_speed (struct cl_cluster_s *asc, int secs)
void	citrusleaf_cluster_change_info_timeout (struct cl_cluster_s *asc, int msecs)
void	citrusleaf_cluster_use_nbconnect (struct cl_cluster_s *asc)
void	citrusleaf_cluster_put_compression_stat (cl_cluster *asc, uint64_t actual_sz, uint64_t compressed_sz)
void	citrusleaf_cluster_get_compression_stat (cl_cluster asc, uint64_t actual_sz, uint64_t *compressed_sz)
cl_rv	citrusleaf_cluster_add_host (cl_cluster asc, char const host, short port, int timeout_ms)
void	citrusleaf_cluster_add_addr_map (cl_cluster asc, char orig, char *alt)
bool	citrusleaf_cluster_settled (cl_cluster *asc)
int	citrusleaf_cluster_get_nodecount (cl_cluster *asc)
void	cl_cluster_get_node_names (cl_cluster asc, int n_nodes, char **node_names)
cl_cluster *	citrusleaf_cluster_get (char const *url)
void	citrusleaf_cluster_follow (cl_cluster *asc, bool flag)
cl_rv	citrusleaf_get_all (cl_cluster asc, const char ns, const char set, const cl_object key, cl_bin *bins, int n_bins, int timeout_ms, uint32_t *cl_gen)
cl_rv	citrusleaf_get_all_digest (cl_cluster asc, const char ns, const cf_digest d, cl_bin bins, int n_bins, int timeout_ms, uint32_t *cl_gen)
cl_rv	citrusleaf_get_all_digest_getsetname (cl_cluster asc, const char ns, const cf_digest d, cl_bin bins, int n_bins, int timeout_ms, uint32_t cl_gen, char setname)
cl_rv	citrusleaf_put (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_put_digest (cl_cluster asc, const char ns, const cf_digest d, const cl_bin bins, int n_bins, const cl_write_parameters *cl_w_p)
cl_rv	citrusleaf_put_replace (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_bin values, int n_values, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_restore (cl_cluster asc, const char ns, const cf_digest digest, const char set, const cl_bin values, int n_values, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_async_put (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p, uint64_t trid, void *udata)
cl_rv	citrusleaf_async_put_digest (cl_cluster asc, const char ns, const cf_digest d, const char set, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p, uint64_t trid, void *udata)
cl_rv	citrusleaf_async_put_forget (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_async_put_digest_forget (cl_cluster asc, const char ns, const cf_digest d, const char set, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_async_put_digest_xdr (cl_cluster asc, const char ns, const cf_digest d, char set, const cl_bin bins, int n_bins, const cl_write_parameters cl_w_p, uint64_t trid, void *udata)
cl_rvclient	citrusleaf_check_cluster_health (cl_cluster *asc)
void	citrusleaf_sleep_for_tender (cl_cluster *asc)
int	citrusleaf_cluster_change_compression_threshold (cl_cluster *asc, int size_in_bytes)
cl_rv	citrusleaf_get (cl_cluster asc, const char ns, const char set, const cl_object key, cl_bin bins, int n_bins, int timeout_ms, uint32_t cl_gen)
cl_rv	citrusleaf_get_digest (cl_cluster asc, const char ns, const cf_digest d, cl_bin bins, int n_bins, int timeout_ms, uint32_t *cl_gen)
cl_rv	citrusleaf_delete (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_write_parameters *cl_w_p)
cl_rv	citrusleaf_delete_digest (cl_cluster asc, const char ns, const cf_digest d, const cl_write_parameters cl_w_p)
cl_rv	citrusleaf_async_delete_digest_xdr (cl_cluster asc, const char ns, const cf_digest digest, const cl_write_parameters cl_w_p, void *udata)
cl_rv	citrusleaf_exists_key (cl_cluster asc, const char ns, const char set, const cl_object key, cl_bin bins, int n_bins, int timeout_ms, uint32_t cl_gen)
cl_rv	citrusleaf_exists_digest (cl_cluster asc, const char ns, const cf_digest d, cl_bin bins, int n_bins, int timeout_ms, uint32_t *cl_gen)
cl_rv	citrusleaf_scan (cl_cluster asc, char ns, char set, cl_bin bins, int n_bins, bool get_key, citrusleaf_get_many_cb cb, void *udata, bool nobindata)
cf_vector *	citrusleaf_scan_all_nodes (cl_cluster asc, char ns, char set, cl_bin bins, int n_bins, bool nobindata, uint8_t scan_pct, citrusleaf_get_many_cb cb, void udata, cl_scan_parameters scan_p)
cl_rv	citrusleaf_scan_node (cl_cluster asc, char node_name, char ns, char set, cl_bin bins, int n_bins, bool nobindata, uint8_t scan_pct, citrusleaf_get_many_cb cb, void udata, cl_scan_parameters *scan_p)
cl_rv	citrusleaf_batch_init (int n_threads)
cl_rv	citrusleaf_get_many_digest (cl_cluster asc, char ns, const cf_digest digests, int n_digests, cl_bin bins, int n_bins, bool get_key, citrusleaf_get_many_cb cb, void *udata)
cl_rv	citrusleaf_get_many_digest_direct (cl_cluster asc, char ns, const cf_digest digests, int n_digests, cl_batchresult *br)
void	citrusleaf_free_batchresult (cl_batchresult *br)
cl_rv	citrusleaf_exists_many_digest (cl_cluster asc, char ns, const cf_digest digests, int n_digests, cl_bin bins, int n_bins, bool get_key, citrusleaf_get_many_cb cb, void *udata)
int	citrusleaf_info (char host, short port, char names, char **values, int timeout_ms)
int	citrusleaf_info_host (struct sockaddr_in sa_in, char names, char **values, int timeout_ms, bool send_asis)
int	cl_lookup (cl_cluster asc, char hostname, short port, cf_vector *sockaddr_in_v)
cl_rv	citrusleaf_verify (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_bin bins, int n_bins, int timeout_ms, uint32_t cl_gen)
cl_rv	citrusleaf_delete_verify (cl_cluster asc, const char ns, const char set, const cl_object key, const cl_write_parameters *cl_w_p)
cl_rv	citrusleaf_operate (cl_cluster asc, const char ns, const char set, const cl_object key, cl_operation operations, int n_operations, const cl_write_parameters cl_w_p, int replace, uint32_t *generation)
cl_rv	citrusleaf_operate_digest (cl_cluster asc, const char ns, cf_digest digest, cl_operation operations, int n_operations, const cl_write_parameters cl_w_p, int replace, uint32_t generation)
int	citrusleaf_calculate_digest (const char set, const cl_object key, cf_digest *digest)

Macro Definition Documentation

#define DEFAULT_PROGRESS_TIMEOUT 50

Definition at line 39 of file citrusleaf.h.

#define INFO_TIMEOUT_MS 500

Definition at line 40 of file citrusleaf.h.

#define NODE_NAME_SIZE 20

Definition at line 42 of file citrusleaf.h.

#define STACK_BUF_SZ (1024 * 16)

Definition at line 38 of file citrusleaf.h.

Typedef Documentation

typedef int(* citrusleaf_get_many_cb)(char *ns, cf_digest *keyd, char *set, uint32_t generation, uint32_t record_ttl, cl_bin *bins, int n_bins, bool is_last, void *udata)

Definition at line 505 of file citrusleaf.h.

typedef struct cl_addrmap cl_addrmap

typedef void(* cl_async_fail_cb)(void *udata, int rv, uint64_t)

Definition at line 168 of file citrusleaf.h.

typedef void(* cl_async_success_cb)(void *udata, int rv, uint64_t)

Definition at line 169 of file citrusleaf.h.

typedef struct cl_batchresult cl_batchresult

typedef struct cl_bin_s cl_bin

typedef struct cl_cluster_s cl_cluster

Definition at line 257 of file citrusleaf.h.

typedef struct cl_cluster_compression_stat_s cl_cluster_compression_stat

Definition at line 260 of file citrusleaf.h.

typedef struct cl_conn_s cl_conn

Definition at line 80 of file citrusleaf.h.

typedef struct cl_node_response_s cl_node_response

typedef struct cl_object_s cl_object

typedef struct cl_operation_s cl_operation

typedef enum cl_operator_type cl_operator

typedef struct cl_rec cl_rec

typedef enum cl_rv cl_rv

typedef enum cl_rvclient cl_rvclient

typedef struct cl_scan_parameters_s cl_scan_parameters

typedef enum cl_scan_priority cl_scan_priority

Definition at line 95 of file citrusleaf.h.

typedef enum cl_type cl_type

Definition at line 87 of file citrusleaf.h.

typedef enum cl_write_policy cl_write_policy

Definition at line 91 of file citrusleaf.h.

Enumeration Type Documentation

enum cl_operator_type

Enumerator:

CL_OP_WRITE
CL_OP_READ
CL_OP_INCR
CL_OP_MC_INCR
CL_OP_PREPEND
CL_OP_APPEND
CL_OP_MC_PREPEND
CL_OP_MC_APPEND
CL_OP_TOUCH
CL_OP_MC_TOUCH

Definition at line 118 of file citrusleaf.h.

enum cl_rv

Enumerator:

CITRUSLEAF_FAIL_ASYNCQ_FULL
CITRUSLEAF_FAIL_TIMEOUT
CITRUSLEAF_FAIL_CLIENT
CITRUSLEAF_OK
CITRUSLEAF_FAIL_UNKNOWN
CITRUSLEAF_FAIL_NOTFOUND
CITRUSLEAF_FAIL_GENERATION
CITRUSLEAF_FAIL_PARAMETER
CITRUSLEAF_FAIL_KEY_EXISTS
CITRUSLEAF_FAIL_BIN_EXISTS
CITRUSLEAF_FAIL_CLUSTER_KEY_MISMATCH
CITRUSLEAF_FAIL_PARTITION_OUT_OF_SPACE
CITRUSLEAF_FAIL_SERVERSIDE_TIMEOUT
CITRUSLEAF_FAIL_NOXDS
CITRUSLEAF_FAIL_UNAVAILABLE
CITRUSLEAF_FAIL_INCOMPATIBLE_TYPE
CITRUSLEAF_FAIL_RECORD_TOO_BIG
CITRUSLEAF_FAIL_KEY_BUSY

Definition at line 52 of file citrusleaf.h.

enum cl_rvclient

Enumerator:

CITRUSLEAF_FAIL_DC_DOWN
CITRUSLEAF_FAIL_DC_UP

Definition at line 73 of file citrusleaf.h.

enum cl_scan_priority

Enumerator:

CL_SCAN_PRIORITY_AUTO
CL_SCAN_PRIORITY_LOW
CL_SCAN_PRIORITY_MEDIUM
CL_SCAN_PRIORITY_HIGH

Definition at line 93 of file citrusleaf.h.

enum cl_type

Enumerator:

CL_NULL
CL_INT
CL_FLOAT
CL_STR
CL_BLOB
CL_TIMESTAMP
CL_DIGEST
CL_JAVA_BLOB
CL_CSHARP_BLOB
CL_PYTHON_BLOB
CL_RUBY_BLOB
CL_PHP_BLOB
CL_ERLANG_BLOB
CL_UNKNOWN

Definition at line 82 of file citrusleaf.h.

enum cl_write_policy

Enumerator:

CL_WRITE_ASYNC
CL_WRITE_ONESHOT
CL_WRITE_RETRY
CL_WRITE_ASSURED

Definition at line 89 of file citrusleaf.h.

Function Documentation

cl_rv citrusleaf_async_delete_digest_xdr	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	digest,
		const cl_write_parameters *	cl_w_p,
		void *	udata
	)

void citrusleaf_async_getstats	(	uint64_t *	retries,
		uint64_t *	dropouts,
		int *	workitems
	)

int citrusleaf_async_init	(	int	size_limit,
		int	num_receiver_threads,
		cl_async_fail_cb	fail_cb_fn,
		cl_async_success_cb	success_cb_fn
	)

cl_rv citrusleaf_async_put	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p,
		uint64_t	trid,
		void *	udata
	)

cl_rv citrusleaf_async_put_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		const char *	set,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p,
		uint64_t	trid,
		void *	udata
	)

cl_rv citrusleaf_async_put_digest_forget	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		const char *	set,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_async_put_digest_xdr	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		char *	set,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p,
		uint64_t	trid,
		void *	udata
	)

cl_rv citrusleaf_async_put_forget	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p
	)

int citrusleaf_async_reinit	(	int	size_limit,
		unsigned int	num_receiver_threads
	)

void citrusleaf_async_set_nw_timeout ( int nw_timeout )

cl_rv citrusleaf_batch_init ( int n_threads )

void citrusleaf_bins_free	(	cl_bin *	bins,
		int	n_bins
	)

int citrusleaf_calculate_digest	(	const char *	set,
		const cl_object *	key,
		cf_digest *	digest
	)

void citrusleaf_change_tend_speed ( int secs )

cl_rvclient citrusleaf_check_cluster_health ( cl_cluster * asc )

void citrusleaf_cluster_add_addr_map	(	cl_cluster *	asc,
		char *	orig,
		char *	alt
	)

cl_rv citrusleaf_cluster_add_host	(	cl_cluster *	asc,
		char const *	host,
		short	port,
		int	timeout_ms
	)

int citrusleaf_cluster_change_compression_threshold	(	cl_cluster *	asc,
		int	size_in_bytes
	)

void citrusleaf_cluster_change_info_timeout	(	struct cl_cluster_s *	asc,
		int	msecs
	)

void citrusleaf_cluster_change_tend_speed	(	struct cl_cluster_s *	asc,
		int	secs
	)

cl_cluster* citrusleaf_cluster_create ( void )

void citrusleaf_cluster_destroy ( cl_cluster * asc )

void citrusleaf_cluster_follow	(	cl_cluster *	asc,
		bool	flag
	)

cl_cluster* citrusleaf_cluster_get ( char const * url )

void citrusleaf_cluster_get_compression_stat	(	cl_cluster *	asc,
		uint64_t *	actual_sz,
		uint64_t *	compressed_sz
	)

int citrusleaf_cluster_get_nodecount ( cl_cluster * asc )

cl_cluster* citrusleaf_cluster_get_or_create	(	char *	host,
		short	port,
		int	timeout_ms
	)

void citrusleaf_cluster_put_compression_stat	(	cl_cluster *	asc,
		uint64_t	actual_sz,
		uint64_t	compressed_sz
	)

void citrusleaf_cluster_release_or_destroy ( cl_cluster ** asc )

bool citrusleaf_cluster_settled ( cl_cluster * asc )

void citrusleaf_cluster_shutdown ( void )

void citrusleaf_cluster_use_nbconnect ( struct cl_cluster_s * asc )

int citrusleaf_copy_bins	(	cl_bin **	destbins,
		const cl_bin *	srcbins,
		int	n_bins
	)

cl_rv citrusleaf_delete	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_delete_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_delete_verify	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_exists_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		cl_bin *	bins,
		int	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_exists_key	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		cl_bin *	bins,
		int	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_exists_many_digest	(	cl_cluster *	asc,
		char *	ns,
		const cf_digest *	digests,
		int	n_digests,
		cl_bin *	bins,
		int	n_bins,
		bool	get_key,
		citrusleaf_get_many_cb	cb,
		void *	udata
	)

void citrusleaf_free_batchresult ( cl_batchresult * br )

cl_rv citrusleaf_get	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		cl_bin *	bins,
		int	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_get_all	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		cl_bin **	bins,
		int *	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_get_all_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		cl_bin **	bins,
		int *	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_get_all_digest_getsetname	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		cl_bin **	bins,
		int *	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen,
		char *	setname
	)

cl_rv citrusleaf_get_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		cl_bin *	bins,
		int	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

cl_rv citrusleaf_get_many_digest	(	cl_cluster *	asc,
		char *	ns,
		const cf_digest *	digests,
		int	n_digests,
		cl_bin *	bins,
		int	n_bins,
		bool	get_key,
		citrusleaf_get_many_cb	cb,
		void *	udata
	)

cl_rv citrusleaf_get_many_digest_direct	(	cl_cluster *	asc,
		char *	ns,
		const cf_digest *	digests,
		int	n_digests,
		cl_batchresult **	br
	)

int citrusleaf_info	(	char *	host,
		short	port,
		char *	names,
		char **	values,
		int	timeout_ms
	)

int citrusleaf_info_host	(	struct sockaddr_in *	sa_in,
		char *	names,
		char **	values,
		int	timeout_ms,
		bool	send_asis
	)

int citrusleaf_init ( void )

void citrusleaf_object_free ( cl_object * o )

void citrusleaf_object_init ( cl_object * o )

void citrusleaf_object_init_blob	(	cl_object *	o,
		void const *	buf,
		size_t	buf_len
	)

void citrusleaf_object_init_blob2	(	cl_object *	o,
		void const *	buf,
		size_t	buf_len,
		cl_type	type
	)

void citrusleaf_object_init_int	(	cl_object *	o,
		int64_t	i
	)

void citrusleaf_object_init_null ( cl_object * o )

void citrusleaf_object_init_str	(	cl_object *	o,
		char const *	str
	)

void citrusleaf_object_init_str2	(	cl_object *	o,
		char const *	str,
		size_t	str_len
	)

cl_rv citrusleaf_operate	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		cl_operation *	operations,
		int	n_operations,
		const cl_write_parameters *	cl_w_p,
		int	replace,
		uint32_t *	generation
	)

cl_rv citrusleaf_operate_digest	(	cl_cluster *	asc,
		const char *	ns,
		cf_digest *	digest,
		cl_operation *	operations,
		int	n_operations,
		const cl_write_parameters *	cl_w_p,
		int	replace,
		uint32_t *	generation
	)

void citrusleaf_print_stats ( void )

cl_rv citrusleaf_put	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_put_digest	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	d,
		const cl_bin *	bins,
		int	n_bins,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_put_replace	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_bin *	values,
		int	n_values,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_restore	(	cl_cluster *	asc,
		const char *	ns,
		const cf_digest *	digest,
		const char *	set,
		const cl_bin *	values,
		int	n_values,
		const cl_write_parameters *	cl_w_p
	)

cl_rv citrusleaf_scan	(	cl_cluster *	asc,
		char *	ns,
		char *	set,
		cl_bin *	bins,
		int	n_bins,
		bool	get_key,
		citrusleaf_get_many_cb	cb,
		void *	udata,
		bool	nobindata
	)

cf_vector* citrusleaf_scan_all_nodes	(	cl_cluster *	asc,
		char *	ns,
		char *	set,
		cl_bin *	bins,
		int	n_bins,
		bool	nobindata,
		uint8_t	scan_pct,
		citrusleaf_get_many_cb	cb,
		void *	udata,
		cl_scan_parameters *	scan_p
	)

cl_rv citrusleaf_scan_node	(	cl_cluster *	asc,
		char *	node_name,
		char *	ns,
		char *	set,
		cl_bin *	bins,
		int	n_bins,
		bool	nobindata,
		uint8_t	scan_pct,
		citrusleaf_get_many_cb	cb,
		void *	udata,
		cl_scan_parameters *	scan_p
	)

void citrusleaf_set_debug ( bool debug_flag )

void citrusleaf_shutdown ( void )

void citrusleaf_sleep_for_tender ( cl_cluster * asc )

cl_rv citrusleaf_verify	(	cl_cluster *	asc,
		const char *	ns,
		const char *	set,
		const cl_object *	key,
		const cl_bin *	bins,
		int	n_bins,
		int	timeout_ms,
		uint32_t *	cl_gen
	)

void cl_cluster_get_node_names	(	cl_cluster *	asc,
		int *	n_nodes,
		char **	node_names
	)

int cl_lookup	(	cl_cluster *	asc,
		char *	hostname,
		short	port,
		cf_vector *	sockaddr_in_v
	)

Classes

Macros

Typedefs

Enumerations

Functions

Macro Definition Documentation

Typedef Documentation

Enumeration Type Documentation

Function Documentation