1 files changed, 48 insertions, 0 deletions
diff --git a/src/plugins.d/pluginsd_functions.h b/src/plugins.d/pluginsd_functions.h
new file mode 100644
index 000000000..ad47dc23a
--- /dev/null
+++ b/src/plugins.d/pluginsd_functions.h
@@ -0,0 +1,48 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_PLUGINSD_FUNCTIONS_H
+#define NETDATA_PLUGINSD_FUNCTIONS_H
+
+#include "pluginsd_internals.h"
+
+struct inflight_function {
+    nd_uuid_t transaction;
+
+    int code;
+    int timeout_s;
+    STRING *function;
+    BUFFER *payload;
+    HTTP_ACCESS access;
+    const char *source;
+
+    BUFFER *result_body_wb;
+
+    usec_t *stop_monotonic_ut; // pointer to caller data
+    usec_t started_monotonic_ut;
+    usec_t sent_monotonic_ut;
+    PARSER *parser;
+
+    bool sent_successfully;
+
+    struct {
+        rrd_function_result_callback_t cb;
+        void *data;
+    } result;
+
+    struct {
+        rrd_function_progress_cb_t cb;
+        void *data;
+    } progress;
+};
+
+PARSER_RC pluginsd_function(char **words, size_t num_words, PARSER *parser);
+PARSER_RC pluginsd_function_result_begin(char **words, size_t num_words, PARSER *parser);
+PARSER_RC pluginsd_function_progress(char **words, size_t num_words, PARSER *parser);
+
+void pluginsd_inflight_functions_init(PARSER *parser);
+void pluginsd_inflight_functions_cleanup(PARSER *parser);
+void pluginsd_inflight_functions_garbage_collect(PARSER  *parser, usec_t now_ut);
+
+int pluginsd_function_execute_cb(struct rrd_function_execute *rfe, void *data);
+
+#endif //NETDATA_PLUGINSD_FUNCTIONS_H