private:
-@@ -141,8 +141,8 @@
+@@ -145,8 +145,8 @@
std::string m_event_uri;
long m_timeout_ms;
std::string m_url;
@@ -600,7 +628,7 @@
json_query m_jq;
std::string m_http_version;
ssl_ptr_t m_ssl;
-@@ -153,7 +153,7 @@
+@@ -157,7 +157,7 @@
// this flag indicates whether handler should continue to watch after
receiving
// the initial state
bool m_watch;
@@ -609,16 +637,24 @@
// flag indicating whether to connect to K8s API server (no
connection needed when
// replaying capture)
-@@ -163,7 +163,7 @@
+@@ -167,13 +167,13 @@
// it must have its state fully built before this handler can begin
building its own state
ptr_t m_dependency_handler;
+ // limits the number of messages handled in single cycle
+- unsigned m_max_messages = ~0;
+- bool m_state_processing_started = false;
++ unsigned m_max_messages;
++ bool m_state_processing_started;
+
event_list_t m_events;
-@@ -183,9 +183,9 @@
+
+@@ -192,9 +192,9 @@
// at all (eg. there is no need to capture api or extensions
detection data)
//
// global capture flag is checked in the k8s state call
@@ -629,19 +665,19 @@
+ bool m_connect_logged;
};