Line data Source code
1 : /*
2 : ___________________________________________
3 : | _ ___ _ |
4 : | | | |__ \ | | |
5 : | | |__ ) |__ _ __ _ ___ _ __ | |_ |
6 : | | '_ \ / // _` |/ _` |/ _ \ '_ \| __| | HTTP/2 AGENT FOR MOCK TESTING
7 : | | | | |/ /| (_| | (_| | __/ | | | |_ | Version 0.0.z
8 : | |_| |_|____\__,_|\__, |\___|_| |_|\__| | https://github.com/testillano/h2agent
9 : | __/ | |
10 : | |___/ |
11 : |___________________________________________|
12 :
13 : Licensed under the MIT License <http://opensource.org/licenses/MIT>.
14 : SPDX-License-Identifier: MIT
15 : Copyright (c) 2021 Eduardo Ramos
16 :
17 : Permission is hereby granted, free of charge, to any person obtaining a copy
18 : of this software and associated documentation files (the "Software"), to deal
19 : in the Software without restriction, including without limitation the rights
20 : to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
21 : copies of the Software, and to permit persons to whom the Software is
22 : furnished to do so, subject to the following conditions:
23 :
24 : The above copyright notice and this permission notice shall be included in all
25 : copies or substantial portions of the Software.
26 :
27 : THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
28 : IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
29 : FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
30 : AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
31 : LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
32 : OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
33 : SOFTWARE.
34 : */
35 :
36 : #pragma once
37 :
38 : #include <memory>
39 : #include <string>
40 : #include <vector>
41 : #include <regex>
42 : #include <cstdint>
43 :
44 : #include <nlohmann/json.hpp>
45 :
46 : #include <AdminSchema.hpp>
47 : #include <Transformation.hpp>
48 : #include <TypeConverter.hpp>
49 : #include <DataPart.hpp>
50 :
51 : #include <MyTrafficHttp2Client.hpp>
52 :
53 : #include <ert/metrics/Metrics.hpp>
54 :
55 :
56 :
57 : namespace h2agent
58 : {
59 : namespace model
60 : {
61 :
62 : // Client endpoint key:
63 : typedef std::string admin_client_endpoint_key_t;
64 :
65 : class AdminClientEndpoint
66 : {
67 : nlohmann::json json_{}; // client endpoint reference
68 :
69 : admin_client_endpoint_key_t key_{};
70 :
71 : // Cached information:
72 : std::string host_{};
73 : int port_{};
74 : bool secure_{};
75 : bool permit_{};
76 :
77 : std::shared_ptr<h2agent::http2::MyTrafficHttp2Client> client_{};
78 :
79 : // Metrics for client:
80 : std::string application_name_{};
81 : ert::metrics::Metrics *metrics_{};
82 : ert::metrics::bucket_boundaries_t response_delay_seconds_histogram_bucket_boundaries_{};
83 : ert::metrics::bucket_boundaries_t message_size_bytes_histogram_bucket_boundaries_{};
84 :
85 : public:
86 :
87 22 : AdminClientEndpoint() {}
88 22 : ~AdminClientEndpoint() {}
89 :
90 : // setters:
91 :
92 : /**
93 : * Load client endpoint information
94 : *
95 : * @param j Json client endpoint object
96 : *
97 : * @return Operation success
98 : */
99 : bool load(const nlohmann::json &j);
100 :
101 : /**
102 : * Connects the endpoint
103 : *
104 : * @param fromScratch Indicates if the previous client must be dropped
105 : */
106 : void connect(bool fromScratch = false);
107 :
108 : /**
109 : * Set metrics data
110 : *
111 : * @param metrics Optional metrics object to compute counters and histograms
112 : * @param responseDelaySecondsHistogramBucketBoundaries Optional bucket boundaries for response delay seconds histogram
113 : * @param messageSizeBytesHistogramBucketBoundaries Optional bucket boundaries for message size bytes histogram
114 : * @param applicationName Application/process name used for metrics source label
115 : */
116 : void setMetricsData(ert::metrics::Metrics *metrics, const ert::metrics::bucket_boundaries_t &responseDelaySecondsHistogramBucketBoundaries,
117 : const ert::metrics::bucket_boundaries_t &messageSizeBytesHistogramBucketBoundaries, const std::string &applicationName);
118 :
119 : // getters:
120 :
121 : /**
122 : * Gets the client endpoint key
123 : *
124 : * @return Client endpoint key
125 : */
126 18 : const admin_client_endpoint_key_t &getKey() const {
127 18 : return key_;
128 : }
129 :
130 : /**
131 : * Json for class information and also current connection status
132 : *
133 : * @return Json object
134 : */
135 : nlohmann::json asJson() const;
136 :
137 : /**
138 : * Configured host
139 : *
140 : * @return Host
141 : */
142 15 : const std::string &getHost() const {
143 15 : return host_;
144 : }
145 :
146 : /**
147 : * Configured port
148 : *
149 : * @return Port
150 : */
151 15 : int getPort() const {
152 15 : return port_;
153 : }
154 :
155 : /*
156 : * Configured secure field
157 : *
158 : * @return Secure boolean
159 : */
160 11 : bool getSecure() const {
161 11 : return secure_;
162 : }
163 :
164 : /*
165 : * Configured permit field
166 : *
167 : * @return Permit boolean
168 : */
169 1 : bool getPermit() const {
170 1 : return permit_;
171 : }
172 :
173 : /*
174 : * Get the associated http2 client
175 : *
176 : * @return Http2 client
177 : */
178 0 : std::shared_ptr<h2agent::http2::MyTrafficHttp2Client> getClient() {
179 0 : return client_;
180 : }
181 :
182 : /*
183 : * Get http2 client general unique sequence
184 : *
185 : * @return client sequence (1..N)
186 : */
187 : std::uint64_t getGeneralUniqueClientSequence() const;
188 : };
189 :
190 : }
191 : }
192 :
|
