/proc/self/cwd/source/extensions/filters/network/dubbo_proxy/dubbo_hessian2_serializer_impl.h
Line | Count | Source (jump to first uncovered line) |
1 | | #pragma once |
2 | | |
3 | | #include "source/extensions/filters/network/dubbo_proxy/message_impl.h" |
4 | | #include "source/extensions/filters/network/dubbo_proxy/serializer.h" |
5 | | |
6 | | namespace Envoy { |
7 | | namespace Extensions { |
8 | | namespace NetworkFilters { |
9 | | namespace DubboProxy { |
10 | | |
11 | | class DubboHessian2SerializerImpl : public Serializer { |
12 | | public: |
13 | 0 | const std::string& name() const override { |
14 | 0 | return ProtocolSerializerNames::get().fromType(ProtocolType::Dubbo, type()); |
15 | 0 | } |
16 | 0 | SerializationType type() const override { return SerializationType::Hessian2; } |
17 | | |
18 | | std::pair<RpcInvocationSharedPtr, bool> |
19 | | deserializeRpcInvocation(Buffer::Instance& buffer, ContextSharedPtr context) override; |
20 | | |
21 | | std::pair<RpcResultSharedPtr, bool> deserializeRpcResult(Buffer::Instance& buffer, |
22 | | ContextSharedPtr context) override; |
23 | | |
24 | | size_t serializeRpcResult(Buffer::Instance& output_buffer, const std::string& content, |
25 | | RpcResponseType type) override; |
26 | | }; |
27 | | |
28 | | } // namespace DubboProxy |
29 | | } // namespace NetworkFilters |
30 | | } // namespace Extensions |
31 | | } // namespace Envoy |