/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */ /* * Copyright 2020-2021 Couchbase, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #pragma once #include #include #include namespace couchbase::operations { struct get_and_lock_response { error_context::key_value ctx; std::string value{}; std::uint64_t cas{}; std::uint32_t flags{}; }; struct get_and_lock_request { using encoded_request_type = protocol::client_request; using encoded_response_type = protocol::client_response; document_id id; uint16_t partition{}; uint32_t opaque{}; uint32_t lock_time{}; std::chrono::milliseconds timeout{ timeout_defaults::key_value_timeout }; io::retry_context retries{ false }; [[nodiscard]] std::error_code encode_to(encoded_request_type& encoded, mcbp_context&& /* context */) const { encoded.opaque(opaque); encoded.partition(partition); encoded.body().id(id); encoded.body().lock_time(lock_time); return {}; } }; get_and_lock_response make_response(error_context::key_value&& ctx, const get_and_lock_request& /* request */, get_and_lock_request::encoded_response_type&& encoded) { get_and_lock_response response{ std::move(ctx) }; if (!response.ctx.ec) { response.value = std::move(encoded.body().value()); response.cas = encoded.cas(); response.flags = encoded.body().flags(); } return response; } } // namespace couchbase::operations