1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
/*
Copyright (C) 2021 The Falco Authors.
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.
*/
//
// k8s_api_handler.h
//
#if defined(HAS_CAPTURE) && !defined(_WIN32)
#pragma once
#include "json/json.h"
#include "k8s_handler.h"
class k8s_api_handler : public k8s_handler
{
public:
typedef std::vector<std::string> api_list_t;
k8s_api_handler(collector_ptr_t collector,
const std::string& url,
const std::string& path,
const std::string& filter,
const std::string& http_version = "1.1",
ssl_ptr_t ssl = 0,
bt_ptr_t bt = 0,
bool blocking_socket = false,
uint32_t data_max_b = K8S_DATA_MAX_B,
uint32_t data_chunk_wait_us = K8S_DATA_CHUNK_WAIT_US
);
~k8s_api_handler();
bool error() const;
const api_list_t& extensions() const;
bool has(const std::string& version) const;
private:
void handle_json(Json::Value&& root);
bool handle_component(const Json::Value& json, const msg_data* data = 0);
api_list_t m_extensions;
bool m_error = false;
};
inline bool k8s_api_handler::error() const
{
return m_error;
}
inline const k8s_api_handler::api_list_t& k8s_api_handler::extensions() const
{
return m_extensions;
}
#endif // HAS_CAPTURE
|
