gauc 0.3.0

Couchbase Rust Adapter / CLI
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

/**
 * Document request routines
 */
#ifndef LCB_DOCREQ_H
#define LCB_DOCREQ_H

#include <libcouchbase/couchbase.h>
#include <libcouchbase/api3.h>
#include <libcouchbase/pktfwd.h>
#include <lcbio/lcbio.h>
#include "sllist.h"

#ifdef __cplusplus
extern "C" {
#endif

struct lcb_DOCQUEUE_st;
struct lcb_DOCREQ_st;

typedef struct lcb_DOCQUEUE_st{
    lcb_t instance;
    void *parent;
    lcbio_pTIMER timer;

    /**Called when a document is ready
     * @param The queue
     * @param The document */
    void (*cb_ready)(struct lcb_DOCQUEUE_st*,struct lcb_DOCREQ_st*);

    /**Called when throttle state changes. This may be used by higher layers
     * for appropriate flow control
     * @param The queue
     * @param enabled Whether throttling has been enabled or disabled */
    void (*cb_throttle)(struct lcb_DOCQUEUE_st*, int enabled);

    /**This queue holds requests which were not yet issued to the library
     * via lcb_get3(). This list is aggregated after each chunk callback and
     * sent as a batch*/
    sllist_root pending_gets;

    /**This queue holds the requests which were already passed to lcb_get3().
     * It is popped when the callback arrives (and is popped in order!) */
    sllist_root cb_queue;

    unsigned n_awaiting_schedule;
    unsigned n_awaiting_response;

    unsigned max_pending_response;
    unsigned min_batch_size;
    unsigned cancelled;
    unsigned refcount;
} lcb_DOCQUEUE;

typedef struct lcb_DOCREQ_st {
    /* Callback. Must be first */
    lcb_RESPCALLBACK callback;
    sllist_node slnode;
    lcb_DOCQUEUE *parent;
    lcb_RESPGET docresp;
    /* To be filled in by the subclass */
    lcb_IOV docid;
    unsigned ready;
} lcb_DOCQREQ;

lcb_DOCQUEUE *
lcbdocq_create(lcb_t instance);

void
lcbdocq_add(lcb_DOCQUEUE *q, lcb_DOCQREQ *req);

void
lcbdocq_unref(lcb_DOCQUEUE *);

void
lcbdocq_cancel(lcb_DOCQUEUE *q);

#define lcbdocq_has_pending(q) \
    ((q)->n_awaiting_response || (q)->n_awaiting_schedule)

#ifdef __cplusplus
}
#endif
#endif