]>
git.proxmox.com Git - ceph.git/blob - ceph/src/cls/queue/cls_queue_client.h
59d32bfa1a7584e02c60feafe2a2b1cce348c137
1 #ifndef CEPH_CLS_QUEUE_CLIENT_H
2 #define CEPH_CLS_QUEUE_CLIENT_H
4 #include "include/rados/librados.hpp"
5 #include "cls/queue/cls_queue_types.h"
6 #include "cls_queue_ops.h"
7 #include "common/ceph_time.h"
9 void cls_queue_init(librados::ObjectWriteOperation
& op
, const string
& queue_name
, uint64_t size
);
10 int cls_queue_get_capacity(librados::IoCtx
& io_ctx
, const string
& oid
, uint64_t& size
);
11 void cls_queue_enqueue(librados::ObjectWriteOperation
& op
, uint32_t expiration_secs
, vector
<bufferlist
> bl_data_vec
);
12 int cls_queue_list_entries(librados::IoCtx
& io_ctx
, const string
& oid
, const string
& marker
, uint32_t max
,
13 vector
<cls_queue_entry
>& entries
, bool *truncated
, string
& next_marker
);
14 void cls_queue_remove_entries(librados::ObjectWriteOperation
& op
, const string
& end_marker
);