| 1316 | } |
| 1317 | |
| 1318 | bool CouchbaseOperations::CouchbaseRequest::getCollectionManifest() { |
| 1319 | const policy::CouchbaseRequestHeader header = { |
| 1320 | policy::CB_MAGIC_REQUEST, |
| 1321 | policy::CB_GET_COLLECTIONS_MANIFEST, |
| 1322 | 0, // no key |
| 1323 | 0, // no extras |
| 1324 | policy::CB_BINARY_RAW_BYTES, |
| 1325 | 0, // no vbucket |
| 1326 | 0, // no body (no key, no extras, no value) |
| 1327 | 0, // opaque |
| 1328 | 0 // no CAS |
| 1329 | }; |
| 1330 | if (_buf.append(&header, sizeof(header))) { |
| 1331 | return false; |
| 1332 | } |
| 1333 | ++_pipelined_count; |
| 1334 | return true; |
| 1335 | } |
| 1336 | |
| 1337 | bool CouchbaseOperations::CouchbaseRequest::addRequest( |
| 1338 | const butil::StringPiece& key, const butil::StringPiece& value, |
no test coverage detected