| 2095 | } |
| 2096 | } |
| 2097 | CouchbaseOperations::Result CouchbaseOperations::get(const std::string& key, |
| 2098 | std::string collection_name) { |
| 2099 | // create CouchbaseRequest and CouchbaseResponse objects and then using the |
| 2100 | // channel which is created for this thread in authenticate() use it to call() |
| 2101 | CouchbaseRequest request(&local_bucket_to_collection_manifest_); |
| 2102 | CouchbaseResponse response; |
| 2103 | brpc::Controller cntl; |
| 2104 | CouchbaseOperations::Result result; |
| 2105 | sendRequest(CouchbaseOperations::GET, key, "", collection_name, &result, |
| 2106 | channel_, server_address_, selected_bucket_, &request, &response); |
| 2107 | return result; |
| 2108 | } |
| 2109 | |
| 2110 | bool CouchbaseOperations::CouchbaseRequest::getLocalCachedCollectionId( |
| 2111 | const std::string& bucket, const std::string& scope, const std::string& collection, |
nothing calls this directly
no test coverage detected