| 2138 | } |
| 2139 | |
| 2140 | CouchbaseOperations::Result CouchbaseOperations::upsert( |
| 2141 | const std::string& key, const std::string& value, std::string collection_name) { |
| 2142 | CouchbaseRequest request(&local_bucket_to_collection_manifest_); |
| 2143 | CouchbaseResponse response; |
| 2144 | brpc::Controller cntl; |
| 2145 | CouchbaseOperations::Result result; |
| 2146 | sendRequest(CouchbaseOperations::UPSERT, key, value, collection_name, &result, |
| 2147 | channel_, server_address_, selected_bucket_, &request, &response); |
| 2148 | return result; |
| 2149 | } |
| 2150 | |
| 2151 | CouchbaseOperations::Result CouchbaseOperations::delete_( |
| 2152 | const std::string& key, std::string collection_name) { |
no test coverage detected